[Question/Help] C++ simple send example not showing in management plugin

Jasser Kafafi

unread,

May 25, 2018, 10:05:32 PM5/25/18

to rabbitmq-users

When I make send with cmake and execute the send file in terminal it seems to execute fine but I get AMQP error invalid end of frame marker

No que is made/visible when I log into

http://localhost:15672/#/queues

Here is the code for the send file.

Any help is much appreciated!

#include <iostream>

#include "SimplePocoHandler.h"

int main(void)

{

SimplePocoHandler handler("localhost", 5672);

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

AMQP::Channel channel(&connection);

channel.onReady([&]()

{

if(handler.connected())

for (int i=1; i<=2; i++)

{

channel.publish("", "hello", "Hello World!");

std::cout << " [x] Sent 'Hello World!'" << std::endl;

handler.quit();

}

});

Michael Klishin

unread,

May 25, 2018, 11:31:06 PM5/25/18

to rabbitm...@googlegroups.com

Start with inspecting server logs and going through the methodology described in [1].

It would help others a lot if the actual error/stack trace was shared instead of "an invalid end of frame marker".

1. https://www.rabbitmq.com/troubleshooting-networking.html

--
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-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

MK

Staff Software Engineer, Pivotal/RabbitMQ

Michael Klishin

unread,

May 25, 2018, 11:31:31 PM5/25/18

to rabbitm...@googlegroups.com

Wireshark [1] can provide a lot of relevant information, too.

1. http://www.rabbitmq.com/amqp-wireshark.html

To post to this group, send email to rabbitm...@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

--
MK

Staff Software Engineer, Pivotal/RabbitMQ

spider

unread,

May 26, 2018, 4:41:36 AM5/26/18

to rabbitmq-users

I've followed the first 2 steps in https://www.rabbitmq.com/troubleshooting-networking.html

however it does not specify where to look in order to:

Check server logs (see above)
Verify hostname resolution
Verify TCP port connectivity
Verify IP routing
If needed, take and analyze a traffic dump (traffic capture)
"It would help others a lot if the actual error/stack trace" is that what I have below? Where would I find this stack trace?

Sorry I am really new to this

pi@raspberrypi:~ $ sudo rabbitmqctl status

Status of node rabbit@raspberrypi ...

[{pid,384},

{running_applications,

[{rabbitmq_management,"RabbitMQ Management Console","3.7.5"},

{rabbitmq_web_dispatch,"RabbitMQ Web Dispatcher","3.7.5"},

{cowboy,"Small, fast, modern HTTP server.","2.2.2"},

{rabbitmq_management_agent,"RabbitMQ Management Agent","3.7.5"},

{cowlib,"Support library for manipulating Web protocols.","2.1.0"},

{amqp_client,"RabbitMQ AMQP Client","3.7.5"},

{rabbit,"RabbitMQ","3.7.5"},

{rabbit_common,

"Modules shared by rabbitmq-server and rabbitmq-erlang-client",

"3.7.5"},

{ranch_proxy_protocol,"Ranch Proxy Protocol Transport","1.5.0"},

{ranch,"Socket acceptor pool for TCP protocols.","1.5.0"},

{ssl,"Erlang/OTP SSL application","8.2.2"},

{public_key,"Public key infrastructure","1.5.1"},

{crypto,"CRYPTO","4.1"},

{asn1,"The Erlang ASN1 compiler version 5.0.3","5.0.3"},

{xmerl,"XML parser","1.3.15"},

{mnesia,"MNESIA CXC 138 12","4.15.1"},

{recon,"Diagnostic tools for production use","2.3.2"},

{os_mon,"CPO CXC 138 46","2.4.3"},

{inets,"INETS CXC 138 49","6.4.4"},

{jsx,"a streaming, evented json parsing toolkit","2.8.2"},

{lager,"Erlang logging framework","3.5.1"},

{goldrush,"Erlang event stream processor","0.1.9"},

{compiler,"ERTS CXC 138 10","7.1.3"},

{syntax_tools,"Syntax tools","2.1.3"},

{sasl,"SASL CXC 138 11","3.1"},

{stdlib,"ERTS CXC 138 10","3.4.2"},

{kernel,"ERTS CXC 138 10","5.4"}]},

{os,{unix,linux}},

{erlang_version,

"Erlang/OTP 20 [erts-9.1.5] [source] [smp:4:4] [ds:4:4:10] [async-threads:64] [hipe] [kernel-poll:true]\n"},

{memory,

[{connection_readers,0},

{connection_writers,0},

{connection_channels,0},

{connection_other,9952},

{queue_procs,0},

{queue_slave_procs,0},

{plugins,732180},

{other_proc,13294776},

{metrics,99092},

{mgmt_db,209172},

{mnesia,38104},

{other_ets,1105244},

{binary,102768},

{msg_index,15240},

{code,15633313},

{atom,873089},

{other_system,6760358},

{allocated_unused,20531000},

{reserved_unallocated,0},

{strategy,rss},

{total,[{erlang,38873288},{rss,51253248},{allocated,59404288}]}]},

{alarms,[]},

{listeners,[{clustering,25672,"::"},{amqp,5672,"::"},{http,15672,"::"}]},

{vm_memory_calculation_strategy,rss},

{vm_memory_high_watermark,0.4},

{vm_memory_limit,388895539},

{disk_free_limit,50000000},

{disk_free,24804560896},

{file_descriptors,

[{total_limit,924},{total_used,2},{sockets_limit,829},{sockets_used,0}]},

{processes,[{limit,1048576},{used,370}]},

{run_queue,0},

{uptime,2057},

{kernel,{net_ticktime,60}}]

pi@raspberrypi:~ $ sudo rabbitmqctl environment

Application environment of node rabbit@raspberrypi ...

[{amqp_client,[{prefer_ipv6,false},{ssl_options,[]}]},

{asn1,[]},

{compiler,[]},

{cowboy,[]},

{cowlib,[]},

{crypto,[{fips_mode,false}]},

{goldrush,[]},

{inets,[]},

{jsx,[]},

{kernel,

[{error_logger,tty},

{inet_default_connect_options,[{nodelay,true}]},

{inet_dist_listen_max,25672},

{inet_dist_listen_min,25672}]},

{lager,

[{async_threshold,20},

{async_threshold_window,5},

{colored,false},

{colors,

[{debug,"\e[0;38m"},

{info,"\e[1;37m"},

{notice,"\e[1;36m"},

{warning,"\e[1;33m"},

{error,"\e[1;31m"},

{critical,"\e[1;35m"},

{alert,"\e[1;44m"},

{emergency,"\e[1;41m"}]},

{crash_log,"log/crash.log"},

{crash_log_count,5},

{crash_log_date,"$D0"},

{crash_log_msg_size,65536},

{crash_log_size,10485760},

{error_logger_format_raw,true},

{error_logger_hwm,50},

{error_logger_hwm_original,50},

{error_logger_redirect,true},

{extra_sinks,

[{error_logger_lager_event,

[{handlers,[{lager_forwarder_backend,[lager_event,inherit]}]},

{rabbit_handlers,