summaryrefslogtreecommitdiff
path: root/cpp/client/src/Connection.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/client/src/Connection.cpp')
-rw-r--r--cpp/client/src/Connection.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/client/src/Connection.cpp b/cpp/client/src/Connection.cpp
index eeb2330561..f332d2242c 100644
--- a/cpp/client/src/Connection.cpp
+++ b/cpp/client/src/Connection.cpp
@@ -37,9 +37,9 @@ Connection::~Connection(){
delete connector;
}
-void Connection::open(const std::string& host, int port, const std::string& uid, const std::string& pwd, const std::string& virtualhost){
- this->host = host;
- this->port = port;
+void Connection::open(const std::string& _host, int _port, const std::string& uid, const std::string& pwd, const std::string& virtualhost){
+ host = _host;
+ port = _port;
connector->setInputHandler(this);
connector->setTimeoutHandler(this);
connector->setShutdownHandler(this);
@@ -181,15 +181,15 @@ void Connection::handleMethod(AMQMethodBody::shared_ptr body){
}
}
-void Connection::handleHeader(AMQHeaderBody::shared_ptr body){
+void Connection::handleHeader(AMQHeaderBody::shared_ptr /*body*/){
error(504, "Channel error: received header body with channel 0.");
}
-void Connection::handleContent(AMQContentBody::shared_ptr body){
+void Connection::handleContent(AMQContentBody::shared_ptr /*body*/){
error(504, "Channel error: received content body with channel 0.");
}
-void Connection::handleHeartbeat(AMQHeartbeatBody::shared_ptr body){
+void Connection::handleHeartbeat(AMQHeartbeatBody::shared_ptr /*body*/){
}
void Connection::sendAndReceive(AMQFrame* frame, const AMQMethodBody& body){
@@ -204,7 +204,7 @@ void Connection::error(int code, const string& msg, int classid, int methodid){
std::cout << " [" << methodid << ":" << classid << "]";
}
std::cout << std::endl;
- sendAndReceive(new AMQFrame(0, new ConnectionCloseBody(code, (string&) msg, classid, methodid)), connection_close_ok);
+ sendAndReceive(new AMQFrame(0, new ConnectionCloseBody(code, msg, classid, methodid)), connection_close_ok);
connector->close();
}