diff --git a/src/SimplePocoHandler.cpp b/src/SimplePocoHandler.cpp index 1a9feff..b9773ca 100644 --- a/src/SimplePocoHandler.cpp +++ b/src/SimplePocoHandler.cpp @@ -4,6 +4,8 @@ #include #include #include + +#include #include #include "SimplePocoHandler.h" @@ -84,6 +86,7 @@ struct SimplePocoHandlerImpl Buffer outBuffer; std::vector tmpBuff; }; + SimplePocoHandler::SimplePocoHandler(const std::string& host, uint16_t port) : m_impl(new SimplePocoHandlerImpl) { @@ -92,6 +95,14 @@ SimplePocoHandler::SimplePocoHandler(const std::string& host, uint16_t port) : m_impl->socket.setKeepAlive(true); } +SimplePocoHandler::SimplePocoHandler(const Poco::Net::IPAddress& ip, uint16_t port) : + m_impl(new SimplePocoHandlerImpl) +{ + const Poco::Net::SocketAddress address(ip, port); + m_impl->socket.connect(address); + m_impl->socket.setKeepAlive(true); +} + SimplePocoHandler::~SimplePocoHandler() { close(); diff --git a/src/SimplePocoHandler.h b/src/SimplePocoHandler.h index 3a9aa3c..80c1dd9 100644 --- a/src/SimplePocoHandler.h +++ b/src/SimplePocoHandler.h @@ -4,6 +4,8 @@ #include #include +#include + class SimplePocoHandlerImpl; class SimplePocoHandler: public AMQP::ConnectionHandler { @@ -13,6 +15,7 @@ class SimplePocoHandler: public AMQP::ConnectionHandler static constexpr size_t TEMP_BUFFER_SIZE = 1024 * 1024; //1Mb SimplePocoHandler(const std::string& host, uint16_t port); + SimplePocoHandler(const Poco::Net::IPAddress& ip, uint16_t port); virtual ~SimplePocoHandler(); void loop(); diff --git a/src/send.cpp b/src/send.cpp index 9b42a15..2b6d0cc 100644 --- a/src/send.cpp +++ b/src/send.cpp @@ -1,17 +1,19 @@ #include +#include #include "SimplePocoHandler.h" int main(void) { - SimplePocoHandler handler("localhost", 5672); + Poco::Net::IPAddress ip("127.0.0.1"); + SimplePocoHandler handler(ip, 5672); AMQP::Connection connection(&handler, AMQP::Login("guest", "guest"), "/"); AMQP::Channel channel(&connection); channel.onReady([&]() { - if(handler.connected()) + if (handler.connected()) { channel.publish("", "hello", "Hello World!"); std::cout << " [x] Sent 'Hello World!'" << std::endl;