Package org.nuxeo.lib.stream.pattern.consumer

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, RedisDocumentMessageConsumer

public abstract class AbstractConsumer<M extends Message>
extends Object
implements Consumer<M>

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected String	consumerId

Constructor Summary

Constructors

Constructor	Description
AbstractConsumer(String consumerId)

Method Summary

Modifier and Type	Method	Description
void	close()
String	getConsumerId()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.pattern.consumer.Consumer

accept, begin, commit, rollback

Field Detail

consumerId

protected final String consumerId

Constructor Detail

AbstractConsumer

public AbstractConsumer(String consumerId)

Method Detail

getConsumerId

public String getConsumerId()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception