I find some error in rabbitmq log.
my environment:
=INFO REPORT==== 29-Aug-2013::16:17:32 ===
MQTT detected network error for "117.X.X.X:27471 -> 183.X.X.X:1883": closed
=ERROR REPORT==== 29-Aug-2013::16:17:32 ===
** Generic server <0.8464.0> terminating
** Last message in was {'EXIT',<0.8446.0>,
{{badmatch,not_registered},
[{rabbit_mqtt_reader,stop,2,[]},
{gen_server2,handle_msg,2,[]},
{proc_lib,wake_up,3,
[{file,"proc_lib.erl"},{line,249}]}]}}
** When Server state == {state,amqp_direct_connection,
{state,'rabbit@ubuntu-002',
{user,<<"guest">>,
[administrator],
rabbit_auth_backend_internal,
{internal_user,<<"guest">>,
<<142,75,13,22,6,167,52,4,57,111,48,140,61,105,247,
169,249,185,164,125>>,
[administrator]}},
<<"/">>,
{amqp_params_direct,<<"guest">>,<<"guest">>,
<<"/">>,'rabbit@ubuntu-002',
{amqp_adapter_info,
{0,0,0,0,0,65535,46977,49667},
1883,
{0,0,0,0,0,65535,30088,11},
27471,
<<"117.X.X.11:27471 -> 183.X.X.X:1883">>,
{'MQTT',{3,1}},
[{ssl,false}]},
[]},
{amqp_adapter_info,
{0,0,0,0,0,65535,46977,49667},
1883,
{0,0,0,0,0,65535,30088,11},
27471,
<<"117.X.X.11:27471 -> 183.X.X.X:1883">>,
{'MQTT',{3,1}},
[{ssl,false}]},
<0.8484.0>,undefined},
<0.8460.0>,<0.8472.0>,
{amqp_params_direct,<<"guest">>,<<"guest">>,<<"/">>,
'rabbit@ubuntu-002',
{amqp_adapter_info,
{0,0,0,0,0,65535,46977,49667},
1883,
{0,0,0,0,0,65535,30088,11},
27471,
<<"117.X.X.X:27471 -> 183.X.X.X:1883">>,
{'MQTT',{3,1}},
[{ssl,false}]},
[]},
0,
[{<<"capabilities">>,table,
[{<<"publisher_confirms">>,bool,true},
{<<"exchange_exchange_bindings">>,bool,true},
{<<"basic.nack">>,bool,true},
{<<"consumer_cancel_notify">>,bool,true}]},
{<<"copyright">>,longstr,
<<"Copyright (C) 2007-2013 GoPivotal, Inc.">>},
{<<"information">>,longstr,
<<"Licensed under the MPL. See http://www.rabbitmq.com/">>},
{<<"platform">>,longstr,<<"Erlang/OTP">>},
{<<"product">>,longstr,<<"RabbitMQ">>},
{<<"version">>,longstr,<<"3.1.5">>}],
#Fun,
#Fun,false}
** Reason for termination ==
** {unexpected_msg,
{'EXIT',<0.8446.0>,
{{badmatch,not_registered},
[{rabbit_mqtt_reader,stop,2,[]},
{gen_server2,handle_msg,2,[]},
{proc_lib,wake_up,3,[{file,"proc_lib.erl"},{line,249}]}]}}}
=INFO REPORT==== 29-Aug-2013::16:17:32 ===
accepting MQTT connection (117.X.XX:43208 -> 183.X.X.X:1883)
=ERROR REPORT==== 29-Aug-2013::16:17:32 ===
** Generic server <0.17986.0> terminating
** Last message in was {inet_async,#Port<0.8643>,3635,
{ok,<<16,37,0,6,77,81,73,115,100,112,3,2,1,44,0,
23,115,101,101,100,105,116,47,98,56,99,97,
49,102,97,56,97,55,102,48,57,53,101,102>>}}
** When Server state == {state,#Port<0.8643>,
"117.X.X.X:43208 -> 183.X.X.3:1883",true,
running,false,none,
{proc_state,#Port<0.8643>,
{dict,0,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[],[]},
{{[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[],[]}}},
{undefined,undefined},
{0,nil},
{0,nil},
undefined,1,undefined,undefined,undefined,
{undefined,undefined},
undefined,<<"amq.topic">>}}
** Reason for termination ==
** {badarg,[{erlang,list_to_binary,[unknown],[]},
{amqp_direct_connection,socket_adapter_info,2,[]},
{rabbit_mqtt_processor,process_login,3,[]},
{rabbit_mqtt_processor,process_request,3,[]},
{rabbit_mqtt_reader,process_received_bytes,2,[]},
{gen_server2,handle_msg,2,[]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,239}]}]}
=INFO REPORT==== 29-Aug-2013::16:17:32 ===
accepting MQTT connection (118.X.X.X:54619 -> 121.X.X.X:1883)
=ERROR REPORT==== 29-Aug-2013::16:17:32 ===
connection <0.17989.0>, channel 1 - soft error:
{amqp_error,not_found,
"no queue 'mqtt-subscription-seedit/4cec3667f1acc5b1qos1' in vhost '/'",
'queue.delete'}
=INFO REPORT==== 29-Aug-2013::16:17:34 ===
MQTT detected network error for "183.X.X.6:46153 -> 121.X.X.X:1883": closed
=INFO REPORT==== 29-Aug-2013::16:17:34 ===
accepting MQTT connection (117.X.X.X:33572 -> 183.X.X.X:1883)
=ERROR REPORT==== 29-Aug-2013::16:17:34 ===
** Generic server <0.18008.0> terminating
** Last message in was {inet_async,#Port<0.8646>,3642,
{ok,<<16,37,0,6,77,81,73,115,100,112,3,2,1,44,0,
23,115,101,101,100,105,116,47,51,49,100,56,
49,102,97,98,102,102,51,52,99,102,50,55>>}}
** When Server state == {state,#Port<0.8646>,
"117.X.X.75:33572 -> 183.X.X.X:1883",true,
running,false,none,
{proc_state,#Port<0.8646>,
{dict,0,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[],[]},
{{[],[],[],[],[],[],[],[],[],[],[],[],[],
[],[],[]}}},
{undefined,undefined},
{0,nil},
{0,nil},
undefined,1,undefined,undefined,undefined,
{undefined,undefined},
undefined,<<"amq.topic">>}}
** Reason for termination ==
** {badarg,[{erlang,list_to_binary,[unknown],[]},
{amqp_direct_connection,socket_adapter_info,2,[]},
{rabbit_mqtt_processor,process_login,3,[]},
{rabbit_mqtt_processor,process_request,3,[]},
{rabbit_mqtt_reader,process_received_bytes,2,[]},
{gen_server2,handle_msg,2,[]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,239}]}]}