public class BlobMessageConsumer extends AbstractConsumer<BlobMessage>
Modifier and Type | Field and Description |
---|---|
protected BlobInfoWriter |
blobInfoWriter |
protected BlobProvider |
blobProvider |
protected String |
blobProviderName |
protected static AtomicInteger |
consumerCounter |
consumerId
Constructor and Description |
---|
BlobMessageConsumer(String consumerId,
String blobProviderName,
BlobInfoWriter blobInfoWriter) |
Modifier and Type | Method and Description |
---|---|
void |
accept(BlobMessage message)
Consume a message.
|
void |
begin()
Begin a batch of messages.
|
void |
commit()
End of the batch message.
|
void |
rollback()
Called when there is an exception during
Consumer.accept(Message) or Consumer.commit() . |
protected void |
saveBlobInfo(BlobMessage message,
String digest,
long length) |
close, getConsumerId
protected static final AtomicInteger consumerCounter
protected final BlobProvider blobProvider
protected final String blobProviderName
protected final BlobInfoWriter blobInfoWriter
public BlobMessageConsumer(String consumerId, String blobProviderName, BlobInfoWriter blobInfoWriter)
public void accept(BlobMessage message)
Consumer
protected void saveBlobInfo(BlobMessage message, String digest, long length) throws IOException
IOException
public void rollback()
Consumer
Consumer.accept(Message)
or Consumer.commit()
.Copyright © 2018 Nuxeo. All rights reserved.