From 3a87c67be419a3ae74ea456ae67be5d0f2d2ec92 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 9 May 2007 17:00:32 +0000 Subject: * Added support for channel.flow: cpp/tests/ChannelTest.cpp cpp/lib/broker/SessionHandlerImpl.cpp cpp/lib/broker/BrokerChannel.h cpp/lib/broker/BrokerChannel.cpp * Fixed client connection closing process: cpp/lib/common/sys/apr/Socket.cpp cpp/lib/client/Connector.h cpp/lib/client/Connector.cpp cpp/lib/client/Connection.h cpp/lib/client/Connection.cpp * Use amq.direct rather than default exchange in P2P test (to interop with java) cpp/tests/BasicP2Ptest.h git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@536584 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/tests/BasicP2PTest.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'cpp/tests/BasicP2PTest.h') diff --git a/cpp/tests/BasicP2PTest.h b/cpp/tests/BasicP2PTest.h index 989344bb47..8b5d0e7a8c 100644 --- a/cpp/tests/BasicP2PTest.h +++ b/cpp/tests/BasicP2PTest.h @@ -71,7 +71,7 @@ public: std::string queue = params.getString("P2P_QUEUE_AND_KEY_NAME"); int messages = params.getInt("P2P_NUM_MESSAGES"); if (role == "SENDER") { - worker = std::auto_ptr(new Sender(options, Exchange::DEFAULT_EXCHANGE, queue, messages)); + worker = std::auto_ptr(new Sender(options, Exchange::STANDARD_DIRECT_EXCHANGE, queue, messages)); } else if(role == "RECEIVER"){ worker = std::auto_ptr(new Receiver(options, queue, messages)); } else { -- cgit v1.2.1