Lutziferbox
commented
6 years ago Hi again, first of all thank you for your answer and your tipps on how to get support for my issue. My problem is that I am not using rabbitmq at all but only this client to connect to an Azure Event Hub instead.
My client is running an Elixir umbrella app within a Docker container that uses the rabbitmq-amqp1.0-client like this:
def start_link(partition) do
GenServer.start_link(__MODULE__, partition)
end
def init(partition) do
send(self(), :connect)
{:ok, %{status: :disconnected, receiver: nil, partition: partition}}
end
def handle_info(:connect, %{status: :disconnected, partition: partition} = state) do
connection_info = %{
address: 'xxx',
hostname: "xxx",
container_id: "xxx",
port: 5671,
sasl: {:plain, xxx-policy, xxx-key},
tls_opts: {:secure_port, []}
}
with {:ok, connection} <- :amqp10_client.open_connection(connection_info),
{:ok, session} <- :amqp10_client.begin_session(connection),
{:ok, receiver} <- apply(:amqp10_client, :attach_receiver_link, [session, "receiver", partition]),
:ok <- :amqp10_client.flow_link_credit(receiver, 1000, :never)
do
{:noreply, %{state | status: :connected, receiver: receiver}}
end
end
def handle_info({:amqp10_msg, _link, message}, state) do
{message_content, message_annotations} = do_something_with_message(message)
{:noreply, state}
endThe code did work fine until recently when we started to see the following error message:
` 17:43:18.712 [warn] Unhandled session frame {{:"v1_0.transfer", {:uint, 0}, :undefined, :undefined, :undefined, :undefined, false, :undefined, :undefined, :undefined, :undefined, :undefined}, "xxx-very-long-not-valid-json-string" <> ...} in state {:state, 1, 1, 30588, 65535, 1, 65535, 5000, 34948, #PID<0.5502.0>, {:ssl, {:sslsocket, {:gen_tcp, #Port<0.158324>, :tls_connection, :undefined},
PID<0.5503.0>}},
%{0 => {:link, "receiver", {:link_ref, :receiver, #PID<0.5511.0>, 0}, :attached, #PID<0.5499.0>, 0, 0, :receiver, :undefined, {:pid, #PID<0.5499.0>}, 30585, 415, 415, 0, false, {{:"v1_0.transfer", {:uint, 0}, {:uint, 30585}, {:binary, ""}, {:uint, 0}, true, true, :undefined, :undefined, :undefined, :undefined, true}, ["xxx-another-very-long-not-valid-json-string (truncated) 17:43:18.717 [error] State machine #PID<0.5511.0> terminating Last event in was {{:"v1_0.transfer", {:uint, 0}, {:uint, 30586}, {:binary, ""}, {:uint, 0}, true, false, :undefined, :undefined, :undefined, :undefined, true}, <<0, 83, 114, 193, 90, 6, 163, 21, 120, 45, 111, 112, 116, 45, 115, 101, 113, 117, 101, 110, 99, 101, 45, 110, 117, 109, 98, 101, 114, 129, 0, 0, 0, 0, 0, 12, 20, 56, 163, 12, 120, 45, 111, 112, 116, 45, 111, 102, 102, ...>>} When State == :mapped Data == {:state, 1, 1, 30588, 65535, 1, 65535, 5000, 34948, #PID<0.5502.0>, {:ssl, {:sslsocket, {:gen_tcp, #Port<0.158324>, :tls_connection, :undefined},
PID<0.5503.0>}},
%{0 => {:link, "receiver", {:link_ref, :receiver, #PID<0.5511.0>, 0}, :attached, #PID<0.5499.0>, 0, 0, :receiver, :undefined, {:pid, #PID<0.5499.0>}, 30585, 415, 415, 0, false, {{:"v1_0.transfer", {:uint, 0}, {:uint, 30585}, {:binary, ""}, {:uint, 0}, true, true, :undefined, :undefined, :undefined, :undefined, true}, ["xxx-another-very-long-not-valid-json-string" <> ..., <<0, 83, 114, 193, 90, 6, 163, 21, 120, 45, 111, 112, 116, 45, 115, 101, 113, 117, 101, 110, ...>>]}, :never}}, %{}, %{0 => 0}, 1, [], %{address: 'xxx', container_id: "xxx", hostname: "xxx", notify: #PID<0.5499.0>, outgoing_max_frame_size: 65536, port: 5671, sasl: {:plain, "xxx", "xxx"}, tls_opts: {:secure_port, []}, transfer_limit_margin: 0}, %{}, %{},
PID<0.5499.0>}
Reason for termination = {:bad_return_value, {:primitive_type_unsupported, 176}} `
I am still working on means to reproduce this issue with a short script, but didn't find any good way to do so yet.
Any help is much appreciated.
kjnilsson
lukebakken
michaelklishin
Hi,
I am using this rabbitmq-amqp1.0-client in an elixir project to read AMQP messages from an Azure Event Hub. Yesterday, there appeared some broken message in the queue and the amqp-client did break during handling it. The message looks something like this: "\":null,\"CorrelationId\":null,..." and the amqp-client reacts with the warning log "Unhandled session frame {{:"v1_0.transfer", {:uint, 0}, :undefined, :undefined, :undefined, :undefined, false, :undefined, :undefined, :undefined, :undefined, :undefined},", followed by the frame and "in state {:state, 1, 1, 30588, 65535, 1, 65535, 5000, 34948, #PID<0.5502.0>,". Afterwards it terminates with " State machine #PID<0.5511.0> terminating Last event in was {{:"v1_0.transfer", {:uint, 0}, {:uint, 30586}, {:binary, ""}, {:uint, 0}, true, false, :undefined, :undefined, :undefined, :undefined, true}, <<0, 83, 114, 193, 90, 6, 163, 21, 120, 45, 111, 112, 116, 45, 115, 101, 113, 117, 101, 110, 99, 101, 45, 110, 117, 109, 98, 101, 114, 129, 0, 0, 0, 0, 0, 12, 20, 56, 163, 12, 120, 45, 111, 112, 116, 45, 111, 102, 102, ...>>} When State == :mapped Data == {:state, 1, 1, 30588, 65535, 1, 65535, 5000, 34948, #PID<0.5502.0>, {:ssl, {:sslsocket, {:gen_tcp, #Port<0.158324>, :tls_connection, :undefined},
PID<0.5503.0>}},
%{0 => {:link, "receiver", {:link_ref, :receiver, #PID<0.5511.0>, 0}, :attached, #PID<0.5499.0>, 0, 0, :receiver, :undefined, {:pid, #PID<0.5499.0>}, 30585, 415, 415, 0, false, {{:"v1_0.transfer", {:uint, 0}, {:uint, 30585}, {:binary, ""}, {:uint, 0}, true, true, :undefined, :undefined, :undefined, :undefined, true}," followed by the frame again and something like this: "<<0, 83, 114, 193, 90, 6, 163, 21, 120, 45, 111, 112, 116, 45, 115, 101, 113, 117, 101, 110, ...>>]}, :never}}, %{}, %{0 => 0}, 1, [], %{address: 'xxx', container_id: "xxx", hostname: "xxx", notify: #PID<0.5499.0>, outgoing_max_frame_size: 65536, port: 5671, sasl: {:plain, "xxx", "xxx"}, tls_opts: {:secure_port, []}, transfer_limit_margin: 0}, %{}, %{},
PID<0.5499.0>}
Reason for termination = {:bad_return_value, {:primitive_type_unsupported, 176}}"
I did not find a way to react to this error from within my wrapping code.
Could you please help me figure out what exactly is going wrong and what to do about it? Thanks a lot in advance!