|
Change Return Type ByteBuf to ByteBufPair in method private serializeCommandSendWithSize(cmdBuilder BaseCommand.Builder, checksumType ChecksumType, msgMetadata MessageMetadata, payload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method public get(b1 ByteBuf, b2 ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.ByteBufPair |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method public newSend(producerId long, sequenceId long, numMessages int, checksumType ChecksumType, messageData MessageMetadata, payload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method private serializeCommandMessageWithSize(cmd BaseCommand, metadataAndPayload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method private sendMessage(producerId long, sequenceId long, numMessages int, msgMetadata MessageMetadata, compressedPayload ByteBuf) : ByteBufPair in class org.apache.pulsar.client.impl.ProducerImpl |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method public newMessage(consumerId long, messageId MessageIdData, metadataAndPayload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method public serialize() : ByteBufPair in class org.apache.pulsar.client.api.RawMessage |
From |
To |
|
Change Return Type boolean to int in method public readableBytes() : int in class org.apache.pulsar.common.api.ByteBufPair |
From |
To |
|
Change Return Type ByteBuf to ByteBufPair in method public serialize() : ByteBufPair in class org.apache.pulsar.client.impl.RawMessageImpl |
From |
To |
|
Change Variable Type clientCommand : ByteBuf to clientCommand : ByteBufPair in method public testChecksumSendCommand() : void in class org.apache.pulsar.common.compression.CommandsTest |
From |
To |
|
Change Variable Type res : ByteBuf to res : ByteBufPair in method public newMessage(consumerId long, messageId MessageIdData, metadataAndPayload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Variable Type cmd : ByteBuf to cmd : ByteBufPair in method private batchMessageAndSend() : void in class org.apache.pulsar.client.impl.ProducerImpl |
From |
To |
|
Change Variable Type cmd : ByteBuf to cmd : ByteBufPair in method public sendAsync(message Message, callback SendCallback) : void in class org.apache.pulsar.client.impl.ProducerImpl |
From |
To |
|
Change Variable Type command : ByteBuf to command : ByteBufPair in method private serializeCommandSendWithSize(cmdBuilder BaseCommand.Builder, checksumType ChecksumType, msgMetadata MessageMetadata, payload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Variable Type res : ByteBuf to res : ByteBufPair in method public newSend(producerId long, sequenceId long, numMessages int, checksumType ChecksumType, messageData MessageMetadata, payload ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.Commands |
From |
To |
|
Change Variable Type metaPayloadBuf : ByteBuf to metaPayloadBuf : ByteBufPair in method private computeChecksum(msgMetadata MessageMetadata, compressedPayload ByteBuf) : int in class org.apache.pulsar.common.compression.CommandsTest |
From |
To |
|
Change Variable Type cmd : ByteBuf to cmd : ByteBufPair in method public testCorruptMessageRemove() : void in class org.apache.pulsar.client.impl.MessageIdTest |
From |
To |
|
Change Variable Type buf : DoubleByteBuf to buf : ByteBufPair in method public get(b1 ByteBuf, b2 ByteBuf) : ByteBufPair in class org.apache.pulsar.common.api.ByteBufPair |
From |
To |