1

Topic: [Erlang] the Error by operation with RabbitMq

All greetings! Help  to find a cause of error in application... A problem Essence in the following. Is  a bicycle for operation with queue in a mode rpc. Messages are sent to queue, it is underlined for them correlation_id and answer queue I create Answer queue in a separate flow and I subscribe for reading of answers with the help basic.consume. Sometimes there are situations (the reason to install I can not yet) when I see error reports of a following type (see more low the Error 1). And after that somewhere with 50 % of requests begins something is created not clear (sm the Error 2). Push  on thought in what side to dig. An error 1 =ERROR REPORT ==== 20-Jan-2015:: : 13:56:22 === ** Generic server <0.83.0> terminating ** Last message in was {consumer_call, {' basic.deliver ', <<"amq.ctag-AUQbOnN34dHwt-KDOHhyVQ">>, 1, false, <<>>, <<"RespTest">>}, {amqp_msg, {' P_basic ', undefined, undefined, undefined, undefined, undefined, <<"b7d000eb-f446-4ef2-b008-dc9c19e778eb">>, undefined, undefined, undefined, undefined, undefined, undefined, undefined, undefined}, <<0,101,0,0,0. ....., 205,205,219,213>>}} ** When Server state == {state, amqp_selective_consumer, {state, {dict, 0,16,16,8,80,48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}}}, undefined, {dict, 0,16,16,8,80,48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}}}, none}} ** Reason for termination == [{process_name, {amqp_gen_consumer, {<<"client 192.0.2.15:50205-> 192.61.128.43:5672">>, 1}}}] trap_exit: false status: running heap_size: 987 stack_size: 27 reductions: 525 neighbors: =SUPERVISOR REPORT ==== 20-Jan-2015:: 13:56:22 === Supervisor: {<0.82.0>, amqp_channel_sup} Context: child_terminated Reason: unexpected_delivery_and_no_default_consumer Offender: [{pid, <0.83.0>}, {name, gen_consumer}, {mfargs, {amqp_gen_consumer, start_link, [amqp_selective_consumer, [], {<<"client 192.0.2.15:50205-> 192.61.128.43:5672">>, 1}]}}, {restart_type, intrinsic}, {shutdown, 4294967295}, {child_type, worker}] =SUPERVISOR REPORT ==== 20-Jan-2015:: 13:56:22 === Supervisor: {<0.82.0>, amqp_channel_sup} Context: shutdown Reason: reached_max_restart_intensity Offender: [{pid, <0.83.0>}, {name, gen_consumer}, {mfargs, {amqp_gen_consumer, start_link, [amqp_selective_consumer, [], {<<"client 192.0.2.15:50205-> 192.61.128.43:5672">>, 1}]}}, {restart_type, intrinsic}, {shutdown, 4294967295}, {child_type, worker}] =ERROR REPORT ==== 20-Jan-2015:: 13:56:22 === ** Generic server <0.84.0> terminating ** Last message in was {' $gen_cast ', {method, {' basic.deliver ', <<"amq.ctag-AUQbOnN34dHwt-KDOHhyVQ">>, 1, false, <<>>, <<"RespTest">>}, {content, 60, none, <<4,0,36......., 56,101,98>>, rabbit_framing_amqp_0_9_1, [<<0,101,0,0,0...... 205,205,219,213>>]}, noflow}} ** When Server state == {state, 1, <0.72.0>, <0.83.0>, network, {[], []}, false, <0.85.0>, none, none, 0, true, none, {0, nil}, {0, nil}, true, false} ** Reason for termination == ** shutdown =SUPERVISOR REPORT ==== 20-Jan-2015:: 13:56:22 === Supervisor: {<0.82.0>, amqp_channel_sup} Context: shutdown_error Reason: shutdown Offender: [{pid, <0.84.0>}, {name, channel}, {mfargs, {amqp_channel, start_link, [network, <0.72.0>, 1, <0.83.0>, {<<"client 192.0.2.15:50205-> 192.61.128.43:5672">>, 1}]}}, {restart_type, intrinsic}, {shutdown, 4294967295}, {child_type, worker}] the Error 2 =INFO REPORT ==== 20-Jan-2015:: 13:56:48 === Dropping frame {method, ' basic.deliver ', <<31,97,109,113......, 101,115,116>>} for invalid or closed channel number 1 =INFO REPORT ==== 20-Jan-2015:: 13:56:48 === Dropping frame {content_header, 60,0,103, <<4,0,36,51,48......, 50,52,54,97>>} for invalid or closed channel number 1 =INFO REPORT ==== 20-Jan-2015:: 13:56:48 === Dropping frame {content_body,<<0,101,0,0,0,......,197,216,197,205,205,219,213>>} for invalid or closed channel number 1

2

Re: [Erlang] the Error by operation with RabbitMq

Hello, - Cheese - you wrote: Well the second error is, seemingly, generated by the first (process died), and the first - broke a subscription? Someone cancelled it?

3

Re: [Erlang] the Error by operation with RabbitMq

Hello, netch80, you wrote: N> Well the second error is, seemingly, generated by the first (process died), N> and the first - broke a subscription? Someone cancelled it? And who could cancel it? How it is possible to catch this moment and to restart a subscription?