diff options
| author | Alan Conway <aconway@apache.org> | 2007-03-21 19:12:14 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2007-03-21 19:12:14 +0000 |
| commit | c1b0ba624ff2de40b23342cf2a96885342884dad (patch) | |
| tree | f4fa4ef721b1fe98543cb49cc2c31f03cee452ed /cpp/tests/InProcessBroker.h | |
| parent | df4faa062b3512312c78167bfbdf19ff969210ac (diff) | |
| download | qpid-python-c1b0ba624ff2de40b23342cf2a96885342884dad.tar.gz | |
Refactored client side for dual-mode Channel supporting either 0-9 Message or 0-8 Basic.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@520972 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/tests/InProcessBroker.h')
| -rw-r--r-- | cpp/tests/InProcessBroker.h | 25 |
1 files changed, 15 insertions, 10 deletions
diff --git a/cpp/tests/InProcessBroker.h b/cpp/tests/InProcessBroker.h index 709ca9b953..833b821d11 100644 --- a/cpp/tests/InProcessBroker.h +++ b/cpp/tests/InProcessBroker.h @@ -145,25 +145,30 @@ std::ostream& operator<<( return out; } +} // namespace broker -}} // namespace qpid::broker - +namespace client { /** An in-process client+broker all in one. */ -class InProcessBrokerClient : public qpid::client::Connection { +class InProcessBrokerClient : public client::Connection { public: - qpid::broker::InProcessBroker broker; - qpid::broker::InProcessBroker::Conversation& conversation; + broker::InProcessBroker broker; + broker::InProcessBroker::Conversation& conversation; /** Constructor creates broker and opens client connection. */ - InProcessBrokerClient(qpid::framing::ProtocolVersion version= - qpid::framing::highestProtocolVersion - ) : broker(version), conversation(broker.conversation) + InProcessBrokerClient( + u_int32_t max_frame_size=65536, + framing::ProtocolVersion version= framing::highestProtocolVersion + ) : client::Connection(false, max_frame_size, version), + broker(version), + conversation(broker.conversation) { setConnector(broker); open(""); } - - ~InProcessBrokerClient() {} }; + +}} // namespace qpid::client + + #endif // _tests_InProcessBroker_h |
