Package org.apache.pulsar.client.api
Interface BatchMessageContainer
Batch message container for individual messages being published until they are batched and sent to broker.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
clear()
Clear the message batch container.void
Release the payload and clear the container.int
Get current allocated buffer size of the message batch container in bytes.long
Get current message batch size of the message batch container in bytes.int
Get count of messages in the message batch container.boolean
isEmpty()
Check the message batch container is empty.boolean
Return the batch container batch message in multiple batches.
-
Method Details
-
clear
void clear()Clear the message batch container. -
isEmpty
boolean isEmpty()Check the message batch container is empty.- Returns:
- return true if empty, otherwise return false.
-
getNumMessagesInBatch
int getNumMessagesInBatch()Get count of messages in the message batch container.- Returns:
- messages count
-
getCurrentBatchSize
long getCurrentBatchSize()Get current message batch size of the message batch container in bytes.- Returns:
- message batch size in bytes
-
getBatchAllocatedSizeBytes
int getBatchAllocatedSizeBytes()Get current allocated buffer size of the message batch container in bytes.- Returns:
- allocated buffer size in bytes
-
discard
Release the payload and clear the container.- Parameters:
ex
- cause
-
isMultiBatches
boolean isMultiBatches()Return the batch container batch message in multiple batches.- Returns:
-