Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include <SimpleAmqpClient/SimpleAmqpClient.h>
- int main()
- {
- /*explicit Channel(const std::string &host, int port,
- const std::string &username, const std::string &password,
- const std::string &vhost, int frame_max);*/
- AmqpClient::Channel* connection = new AmqpClient::Channel("127.0.0.1", 5672, "guest", "guest", "/", 131072);
- connection->DeclareExchange("exchange", "direct");
- connection->DeclareQueue("queue");
- AmqpClient::BasicMessage::ptr_t message = AmqpClient::BasicMessage::Create("Hello World");
- connection->BasicPublish("exchange", "", message, true, false);
- return 0;
- }
Advertisement
Add Comment
Please, Sign In to add comment