diff options
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/tests/topic_listener.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/tests/topic_publisher.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/tests/topic_listener.cpp b/cpp/src/tests/topic_listener.cpp index ba6cd5f267..8f0e290070 100644 --- a/cpp/src/tests/topic_listener.cpp +++ b/cpp/src/tests/topic_listener.cpp @@ -181,7 +181,7 @@ void Listener::report(){ << time/TIME_MSEC << " ms."; Message msg(reportstr.str(), responseQueue); msg.getHeaders().setString("TYPE", "REPORT"); - session.messageTransfer(arg::content=msg, arg::acceptMode=1); + session.messageTransfer(arg::destination="amq.direct", arg::content=msg, arg::acceptMode=1); if(transactional){ session.txCommit(); } diff --git a/cpp/src/tests/topic_publisher.cpp b/cpp/src/tests/topic_publisher.cpp index a4d0dd9382..a6a7b4d80d 100644 --- a/cpp/src/tests/topic_publisher.cpp +++ b/cpp/src/tests/topic_publisher.cpp @@ -113,8 +113,8 @@ int main(int argc, char** argv) { } - //declare queue (relying on default binding): session.queueDeclare(arg::queue="response"); + session.exchangeBind(arg::exchange="amq.direct", arg::queue="response", arg::bindingKey="response"); Publisher publisher(session, "topic_control", args.transactional, args.durable); |