io.debezium.server.redis

Class RedisStreamChangeConsumer

java.lang.Object

io.debezium.server.BaseChangeConsumer

io.debezium.server.redis.RedisStreamChangeConsumer

All Implemented Interfaces:

DebeziumEngine.ChangeConsumer<ChangeEvent<Object,Object>>

@Named(value="redis")
 @Dependent
public class RedisStreamChangeConsumer
extends BaseChangeConsumer
implements DebeziumEngine.ChangeConsumer<ChangeEvent<Object,Object>>

Implementation of the consumer that delivers the messages into Redis (stream) destination.

Author:

M Sazzadul Hoque

Field Summary

Fields

Modifier and Type	Field and Description
private redis.clients.jedis.HostAndPort	address
private redis.clients.jedis.Jedis	client
(package private) javax.enterprise.inject.Instance<redis.clients.jedis.Jedis>	customClient
private static org.slf4j.Logger	LOGGER
(package private) String	nullKey
private Optional<String>	password
private static String	PROP_ADDRESS
private static String	PROP_PASSWORD
private static String	PROP_PREFIX
private static String	PROP_USER
private Optional<String>	user

Fields inherited from class io.debezium.server.BaseChangeConsumer

streamNameMapper

Constructor Summary

Constructors

Constructor and Description
RedisStreamChangeConsumer()

Method Summary

Modifier and Type	Method and Description
(package private) void	close()
(package private) void	connect()
void	handleBatch(List<ChangeEvent<Object,Object>> records, DebeziumEngine.RecordCommitter<ChangeEvent<Object,Object>> committer)

Methods inherited from class io.debezium.server.BaseChangeConsumer

getBytes, getConfigSubset, getString, unsupportedTypeMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.debezium.engine.DebeziumEngine.ChangeConsumer

supportsTombstoneEvents

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

PROP_PREFIX

private static final String PROP_PREFIX

See Also:

Constant Field Values

PROP_ADDRESS

private static final String PROP_ADDRESS

See Also:

Constant Field Values

PROP_USER

private static final String PROP_USER

See Also:

Constant Field Values

PROP_PASSWORD

private static final String PROP_PASSWORD

See Also:

Constant Field Values

address

private redis.clients.jedis.HostAndPort address

user

private Optional<String> user

password

private Optional<String> password

nullKey

String nullKey

client

private redis.clients.jedis.Jedis client

customClient

@Inject
 @CustomConsumerBuilder
javax.enterprise.inject.Instance<redis.clients.jedis.Jedis> customClient

Constructor Detail

RedisStreamChangeConsumer

public RedisStreamChangeConsumer()

Method Detail

connect

@PostConstruct
void connect()

close

@PreDestroy
void close()

handleBatch

public void handleBatch(List<ChangeEvent<Object,Object>> records,
                        DebeziumEngine.RecordCommitter<ChangeEvent<Object,Object>> committer)
                 throws InterruptedException

Specified by:

handleBatch in interface DebeziumEngine.ChangeConsumer<ChangeEvent<Object,Object>>

Throws:

InterruptedException