[rabbitmq-discuss] still no love with erlang client and 2.0.0 broker
Jon Brisbin
jon at jbrisbin.com
Tue Sep 7 20:00:47 BST 2010
I'm back to a point where I'm needing to start working with the erlang client in a Nitrogen-based web application I'm building. amqp_connection:start_network() won't work for me at all.
I tried a fresh checkout of the erlang client using the rabbitmq_v2_0_0 tag and built the source. I get the following error consistently, whether using a release version of the broker, or doing a make run from the rabbitmq-server directory just checked out from mercurial.
Channel 1 closing: received exit signal from writer. Reason: {badarg,
[{rabbit_framing_amqp_0_9_1,
encode_method_fields,
1},
{rabbit_binary_generator,
build_simple_method_frame,
3},
{rabbit_writer,
internal_send_command_async,
4},
{rabbit_writer,
handle_message,
2},
{rabbit_writer,
mainloop,1}]}
I'm 1000% sure I'm using the source I'm supposed to because I did an hg clone on the tag (transcript below) and I went to the repo in a browser and downloaded the files for that tag directly from Mercurial. Same result either way.
I've tried to include full transcripts of the build, the logging from the app, and relevant versions, etc... from my OS X erlang install. Any help/insight you can give here would be greatly appreciated! :)
Thanks!
J. Brisbin
http://jbrisbin.com/
Build transcript:
+--( jbrisbin at brisbins-mbp )-(Tue, Sep 07 13:03 PM)-->
+-( ~/src/rabbitmq/2.0 ):> hg clone -r rabbitmq_v2_0_0 http://hg.rabbitmq.com/rabbitmq-codegen
destination directory: rabbitmq-codegen
requesting all changes
adding changesets
adding manifests
adding file changes
added 137 changesets with 120 changes to 18 files
updating to branch default
10 files updated, 0 files merged, 0 files removed, 0 files unresolved
+--( jbrisbin at brisbins-mbp )-(Tue, Sep 07 13:04 PM)-->
+-( ~/src/rabbitmq/2.0 ):> hg clone -r rabbitmq_v2_0_0 http://hg.rabbitmq.com/rabbitmq-erlang-client
destination directory: rabbitmq-erlang-client
requesting all changes
adding changesets
adding manifests
adding file changes
added 695 changesets with 1400 changes to 126 files
updating to branch default
26 files updated, 0 files merged, 0 files removed, 0 files unresolved
+--( jbrisbin at brisbins-mbp )-(Tue, Sep 07 13:04 PM)-->
+-( ~/src/rabbitmq/2.0 ):> hg clone -r rabbitmq_v2_0_0 http://hg.rabbitmq.com/rabbitmq-server
destination directory: rabbitmq-server
requesting all changes
adding changesets
adding manifests
adding file changes
added 4135 changesets with 7116 changes to 229 files
updating to branch default
141 files updated, 0 files merged, 0 files removed, 0 files unresolved
+--( jbrisbin at brisbins-mbp )-(Tue, Sep 07 13:04 PM)-->
+-( ~/src/rabbitmq/2.0 ):> cd rabbitmq-erlang-client/
+--( jbrisbin at brisbins-mbp )-(Tue, Sep 07 13:05 PM)-->
+-( ~/src/rabbitmq/2.0/rabbitmq-erlang-client ):> make
sed -e 's:%%VSN%%:0.0.0:g' < rabbit_common.app.in > rabbit_common.app
mkdir -p dist
make -C ../rabbitmq-server
python codegen.py body ../rabbitmq-codegen//amqp-rabbitmq-0.9.1.json src/rabbit_framing_amqp_0_9_1.erl python codegen.py body ../rabbitmq-codegen//amqp-rabbitmq-0.8.json src/rabbit_framing_amqp_0_8.erl xsltproc --stringparam modulename "`basename src/rabbit_ctl_usage.erl .erl`" \ docs/usage.xsl docs/rabbitmqctl.1.xml > src/rabbit_ctl_usage.erl.tmp sed -e 's/"/\\"/g' -e 's/%QUOTE%/"/g' src/rabbit_ctl_usage.erl.tmp > src/rabbit_ctl_usage.erl.tmp2 fold -s src/rabbit_ctl_usage.erl.tmp2 > src/rabbit_ctl_usage.erl.tmp3 mv src/rabbit_ctl_usage.erl.tmp3 src/rabbit_ctl_usage.erl rm src/rabbit_ctl_usage.erl.tmp src/rabbit_ctl_usage.erl.tmp2 xsltproc --stringparam modulename "`basename src/rabbit_multi_usage.erl .erl`" \ docs/usage.xsl docs/rabbitmq-multi.1.xml > src/rabbit_multi_usage.erl.tmp sed -e 's/"/\\"/g' -e 's/%QUOTE%/"/g' src/rabbit_multi_usage.erl.tmp > src/rabbit_multi_usage.erl.tmp2 fold -s src/rabbit_multi_usage.erl.tmp2 > src/rabbit_multi_usage.erl.tmp3 mv src/rabbit_multi_usage.erl.tmp3 src/rabbit_multi_usage.erl rm src/rabbit_multi_usage.erl.tmp src/rabbit_multi_usage.erl.tmp2 python codegen.py --ignore-conflicts header ../rabbitmq-codegen//amqp-rabbitmq-0.9.1.json ../rabbitmq-codegen//amqp-rabbitmq-0.8.json include/rabbit_framing.hrl escript generate_deps include src \$\(EBIN_DIR\) deps.mk
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/bpqueue.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/gen_server2.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/delegate.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/delegate_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/file_handle_cache.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/gatherer.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/pg_local.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/priority_queue.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_access_control.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_alarm.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_amqqueue.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_amqqueue_process.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/supervisor2.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_amqqueue_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_backing_queue.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_basic.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_binary_generator.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_binary_parser.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_channel.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_control.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_dialyzer.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_error_logger.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_error_logger_file_h.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_event.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange_type.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange_type_direct.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange_type_fanout.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange_type_headers.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange_type_registry.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_exchange_type_topic.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_framing_channel.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_guid.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_heartbeat.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_hooks.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_invariable_queue.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_limiter.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_load.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_log.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_memory_monitor.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_misc.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_mnesia.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_msg_file.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_msg_store.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_msg_store_index.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_msg_store_ets_index.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_msg_store_gc.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_multi.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_net.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_networking.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_node_monitor.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_persister.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_plugin_activator.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_queue_collector.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_queue_index.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_reader.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_restartable_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_router.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_sasl_report_file_h.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_tests.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_tests_event_receiver.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_tracer.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_types.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_variable_queue.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_writer.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/tcp_acceptor.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/tcp_acceptor_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/tcp_client_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/tcp_listener.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/tcp_listener_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/test_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/vm_memory_monitor.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/worker_pool.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/worker_pool_sup.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/worker_pool_worker.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_framing_amqp_0_9_1.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_framing_amqp_0_8.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_ctl_usage.erl
erlc -I include -o ebin -Wall -v +debug_info -Duse_specs -pa ebin src/rabbit_multi_usage.erl
escript generate_app ebin ebin/rabbit.app < ebin/rabbit_app.in
rm -rf dist/rabbit_common
mkdir -p dist/rabbit_common/include
mkdir -p dist/rabbit_common/ebin
cp rabbit_common.app dist/rabbit_common/ebin/
( cp ../rabbitmq-server/ebin/rabbit_writer.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_reader.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_framing_amqp_0_8.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_framing_amqp_0_9_1.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_framing_channel.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_basic.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_binary_generator.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_binary_parser.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_channel.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_exchange_type.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_misc.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_net.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/rabbit_heartbeat.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/gen_server2.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/priority_queue.beam dist/rabbit_common/ebin/ ); ( cp ../rabbitmq-server/ebin/supervisor2.beam dist/rabbit_common/ebin/ );
cp ../rabbitmq-server/include/*.hrl dist/rabbit_common/include/
(cd dist; zip -r rabbit_common.ez rabbit_common)
adding: rabbit_common/ (stored 0%)
adding: rabbit_common/ebin/ (stored 0%)
adding: rabbit_common/ebin/gen_server2.beam (deflated 18%)
adding: rabbit_common/ebin/priority_queue.beam (deflated 20%)
adding: rabbit_common/ebin/rabbit_basic.beam (deflated 7%)
adding: rabbit_common/ebin/rabbit_binary_generator.beam (deflated 12%)
adding: rabbit_common/ebin/rabbit_binary_parser.beam (deflated 18%)
adding: rabbit_common/ebin/rabbit_channel.beam (deflated 19%)
adding: rabbit_common/ebin/rabbit_common.app (deflated 63%)
adding: rabbit_common/ebin/rabbit_exchange_type.beam (deflated 20%)
adding: rabbit_common/ebin/rabbit_framing_amqp_0_8.beam (deflated 21%)
adding: rabbit_common/ebin/rabbit_framing_amqp_0_9_1.beam (deflated 17%)
adding: rabbit_common/ebin/rabbit_framing_channel.beam (deflated 15%)
adding: rabbit_common/ebin/rabbit_heartbeat.beam (deflated 20%)
adding: rabbit_common/ebin/rabbit_misc.beam (deflated 16%)
adding: rabbit_common/ebin/rabbit_net.beam (deflated 13%)
adding: rabbit_common/ebin/rabbit_reader.beam (deflated 17%)
adding: rabbit_common/ebin/rabbit_writer.beam (deflated 11%)
adding: rabbit_common/ebin/supervisor2.beam (deflated 22%)
adding: rabbit_common/include/ (stored 0%)
adding: rabbit_common/include/rabbit.hrl (deflated 61%)
adding: rabbit_common/include/rabbit_backing_queue_spec.hrl (deflated 67%)
adding: rabbit_common/include/rabbit_exchange_type_spec.hrl (deflated 64%)
adding: rabbit_common/include/rabbit_framing.hrl (deflated 75%)
adding: rabbit_common/include/rabbit_msg_store.hrl (deflated 58%)
adding: rabbit_common/include/rabbit_msg_store_index.hrl (deflated 66%)
mkdir -p deps
rm -rf deps/rabbit_common
mkdir -p deps/rabbit_common
unzip -o dist/rabbit_common.ez -d deps
Archive: dist/rabbit_common.ez
creating: deps/rabbit_common/ebin/
inflating: deps/rabbit_common/ebin/gen_server2.beam
inflating: deps/rabbit_common/ebin/priority_queue.beam
inflating: deps/rabbit_common/ebin/rabbit_basic.beam
inflating: deps/rabbit_common/ebin/rabbit_binary_generator.beam
inflating: deps/rabbit_common/ebin/rabbit_binary_parser.beam
inflating: deps/rabbit_common/ebin/rabbit_channel.beam
inflating: deps/rabbit_common/ebin/rabbit_common.app
inflating: deps/rabbit_common/ebin/rabbit_exchange_type.beam
inflating: deps/rabbit_common/ebin/rabbit_framing_amqp_0_8.beam
inflating: deps/rabbit_common/ebin/rabbit_framing_amqp_0_9_1.beam
inflating: deps/rabbit_common/ebin/rabbit_framing_channel.beam
inflating: deps/rabbit_common/ebin/rabbit_heartbeat.beam
inflating: deps/rabbit_common/ebin/rabbit_misc.beam
inflating: deps/rabbit_common/ebin/rabbit_net.beam
inflating: deps/rabbit_common/ebin/rabbit_reader.beam
inflating: deps/rabbit_common/ebin/rabbit_writer.beam
inflating: deps/rabbit_common/ebin/supervisor2.beam
creating: deps/rabbit_common/include/
inflating: deps/rabbit_common/include/rabbit.hrl
inflating: deps/rabbit_common/include/rabbit_backing_queue_spec.hrl
inflating: deps/rabbit_common/include/rabbit_exchange_type_spec.hrl
inflating: deps/rabbit_common/include/rabbit_framing.hrl
inflating: deps/rabbit_common/include/rabbit_msg_store.hrl
inflating: deps/rabbit_common/include/rabbit_msg_store_index.hrl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_channel.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_channel_util.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_connection.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_direct_connection.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_main_reader.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_network_connection.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_rpc_client.erl
ERL_LIBS=deps:dist erlc -I include -o ebin -Wall -v +debug_info -Duse_specs src/amqp_rpc_server.erl
sed -e 's:%%VSN%%:0.0.0:g' < ebin/amqp_client.app.in > ebin/amqp_client.app
rm -rf dist/amqp_client
mkdir -p dist/amqp_client/ebin
cp -r ebin/*.beam dist/amqp_client/ebin
cp -r ebin/*.app dist/amqp_client/ebin
mkdir -p dist/amqp_client/include
cp -r include/* dist/amqp_client/include
(cd dist; zip -r amqp_client.ez amqp_client)
adding: amqp_client/ (stored 0%)
adding: amqp_client/ebin/ (stored 0%)
adding: amqp_client/ebin/amqp_channel.beam (deflated 14%)
adding: amqp_client/ebin/amqp_channel_util.beam (deflated 13%)
adding: amqp_client/ebin/amqp_client.app (deflated 57%)
adding: amqp_client/ebin/amqp_connection.beam (deflated 8%)
adding: amqp_client/ebin/amqp_direct_connection.beam (deflated 11%)
adding: amqp_client/ebin/amqp_main_reader.beam (deflated 10%)
adding: amqp_client/ebin/amqp_network_connection.beam (deflated 14%)
adding: amqp_client/ebin/amqp_rpc_client.beam (deflated 8%)
adding: amqp_client/ebin/amqp_rpc_server.beam (deflated 7%)
adding: amqp_client/include/ (stored 0%)
adding: amqp_client/include/amqp_client.hrl (deflated 57%)
Logging from Nitrogen app:
params: {amqp_params,<<"guest">>,<<"guest">>,<<"/">>,"localhost",5672,0,0,0,
none,[]}
=ERROR REPORT==== 7-Sep-2010::13:08:04 ===
Channel 1 closing: received exit signal from writer. Reason: {badarg,
[{rabbit_framing_amqp_0_9_1,
encode_method_fields,
1},
{rabbit_binary_generator,
build_simple_method_frame,
3},
{rabbit_writer,
internal_send_command_async,
4},
{rabbit_writer,
handle_message,
2},
{rabbit_writer,
mainloop,1}]}
=ERROR REPORT==== 7-Sep-2010::13:08:04 ===
** Generic server <0.115.0> terminating
** Last message in was {'EXIT',<0.117.0>,
{badarg,
[{rabbit_framing_amqp_0_9_1,
encode_method_fields,1},
{rabbit_binary_generator,
build_simple_method_frame,3},
{rabbit_writer,internal_send_command_async,4},
{rabbit_writer,handle_message,2},
{rabbit_writer,mainloop,1}]}}
** When Server state == {c_state,1,<0.108.0>,<0.116.0>,<0.117.0>,network,
{[{{<0.107.0>,#Ref<0.0.0.193>},
{'channel.close',undefined,<<>>,undefined,
undefined},
none}],
[]},
{[],[]},
{dict,0,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
[]},
{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[]}}},
just_channel,none,false,none,
{dict,0,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
[]},
{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[]}}},
unknown}
** Reason for termination ==
** {writer_died,<0.117.0>,
{badarg,[{rabbit_framing_amqp_0_9_1,encode_method_fields,1},
{rabbit_binary_generator,build_simple_method_frame,3},
{rabbit_writer,internal_send_command_async,4},
{rabbit_writer,handle_message,2},
{rabbit_writer,mainloop,1}]}}
=ERROR REPORT==== 7-Sep-2010::13:08:04 ===
Connection (<0.108.0>) closing: channel (<0.115.0>) died. Reason: {writer_died,
<0.117.0>,
{badarg,
[{rabbit_framing_amqp_0_9_1,
encode_method_fields,
1},
{rabbit_binary_generator,
build_simple_method_frame,
3},
{rabbit_writer,
internal_send_command_async,
4},
{rabbit_writer,
handle_message,
2},
{rabbit_writer,
mainloop,
1}]}}
=ERROR REPORT==== 7-Sep-2010::13:08:04 ===
** Generic server oja_amqp terminating
** Last message in was {'$gen_cast',
{provision,
[{name,"test"},
{salt,"564a08ec9a45ba7f417fdf9ea401ddea"},
{password,
"b0bb14adc08f9c98fa12e54f8c48dc855bdacd71"},
{roles,["applicant"]}]}}
** When Server state == {amqp_state,<0.115.0>}
** Reason for termination ==
** {{writer_died,<0.117.0>,
{badarg,
[{rabbit_framing_amqp_0_9_1,encode_method_fields,1},
{rabbit_binary_generator,build_simple_method_frame,3},
{rabbit_writer,internal_send_command_async,4},
{rabbit_writer,handle_message,2},
{rabbit_writer,mainloop,1}]}},
{gen_server,call,
[<0.115.0>,
{call,{'channel.close',undefined,<<>>,undefined,undefined},none},
infinity]}}
=ERROR REPORT==== 7-Sep-2010::13:08:04 ===
Error in process <0.117.0> on node 'oja at 127.0.0.1' with exit value: {badarg,[{rabbit_framing_amqp_0_9_1,encode_method_fields,1},{rabbit_binary_generator,build_simple_method_frame,3},{rabbit_writer,internal_send_command_async,4},{rabbit_writer,handle_message,2},{rabbit_writer...
=ERROR REPORT==== 7-Sep-2010::13:08:04 ===
** Generic server <0.108.0> terminating
** Last message in was {'$gen_cast',{method,{'connection.close_ok'},none}}
** When Server state == {nc_state,
{amqp_params,<<"guest">>,<<"guest">>,<<"/">>,
"localhost",5672,0,0,0,none,[]},
#Port<0.2012>,<0.113.0>,<0.112.0>,<0.111.0>,0,0,
{nc_closing,internal_error,
{'connection.close',541,<<>>,0,0},
none,wait_close_ok},
[{<<"product">>,longstr,<<"RabbitMQ">>},
{<<"version">>,longstr,<<"2.0.0">>},
{<<"platform">>,longstr,<<"Erlang/OTP">>},
{<<"copyright">>,longstr,
<<"Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.">>},
{<<"information">>,longstr,
<<"Licensed under the MPL. See http://www.rabbitmq.com/">>}],
{{0,nil},
{dict,0,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[]},
{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[]}}}}}
** Reason for termination ==
** {internal_error,541,<<>>}
=INFO REPORT==== 7-Sep-2010::13:08:04 ===
Negotiated maximums: (Channel = 0, Frame= 131072, Heartbeat=0)
Broker:
Activating RabbitMQ plugins ...
0 plugins activated:
Erlang R14A (erts-5.8) [source] [64-bit] [smp:2:2] [rq:2] [async-threads:30] [hipe] [kernel-poll:true]
+---+ +---+
| | | |
| | | |
| | | |
| +---+ +-------+
| |
| RabbitMQ +---+ |
| | | |
| v%%VSN%% +---+ |
| |
+-------------------+
AMQP 0-9-1 / 0-9 / 0-8
Client:
BrokerParams = #amqp_params{ host=proplists:get_value(broker_host, Config, "localhost"),
port=proplists:get_value(broker_port, Config, 5672),
username=proplists:get_value(broker_user, Config, <<"guest">>),
password=proplists:get_value(broker_pass, Config, <<"guest">>),
virtual_host=proplists:get_value(broker_vhost, Config, <<"/">>) },
io:format("params: ~p~n", [BrokerParams]),
Connection = amqp_connection:start_network(BrokerParams),
Channel = amqp_connection:open_channel(Connection),
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20100907/1adcc204/attachment-0001.htm>
More information about the rabbitmq-discuss
mailing list