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 Description protected String
redisPrefix
-
Constructor Summary
Constructors Constructor Description RedisDocumentMessageConsumerFactory()
RedisDocumentMessageConsumerFactory(String redisPrefix)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Consumer<DocumentMessage>
createConsumer(String consumerId)
-
-
-
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 interfaceConsumerFactory<DocumentMessage>
- Parameters:
consumerId
- the consumer identifier
-
-