org.nuxeo.importer.stream.consumer

Class RedisDocumentMessageConsumerFactory

java.lang.Object

org.nuxeo.importer.stream.consumer.RedisDocumentMessageConsumerFactory

All Implemented Interfaces:

ConsumerFactory<DocumentMessage>

public class RedisDocumentMessageConsumerFactory
extends Object
implements ConsumerFactory<DocumentMessage>

Since:

10.2

Field Summary

Fields

Modifier and Type	Field and Description
protected String	redisPrefix

Constructor Summary

Constructors

Constructor and Description
RedisDocumentMessageConsumerFactory()
RedisDocumentMessageConsumerFactory(String redisPrefix)

Method Summary

Modifier and Type	Method and Description
Consumer<DocumentMessage>	createConsumer(String consumerId)

Methods inherited from class java.lang.Object

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

Field Detail

redisPrefix

protected final String redisPrefix

Constructor Detail

RedisDocumentMessageConsumerFactory

public RedisDocumentMessageConsumerFactory()

RedisDocumentMessageConsumerFactory

public RedisDocumentMessageConsumerFactory(String redisPrefix)

Method Detail

createConsumer

public Consumer<DocumentMessage> createConsumer(String consumerId)

Specified by:

createConsumer in interface ConsumerFactory<DocumentMessage>

Parameters:

consumerId - the consumer identifier