public class BlobMessageConsumer extends AbstractConsumer<BlobMessage>
Modifier and Type | Class and Description |
---|---|
class |
BlobMessageConsumer.CloseableBlob |
Modifier and Type | Field and Description |
---|---|
protected BlobInfoWriter |
blobInfoWriter |
protected BlobProvider |
blobProvider |
protected String |
blobProviderName |
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.
|
protected BlobMessageConsumer.CloseableBlob |
getBlob(BlobMessage 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,
File blobFile) |
close, getConsumerId
protected 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 BlobMessageConsumer.CloseableBlob getBlob(BlobMessage message)
protected void saveBlobInfo(BlobMessage message, String digest, long length, File blobFile)
public void rollback()
Consumer
Consumer.accept(Message)
or Consumer.commit()
.Copyright © 2019 Nuxeo. All rights reserved.