Skip to content

Instantly share code, notes, and snippets.

@tyrylu
Created October 21, 2019 21:04
Show Gist options
  • Save tyrylu/91d255625e485e12ebf57378e3aa4005 to your computer and use it in GitHub Desktop.
Save tyrylu/91d255625e485e12ebf57378e3aa4005 to your computer and use it in GitHub Desktop.
[2019-10-21T21:00:47Z TRACE mio::poll] registering with poller
[2019-10-21T21:00:47Z DEBUG lapin::channels] create channel with id 0
[2019-10-21T21:00:47Z TRACE lapin::connection] connection send_frame; channel_id=0
[2019-10-21T21:00:47Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:47Z TRACE mio::poll] registering with poller
[2019-10-21T21:00:47Z TRACE mio::poll] registering with poller
[2019-10-21T21:00:47Z TRACE mio::poll] registering with poller
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] will write to buffer: ProtocolHeader
[2019-10-21T21:00:47Z TRACE lapin::io_loop] wrote 8 bytes
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] wrote 0 bytes
[2019-10-21T21:00:47Z TRACE lapin::io_loop] read 494 bytes
[2019-10-21T21:00:47Z TRACE lapin::connection] will handle frame: Method(0, Connection(Start(Start { version_major: 0, version_minor: 9, server_properties: FieldTable({ShortString("capabilities"): FieldTable(FieldTable({ShortString("authentication_failure_close"): Boolean(true), ShortString("basic.nack"): Boolean(true), ShortString("connection.blocked"): Boolean(true), ShortString("consumer_cancel_notify"): Boolean(true), ShortString("consumer_priorities"): Boolean(true), ShortString("direct_reply_to"): Boolean(true), ShortString("exchange_exchange_bindings"): Boolean(true), ShortString("per_consumer_qos"): Boolean(true), ShortString("publisher_confirms"): Boolean(true)})), ShortString("cluster_name"): LongString(LongString("rabbit@trycht")), ShortString("copyright"): LongString(LongString("Copyright (C) 2007-2019 Pivotal Software, Inc.")), ShortString("information"): LongString(LongString("Licensed under the MPL. See https://www.rabbitmq.com/")), ShortString("platform"): LongString(LongString("Erlang/OTP 22.1")), ShortString("product"): LongString(LongString("RabbitMQ")), ShortString("version"): LongString(LongString("3.7.18"))}), mechanisms: LongString("AMQPLAIN PLAIN"), locales: LongString("en_US") })))
[2019-10-21T21:00:47Z TRACE lapin::channel] Server sent connection::Start: Start { version_major: 0, version_minor: 9, server_properties: FieldTable({ShortString("capabilities"): FieldTable(FieldTable({ShortString("authentication_failure_close"): Boolean(true), ShortString("basic.nack"): Boolean(true), ShortString("connection.blocked"): Boolean(true), ShortString("consumer_cancel_notify"): Boolean(true), ShortString("consumer_priorities"): Boolean(true), ShortString("direct_reply_to"): Boolean(true), ShortString("exchange_exchange_bindings"): Boolean(true), ShortString("per_consumer_qos"): Boolean(true), ShortString("publisher_confirms"): Boolean(true)})), ShortString("cluster_name"): LongString(LongString("rabbit@trycht")), ShortString("copyright"): LongString(LongString("Copyright (C) 2007-2019 Pivotal Software, Inc.")), ShortString("information"): LongString(LongString("Licensed under the MPL. See https://www.rabbitmq.com/")), ShortString("platform"): LongString(LongString("Erlang/OTP 22.1")), ShortString("product"): LongString(LongString("RabbitMQ")), ShortString("version"): LongString(LongString("3.7.18"))}), mechanisms: LongString("AMQPLAIN PLAIN"), locales: LongString("en_US") }
[2019-10-21T21:00:47Z TRACE lapin::connection] connection send_frame; channel_id=0
[2019-10-21T21:00:47Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop send continue; can_read=true, can_write=true, has_data=false
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run done; can_read=true, can_write=true, has_data=false, status=Initial
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] will write to buffer: Method(0, Connection(StartOk(StartOk { client_properties: FieldTable({ShortString("capabilities"): FieldTable(FieldTable({ShortString("authentication_failure_close"): Boolean(true), ShortString("basic.nack"): Boolean(true), ShortString("connection.blocked"): Boolean(true), ShortString("consumer_cancel_notify"): Boolean(true), ShortString("exchange_exchange_bindings"): Boolean(true), ShortString("publisher_confirms"): Boolean(true)})), ShortString("platform"): LongString(LongString("rust")), ShortString("product"): LongString(LongString("lapin")), ShortString("version"): LongString(LongString("0.28.0"))}), mechanism: ShortString("PLAIN"), response: LongString("\u{0}tester\u{0}tester"), locale: ShortString("en_US") })))
[2019-10-21T21:00:47Z TRACE lapin::io_loop] wrote 259 bytes
[2019-10-21T21:00:47Z TRACE lapin::io_loop] read 20 bytes
[2019-10-21T21:00:47Z TRACE lapin::connection] will handle frame: Method(0, Connection(Tune(Tune { channel_max: 2047, frame_max: 131072, heartbeat: 30 })))
[2019-10-21T21:00:47Z DEBUG lapin::channel] Server sent Connection::Tune: Tune { channel_max: 2047, frame_max: 131072, heartbeat: 30 }
[2019-10-21T21:00:47Z TRACE lapin::connection] connection send_frame; channel_id=0
[2019-10-21T21:00:47Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:47Z TRACE lapin::connection] connection send_frame; channel_id=0
[2019-10-21T21:00:47Z TRACE lapin::frames] channel 0 state is now waiting for (ConnectionOpenOk(WaitHandle), WaitHandle)
[2019-10-21T21:00:47Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:47Z TRACE lapin::io_loop] will write to buffer: Method(0, Connection(TuneOk(TuneOk { channel_max: 2047, frame_max: 131072, heartbeat: 30 })))
[2019-10-21T21:00:47Z TRACE lapin::io_loop] wrote 20 bytes
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] will write to buffer: Method(0, Connection(Open(Open { virtual_host: ShortString("/") })))
[2019-10-21T21:00:47Z TRACE lapin::io_loop] wrote 16 bytes
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true
[2019-10-21T21:00:47Z TRACE lapin::io_loop] wrote 0 bytes
[2019-10-21T21:00:47Z TRACE lapin::io_loop] read 13 bytes
[2019-10-21T21:00:47Z TRACE lapin::connection] will handle frame: Method(0, Connection(OpenOk(OpenOk)))
[2019-10-21T21:00:47Z DEBUG lapin::channels] create channel
[2019-10-21T21:00:47Z DEBUG lapin::channels] create channel with id 1
[2019-10-21T21:00:47Z TRACE lapin::connection] connection send_frame; channel_id=1
[2019-10-21T21:00:47Z TRACE lapin::frames] channel 1 state is now waiting for (ChannelOpenOk(WaitHandle), WaitHandle)
[2019-10-21T21:00:47Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop send continue; can_read=true, can_write=true, has_data=false
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop do_run done; can_read=true, can_write=true, has_data=false, status=Initial
[2019-10-21T21:00:47Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop: start heartbeat
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop: heartbeat started
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] will write to buffer: Method(1, Channel(Open(Open)))
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 13 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] read 16 bytes
[2019-10-21T21:00:48Z TRACE lapin::connection] will handle frame: Method(1, Channel(OpenOk(OpenOk)))
[2019-10-21T21:00:48Z TRACE lapin::connection] connection send_frame; channel_id=1
[2019-10-21T21:00:48Z TRACE lapin::frames] channel 1 state is now waiting for (ConfirmSelectOk(WaitHandle), WaitHandle)
[2019-10-21T21:00:48Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:48Z TRACE lapin::io_loop] will write to buffer: Method(1, Confirm(Select(Select { nowait: false })))
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 13 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] read 12 bytes
[2019-10-21T21:00:48Z TRACE lapin::connection] will handle frame: Method(1, Confirm(SelectOk(SelectOk)))
[2019-10-21T21:00:48Z TRACE lapin::connection] connection send_frames; channel_id=1
[2019-10-21T21:00:48Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:48Z TRACE lapin::io_loop] will write to buffer: Method(1, Basic(Publish(Publish { exchange: ShortString(""), routing_key: ShortString("somewhere"), mandatory: false, immediate: false })))
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 26 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] will write to buffer: Header(1, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 3, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: None, priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, kind: None, user_id: None, app_id: None, cluster_id: None } })
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 22 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] will write to buffer: Body(1, [102, 111, 111])
[2019-10-21T21:00:48Z TRACE lapin::connection] connection send_frame; channel_id=1
[2019-10-21T21:00:48Z TRACE lapin::frames] channel 1 state is now waiting for (ChannelCloseOk(WaitHandle), WaitHandle)
[2019-10-21T21:00:48Z TRACE lapin::connection] connection set readable
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 11 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] will write to buffer: Method(1, Channel(Close(Close { reply_code: 200, reply_text: ShortString("Normal shutdown"), class_id: 0, method_id: 0 })))
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 34 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true
[2019-10-21T21:00:48Z TRACE lapin::io_loop] wrote 0 bytes
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=false, status=Setup
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop run
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop poll done
[2019-10-21T21:00:48Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=false
[2019-10-21T21:00:48Z TRACE lapin::io_loop] read 33 bytes
[2019-10-21T21:00:48Z TRACE lapin::connection] will handle frame: Method(1, Basic(Ack(Ack { delivery_tag: 1, multiple: false })))
[2019-10-21T21:00:48Z ERROR lapin::connection] Connection error
Error: InvalidChannelState(Error)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment