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

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

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected final 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 Details

consumerId

protected final String consumerId

Constructor Details

AbstractConsumer

public AbstractConsumer(String consumerId)

Method Details

getConsumerId

public String getConsumerId()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception