Skip to content

pulsar
pulsar

apache / pulsar

通知 129
Star 40
Fork 3
pulsar
pulsar

体验新版 GitCode，发现更多精彩内容 >>

提交 776042ba 编写于 作者: S sschepens 提交者： Matteo Merli
浏览文件
操作

Increment receive timeout on PerMessageUnAcknowledgedRedeliveryTest to prevent failing tests (#85)

上级 4d685b51
隐藏空白更改
内联 并排
Showing with 16 addition and 16 deletion
pulsar-broker/src/test/java/com/yahoo/pulsar/client/impl/PerMessageUnAcknowledgedRedeliveryTest.java
浏览文件 @ 776042ba
......@@ -81,7 +81,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
long size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -102,7 +102,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -124,7 +124,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -140,7 +140,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
assertEquals(redelivered, 5);
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
......@@ -178,7 +178,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
long size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -199,7 +199,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -221,7 +221,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -237,7 +237,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
assertEquals(redelivered, 10);
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
......@@ -275,7 +275,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
long size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -296,7 +296,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -318,7 +318,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -334,7 +334,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
assertEquals(redelivered, 10);
size = ((ConsumerImpl) consumer).getUnAckedMessageTracker().size();
......@@ -381,7 +381,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
long size = getUnackedMessagesCountInPartitionedConsumer(consumer);
......@@ -403,7 +403,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = getUnackedMessagesCountInPartitionedConsumer(consumer);
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -425,7 +425,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
while (message != null) {
String data = new String(message.getData());
log.info("Consumer received : " + data);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
size = getUnackedMessagesCountInPartitionedConsumer(consumer);
log.info(key + " Unacked Message Tracker size is " + size);
......@@ -441,7 +441,7 @@ public class PerMessageUnAcknowledgedRedeliveryTest extends BrokerTestBase {
String data = new String(message.getData());
log.info("Consumer received : " + data);
consumer.acknowledge(message);
message = consumer.receive(10, TimeUnit.MILLISECONDS);
message = consumer.receive(100, TimeUnit.MILLISECONDS);
}
assertEquals(redelivered, 5);
size = getUnackedMessagesCountInPartitionedConsumer(consumer);
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或