summaryrefslogtreecommitdiff
path: root/cpp/tests/InProcessBroker.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/tests/InProcessBroker.h')
-rw-r--r--cpp/tests/InProcessBroker.h25
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