This is an automated email from the ASF dual-hosted git repository.
tison 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 034e6a42f34 [fix][test] Fix `testLargeMessage` doesn't respect the
parameter `clientSizeMaxMessageSize` (#18452)
034e6a42f34 is described below
commit 034e6a42f3413c974d370eef258047e9a6ff869e
Author: Zike Yang <[email protected]>
AuthorDate: Tue Nov 15 11:17:09 2022 +0800
[fix][test] Fix `testLargeMessage` doesn't respect the parameter
`clientSizeMaxMessageSize` (#18452)
Signed-off-by: Zike Yang <[email protected]>
---
.../java/org/apache/pulsar/client/impl/MessageChunkingTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingTest.java
index b1eb6fb3846..92771c11581 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingTest.java
@@ -116,10 +116,10 @@ public class MessageChunkingTest extends
ProducerConsumerBase {
public void testLargeMessage(boolean ackReceiptEnabled, boolean
clientSizeMaxMessageSize) throws Exception {
log.info("-- Starting {} test --", methodName);
- clientSizeMaxMessageSize = false;
- this.conf.setMaxMessageSize(50);
if (clientSizeMaxMessageSize) {
- this.conf.setMaxMessageSize(5);
+ this.conf.setMaxMessageSize(35);
+ } else {
+ this.conf.setMaxMessageSize(50);
}
final int totalMessages = 5;
final String topicName = "persistent://my-property/my-ns/my-topic1";
@@ -130,7 +130,7 @@ public class MessageChunkingTest extends
ProducerConsumerBase {
ProducerBuilder<byte[]> producerBuilder =
pulsarClient.newProducer().topic(topicName);
if (clientSizeMaxMessageSize) {
- producerBuilder.chunkMaxMessageSize(5);
+ producerBuilder.chunkMaxMessageSize(35);
}
Producer<byte[]> producer =
producerBuilder.compressionType(CompressionType.LZ4).enableChunking(true)
