Created
October 21, 2019 21:04
-
-
Save tyrylu/91d255625e485e12ebf57378e3aa4005 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[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