public class BlobMessageConsumer extends AbstractConsumer<BlobMessage>
Constructor and Description |
---|
BlobMessageConsumer(String consumerId,
String blobProviderName,
Path outputBlobInfoDirectory) |
Modifier and Type | Method and Description |
---|---|
void |
accept(BlobMessage message)
Consume a message.
|
void |
begin()
Begin a batch of messages.
|
void |
close() |
void |
commit()
End of the batch message.
|
void |
rollback()
Called when there is an exception during
Consumer.accept(Message) or Consumer.commit() . |
getConsumerId
public BlobMessageConsumer(String consumerId, String blobProviderName, Path outputBlobInfoDirectory)
public void close() throws Exception
close
in interface AutoCloseable
close
in class AbstractConsumer<BlobMessage>
Exception
public void accept(BlobMessage message)
Consumer
public void rollback()
Consumer
Consumer.accept(Message)
or Consumer.commit()
.Copyright © 2017 Nuxeo. All rights reserved.