summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/Connection.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/broker/Connection.cpp')
-rw-r--r--cpp/lib/broker/Connection.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/lib/broker/Connection.cpp b/cpp/lib/broker/Connection.cpp
index ae0114cba9..dbc8149cb5 100644
--- a/cpp/lib/broker/Connection.cpp
+++ b/cpp/lib/broker/Connection.cpp
@@ -76,15 +76,15 @@ void Connection::close(
getOutput().close();
}
-void Connection::initiated(framing::ProtocolInitiation* header) {
- version = ProtocolVersion(header->getMajor(), header->getMinor());
+void Connection::initiated(const framing::ProtocolInitiation& header) {
+ version = ProtocolVersion(header.getMajor(), header.getMinor());
FieldTable properties;
string mechanisms("PLAIN");
string locales("en_US");
getChannel(0).init(0, *out, getVersion());
client = &getChannel(0).getAdatper().getProxy().getConnection();
client->start(
- header->getMajor(), header->getMinor(),
+ header.getMajor(), header.getMinor(),
properties, mechanisms, locales);
}