Package 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
    Description
    Consumer<M>
    createConsumer(String consumerId)
     

  • Method Details

    • createConsumer

      Consumer<M> createConsumer(String consumerId)
      Parameters:
      consumerId - the consumer identifier