Created
October 23, 2019 10:45
-
-
Save tyrylu/951e21803f89c8d1c724640ffc4620c6 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-23T10:39:01Z TRACE mio::poll] registering with poller | |
[2019-10-23T10:39:01Z DEBUG lapin::channels] create channel with id 0 | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection send_frame; channel_id=0 | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:01Z TRACE mio::poll] registering with poller | |
[2019-10-23T10:39:01Z TRACE mio::poll] registering with poller | |
[2019-10-23T10:39:01Z TRACE mio::poll] registering with poller | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] will write to buffer: ProtocolHeader | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] wrote 8 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] wrote 0 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=false, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=false | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] read 494 bytes | |
[2019-10-23T10:39:01Z 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-23T10:39:01Z 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-23T10:39:01Z TRACE lapin::connection] connection send_frame; channel_id=0 | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=true, can_write=true, has_data=false | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=true, can_write=true, has_data=false, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z 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-23T10:39:01Z TRACE lapin::io_loop] wrote 259 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] wrote 0 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=false, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=false | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] read 20 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::connection] will handle frame: Method(0, Connection(Tune(Tune { channel_max: 2047, frame_max: 131072, heartbeat: 30 }))) | |
[2019-10-23T10:39:01Z DEBUG lapin::channel] Server sent Connection::Tune: Tune { channel_max: 2047, frame_max: 131072, heartbeat: 30 } | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection send_frame; channel_id=0 | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection send_frame; channel_id=0 | |
[2019-10-23T10:39:01Z TRACE lapin::frames] channel 0 state is now waiting for (ConnectionOpenOk(WaitHandle), WaitHandle) | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=true, can_write=true, has_data=false | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=true, can_write=true, has_data=false, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] will write to buffer: Method(0, Connection(TuneOk(TuneOk { channel_max: 2047, frame_max: 131072, heartbeat: 30 }))) | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] wrote 20 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] will write to buffer: Method(0, Connection(Open(Open { virtual_host: ShortString("/") }))) | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] wrote 16 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] wrote 0 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] read 13 bytes | |
[2019-10-23T10:39:01Z TRACE lapin::connection] will handle frame: Method(0, Connection(OpenOk(OpenOk))) | |
[2019-10-23T10:39:01Z DEBUG lapin::channels] create channel | |
[2019-10-23T10:39:01Z DEBUG lapin::channels] create channel with id 1 | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection send_frame; channel_id=1 | |
[2019-10-23T10:39:01Z TRACE lapin::frames] channel 1 state is now waiting for (ChannelOpenOk(WaitHandle), WaitHandle) | |
[2019-10-23T10:39:01Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop send continue; can_read=true, can_write=true, has_data=false | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop do_run done; can_read=true, can_write=true, has_data=false, status=Initial | |
[2019-10-23T10:39:01Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop: start heartbeat | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop: heartbeat started | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] will write to buffer: Method(1, Channel(Open(Open))) | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] wrote 13 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] read 16 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::connection] will handle frame: Method(1, Channel(OpenOk(OpenOk))) | |
[2019-10-23T10:39:02Z TRACE lapin::connection] connection send_frame; channel_id=1 | |
[2019-10-23T10:39:02Z TRACE lapin::frames] channel 1 state is now waiting for (ConfirmSelectOk(WaitHandle), WaitHandle) | |
[2019-10-23T10:39:02Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] will write to buffer: Method(1, Confirm(Select(Select { nowait: false }))) | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] wrote 13 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] read 12 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::connection] will handle frame: Method(1, Confirm(SelectOk(SelectOk))) | |
[2019-10-23T10:39:02Z TRACE lapin::connection] connection send_frames; channel_id=1 | |
[2019-10-23T10:39:02Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:02Z TRACE lapin::channel_status] Publisher confirms activated | |
[2019-10-23T10:39:02Z TRACE lapin::channel] Channel status is now ChannelStatus { inner: RwLock { data: Inner { confirm: true, send_flow: true, state: Connected } } } | |
[2019-10-23T10:39:02Z 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-23T10:39:02Z TRACE lapin::io_loop] wrote 26 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z 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-23T10:39:02Z TRACE lapin::io_loop] wrote 22 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] will write to buffer: Body(1, [102, 111, 111]) | |
[2019-10-23T10:39:02Z TRACE lapin::channel] No confirms to wait for | |
[2019-10-23T10:39:02Z TRACE lapin::connection] connection send_frame; channel_id=1 | |
[2019-10-23T10:39:02Z TRACE lapin::frames] channel 1 state is now waiting for (ChannelCloseOk(WaitHandle), WaitHandle) | |
[2019-10-23T10:39:02Z TRACE lapin::connection] connection set readable | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] wrote 11 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z 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-23T10:39:02Z TRACE lapin::io_loop] wrote 34 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop send continue; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=true, status=Setup | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run; can_read=false, can_write=true, has_data=true | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] wrote 0 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run done; can_read=false, can_write=true, has_data=false, status=Setup | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop run | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop poll done | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] io_loop do_run; can_read=true, can_write=true, has_data=false | |
[2019-10-23T10:39:02Z TRACE lapin::io_loop] read 33 bytes | |
[2019-10-23T10:39:02Z TRACE lapin::connection] will handle frame: Method(1, Basic(Ack(Ack { delivery_tag: 1, multiple: false }))) | |
[2019-10-23T10:39:02Z 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