org.nuxeo.lib.stream.pattern.consumer

Interface ConsumerFactory<M extends Message>

All Known Implementing Classes:

BlobMessageConsumerFactory, DocumentMessageConsumerFactory

public interface ConsumerFactory<M extends Message>

Since:

9.1

Method Summary

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

Method Detail

createConsumer

Consumer<M> createConsumer(String consumerId)

Parameters:

consumerId - the consumer identifier