diff options
Diffstat (limited to 'cpp/src/tests/echotest.cpp')
-rw-r--r-- | cpp/src/tests/echotest.cpp | 4 |
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')); |