(evanode@shizz-worktop)1> X = eva_amqp:st().
18:03:11.546 [info] START
18:03:11.546 [info] EXCHANGE_DECLARE: {ok,<<"foobar">>}
18:03:11.547 [info] QUEUE_DECLARE: {ok,<<"barfoo">>}
18:03:11.548 [info] QUEUE_BIND: {ok,<<"*">>}
18:03:11.548 [info] CONSUME_START
{{<0.231.0>,<0.241.0>},
 <<"amq.ctag-QETr41aTT-S9X_2Eiphqct">>}
(evanode@shizz-worktop)2>
(evanode@shizz-worktop)2>
(evanode@shizz-worktop)2>
(evanode@shizz-worktop)2>
(evanode@shizz-worktop)2>
(evanode@shizz-worktop)2>
(evanode@shizz-worktop)2> D = eva_amqp:start("localhost", 5672).
{<0.251.0>,<0.259.0>}
(evanode@shizz-worktop)3> eva_amqp:
consume_start/2     consume_start/3     consume_stop/2
exchange_declare/2  exchange_declare/3  module_info/0
module_info/1       publish/3           publish/4
queue_bind/3        queue_bind/4        queue_declare/2
queue_declare/3     sp/1                st/0
start/2             stop/1
(evanode@shizz-worktop)3> eva_amqp:publish(D, <<"foobar">>, <<"message">>).
ok
(evanode@shizz-worktop)4> flush().
Shell got {'basic.consume_ok',<<"amq.ctag-QETr41aTT-S9X_2Eiphqct">>}
Shell got {{'basic.deliver',<<"amq.ctag-QETr41aTT-S9X_2Eiphqct">>,1,false,
                            <<"foobar">>,<<"*">>},
           {amqp_msg,{'P_basic',undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined},
                     <<"message">>}}
ok
(evanode@shizz-worktop)5> eva_amqp:publish(D, <<"foobar">>, <<"message">>).
ok
(evanode@shizz-worktop)6> eva_amqp:publish(D, <<"foobar">>, <<"message">>).
ok
(evanode@shizz-worktop)7> eva_amqp:publish(D, <<"foobar">>, <<"message">>).
ok
(evanode@shizz-worktop)8> flush().
Shell got {{'basic.deliver',<<"amq.ctag-QETr41aTT-S9X_2Eiphqct">>,2,false,
                            <<"foobar">>,<<"*">>},
           {amqp_msg,{'P_basic',undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined},
                     <<"message">>}}
Shell got {{'basic.deliver',<<"amq.ctag-QETr41aTT-S9X_2Eiphqct">>,3,false,
                            <<"foobar">>,<<"*">>},
           {amqp_msg,{'P_basic',undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined},
                     <<"message">>}}
Shell got {{'basic.deliver',<<"amq.ctag-QETr41aTT-S9X_2Eiphqct">>,4,false,
                            <<"foobar">>,<<"*">>},
           {amqp_msg,{'P_basic',undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined,undefined,
                                undefined,undefined},
                     <<"message">>}}
ok
(evanode@shizz-worktop)9> eva_amqp:stop(X).
ok