summaryrefslogtreecommitdiff
path: root/cpp/src/tests/echotest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/echotest.cpp')
-rw-r--r--cpp/src/tests/echotest.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/cpp/src/tests/echotest.cpp b/cpp/src/tests/echotest.cpp
index a57e2de5ad..7cbf3e7df4 100644
--- a/cpp/src/tests/echotest.cpp
+++ b/cpp/src/tests/echotest.cpp
@@ -92,9 +92,7 @@ void Listener::start(uint size)
{
session.queueDeclare(arg::queue=queue, arg::exclusive=true, arg::autoDelete=true);
request.getDeliveryProperties().setRoutingKey(queue);
- subscriptions.setAcceptMode(1/*not-required*/);
- subscriptions.setFlowControl(SubscriptionManager::UNLIMITED, SubscriptionManager::UNLIMITED, false);
- subscriptions.subscribe(*this, queue);
+ subscriptions.subscribe(*this, queue, SubscriptionSettings(FlowControl::unlimited(), ACCEPT_MODE_NONE));
request.getDeliveryProperties().setTimestamp(current_time());
if (size) request.setData(std::string(size, 'X'));