static ByteBufPair |
ByteBufPair.get(io.netty.buffer.ByteBuf b1,
io.netty.buffer.ByteBuf b2)
Get a new ByteBufPair from the pool and assign 2 buffers to it. |
static ByteBufPair |
Commands.newMessage(long consumerId,
PulsarApi.MessageIdData messageId,
int redeliveryCount,
io.netty.buffer.ByteBuf metadataAndPayload) |
static ByteBufPair |
Commands.newSend(long producerId,
long sequenceId,
int numMessages,
Commands.ChecksumType checksumType,
PulsarApi.MessageMetadata messageData,
io.netty.buffer.ByteBuf payload) |