You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2022/08/26 17:07:11 UTC
[pulsar] branch master updated: [fix][broker] Fix broken build caused by conflict between #17195 and #16605 (#17300)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new ba9c01fbc78 [fix][broker] Fix broken build caused by conflict between #17195 and #16605 (#17300)
ba9c01fbc78 is described below
commit ba9c01fbc78782d2e9a303dddc17450e74e41e7c
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Fri Aug 26 20:07:02 2022 +0300
[fix][broker] Fix broken build caused by conflict between #17195 and #16605 (#17300)
- #17195 changed the method signature that #16605 depended upon
---
.../java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java
index a5e77a5bcdd..41ba4168d0f 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java
@@ -220,7 +220,7 @@ class BatchMessageContainerImpl extends AbstractBatchMessageContainer {
messageMetadata.copyFrom(messages.get(0).getMessageBuilder());
ByteBuf encryptedPayload = producer.encryptMessage(messageMetadata, getCompressedBatchMetadataAndPayload());
ByteBufPair cmd = producer.sendMessage(producer.producerId, messageMetadata.getSequenceId(),
- 1, messageMetadata, encryptedPayload);
+ 1, null, messageMetadata, encryptedPayload);
final OpSendMsg op;
// Shouldn't call create(MessageImpl<?> msg, ByteBufPair cmd, long sequenceId, SendCallback callback),