AMQP error invalid end of frame marker

[spider]

Hello!

This was getting buried in another thread, and is kind of a separate issue so I thought I would open a new thread.

Anyway basically this is my Send file/executable C++ code taken from here: https://github.com/RPG-18/rabbitmq-cpp-tutorials/pulls

#include <iostream>

#include <Poco/Net/IPAddress.h>

#include "SimplePocoHandler.h"

int main(void)

{

    const Poco::Net::IPAddress ip("192.168.137.127");

    SimplePocoHandler handler(ip, 5672);

    AMQP::Connection connection(&handler, AMQP::Login("test", "test"), "/");

    AMQP::Channel channel(&connection);

    channel.onReady([&]()

    {

        if (handler.connected())

        {

            channel.publish("", "Leonardo", "Cowabunga!");

            std::cout << " [x] Sent " << std::endl;

            handler.quit();

        }

    });    

    handler.loop();

    return 0;

}

However the messages are not showing up in my localhost even though I have created the queue "Leonardo".

I've attached my wireshark reading and have also displayed it below.

For some reason it is Resetting (see [RST, ACK] at No.66), but I don't know why.

Any help would be much appreciated. 

[Jasser Kafafi]

Quick clarification. When I say "localhost" I'm referring to a different machine/rmq server with the IP,

ip("192.168.137.127");

I meant to take a screenshot of that instead of the localhost of the machine below. 

Either way it's the same idea. It's not receiving the messages. 

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To post to this group, send email to rabbitm...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Luke Bakken]

Hello,

I followed up here:

https://groups.google.com/d/msg/rabbitmq-users/OF-FYIuUaqg/UwuTmmStCAAJ

and I followed up here:

https://github.com/RPG-18/rabbitmq-cpp-tutorials/pull/1#issuecomment-392766862

There may be someone who reads this list and is familiar with the AMQP-CPP library who can help you out.

I think your best path forward is to use the latest AMQP-CPP code and carefully examine the examples for your use. For instance, there is example code that uses libevent here: https://github.com/CopernicaMarketingSoftware/AMQP-CPP/blob/master/examples/libevent.cpp

Thanks,

Luke

On Tuesday, May 29, 2018 at 1:21:33 AM UTC-7, spider wrote:

Quick clarification. When I say "localhost" I'm referring to a different machine/rmq server with the IP,

ip("192.168.137.127");

I meant to take a screenshot of that instead of the localhost of the machine below. 

Either way it's the same idea. It's not receiving the messages. 

[spider]

I replaced all the amqcp files with the newest versions but I still get the same error.

I do not see how this example https://github.com/CopernicaMarketingSoftware/AMQP-CPP/blob/master/examples/libevent.cpp

would help fix the bug in this code as you mention in your last comment here https://github.com/RPG-18/rabbitmq-cpp-tutorials/pull/1#issuecomment-392766862

[spider]

Here is a packet reading from my successful Java program.