[rabbitmq-discuss] still no love with erlang client and 2.0.0 broker

Tue Sep 7 20:35:29 BST 2010

So, that transcript looks ok to me. I just did the same things and got 
an Erlang client that worked. How are you starting the Erlang client? If 
you invoke "make run" in the rabbitmq_erlang_client directory, then type 
amqp_connection:start_network(). at the erl> prompt, does that work?

Cheers, Simon

On 07/09/10 20:00, Jon Brisbin wrote:
> 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),
>
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss