Class AbstractConsumer<M extends Message>
java.lang.Object
org.nuxeo.lib.stream.pattern.consumer.AbstractConsumer<M>
- All Implemented Interfaces:
AutoCloseable
,Consumer<M>
- Direct Known Subclasses:
BlobMessageConsumer
,DocumentMessageConsumer
- Since:
- 9.1
-
Field Details
-
consumerId
-
-
Constructor Details
-
AbstractConsumer
-
-
Method Details
-
getConsumerId
-
close
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
-