trace.log

[TRACE lapin_futures::channel] wait for answer; request_id=6 status=NotReady
[TRACE tokio_threadpool::notifier] Notifier::notify; id=0x563885403e20
[TRACE tokio_threadpool::task]     -> not ready
[TRACE tokio_reactor] event Readable | Writable Token(0)
[TRACE tokio_threadpool::notifier] Notifier::notify; id=0x563885403e20
[TRACE tokio_reactor] loop process - 1 events, 0.000s
[TRACE tokio_threadpool::task] Task::run; state=Running
[TRACE lapin_futures::channel] wait for answer; request_id=6
[TRACE lapin_futures::transport] transport poll
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Method(2, Basic(ConsumeOk(ConsumeOk { consumer_tag: "tasks_consumer" })))
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Method(2, Basic(ConsumeOk(ConsumeOk { consumer_tag: "tasks_consumer" })))
[TRACE lapin_async::connection] will handle frame: Method(2, Basic(ConsumeOk(ConsumeOk { consumer_tag: "tasks_consumer" })))
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 1, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 1, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE lapin_async::connection] will handle frame: Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 1, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE lapin_async::api] channel 2 state is now WillReceiveContent("future_tasks", Some("tasks_consumer"))
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 41, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 41, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE lapin_async::connection] will handle frame: Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 41, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Body(2, [123, 34, 67, 114, 101, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 34, 58, 34, 80, 97, 197, 153, 101, 122, 115, 107, 195, 161, 32, 76, 104, 111, 116, 97, 34, 125])
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Body(2, [123, 34, 67, 114, 101, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 34, 58, 34, 80, 97, 197, 153, 101, 122, 115, 107, 195, 161, 32, 76, 104, 111, 116, 97, 34, 125])
[TRACE lapin_async::connection] will handle frame: Body(2, [123, 34, 67, 114, 101, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 34, 58, 34, 80, 97, 197, 153, 101, 122, 115, 107, 195, 161, 32, 76, 104, 111, 116, 97, 34, 125])
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 2, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 2, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE lapin_async::connection] will handle frame: Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 2, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE lapin_async::api] channel 2 state is now WillReceiveContent("future_tasks", Some("tasks_consumer"))
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 31, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 31, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE lapin_async::connection] will handle frame: Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 31, properties: AMQPProperties { content_type: None, content_encoding: None, headers: None, delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Body(2, [123, 34, 67, 114, 101, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 34, 58, 34, 84, 117, 114, 110, 111, 118, 34, 125])
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Body(2, [123, 34, 67, 114, 101, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 34, 58, 34, 84, 117, 114, 110, 111, 118, 34, 125])
[TRACE lapin_async::connection] will handle frame: Body(2, [123, 34, 67, 114, 101, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 34, 58, 34, 84, 117, 114, 110, 111, 118, 34, 125])
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 3, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 3, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE lapin_async::connection] will handle frame: Method(2, Basic(Deliver(Deliver { consumer_tag: "tasks_consumer", delivery_tag: 3, redelivered: true, exchange: "", routing_key: "tasks" })))
[TRACE lapin_async::api] channel 2 state is now WillReceiveContent("future_tasks", Some("tasks_consumer"))
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 21, properties: AMQPProperties { content_type: None, content_encoding: None, headers: Some({"x-death": FieldArray([FieldTable({"count": LongLongInt(1), "exchange": LongString(""), "original-expiration": LongString("28417401"), "queue": LongString("future_tasks"), "reason": LongString("expired"), "routing-keys": FieldArray([LongString("future_tasks")]), "time": Timestamp(1555027060)})]), "x-first-death-exchange": LongString(""), "x-first-death-queue": LongString("future_tasks"), "x-first-death-reason": LongString("expired")}), delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 21, properties: AMQPProperties { content_type: None, content_encoding: None, headers: Some({"x-death": FieldArray([FieldTable({"count": LongLongInt(1), "exchange": LongString(""), "original-expiration": LongString("28417401"), "queue": LongString("future_tasks"), "reason": LongString("expired"), "routing-keys": FieldArray([LongString("future_tasks")]), "time": Timestamp(1555027060)})]), "x-first-death-exchange": LongString(""), "x-first-death-queue": LongString("future_tasks"), "x-first-death-reason": LongString("expired")}), delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE lapin_async::connection] will handle frame: Header(2, 60, AMQPContentHeader { class_id: 60, weight: 0, body_size: 21, properties: AMQPProperties { content_type: None, content_encoding: None, headers: Some({"x-death": FieldArray([FieldTable({"count": LongLongInt(1), "exchange": LongString(""), "original-expiration": LongString("28417401"), "queue": LongString("future_tasks"), "reason": LongString("expired"), "routing-keys": FieldArray([LongString("future_tasks")]), "time": Timestamp(1555027060)})]), "x-first-death-exchange": LongString(""), "x-first-death-queue": LongString("future_tasks"), "x-first-death-reason": LongString("expired")}), delivery_mode: Some(2), priority: None, correlation_id: None, reply_to: None, expiration: None, message_id: None, timestamp: None, type_: None, user_id: None, app_id: None, cluster_id: None } })
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[TRACE lapin_futures::transport] amqp decoder; frame=Body(2, [34, 85, 112, 100, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 115, 34])
[TRACE tokio_io::_tokio_codec::framed_read] frame decoded from buffer
[TRACE lapin_futures::transport] transport poll_recv; frame=Body(2, [34, 85, 112, 100, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 115, 34])
[TRACE lapin_async::connection] will handle frame: Body(2, [34, 85, 112, 100, 97, 116, 101, 65, 114, 101, 97, 68, 97, 116, 97, 98, 97, 115, 101, 115, 34])
[TRACE tokio_io::_tokio_codec::framed_read] attempting to decode a frame
[DEBUG tokio_reactor::registration] scheduling Read for: 0
[TRACE lapin_futures::transport] transport poll_recv; status=NotReady
[TRACE lapin_futures::transport] transport poll_complete
[TRACE tokio_io::_tokio_codec::framed_write] flushing framed transport
[TRACE tokio_io::_tokio_codec::framed_write] framed transport flushed
[TRACE lapin_futures::channel] wait for answer transport poll; request_id=6 status=NotReady
[TRACE lapin_futures::channel] wait for answer; request_id=6 status=Ready result=Some(6)
[TRACE lapin_futures::channel] basic_consume received response, returning consumer
[INFO  worker] Starting tasks consumption...
[TRACE lapin_futures::consumer] consumer poll; consumer_tag="tasks_consumer" polling transport
[TRACE lapin_futures::transport] transport poll
[DEBUG tokio_reactor::registration] scheduling Read for: 0
[TRACE lapin_futures::transport] transport poll_recv; status=NotReady
[TRACE lapin_futures::transport] transport poll_complete
[TRACE tokio_io::_tokio_codec::framed_write] flushing framed transport
[TRACE tokio_io::_tokio_codec::framed_write] framed transport flushed
[TRACE lapin_futures::consumer] consumer poll; consumer_tag="tasks_consumer" acquired inner lock
[TRACE tokio_threadpool::notifier] Notifier::notify; id=0x563885403e20
[TRACE lapin_futures::consumer] delivery; consumer_tag="tasks_consumer" status=NotReady
[TRACE tokio_threadpool::task]     -> not ready
[TRACE tokio_threadpool::task] Task::run; state=Running
[TRACE lapin_futures::consumer] consumer poll; consumer_tag="tasks_consumer" polling transport
[TRACE lapin_futures::transport] transport poll
[DEBUG tokio_reactor::registration] scheduling Read for: 0
[TRACE lapin_futures::transport] transport poll_recv; status=NotReady
[TRACE lapin_futures::transport] transport poll_complete
[TRACE tokio_io::_tokio_codec::framed_write] flushing framed transport
[TRACE tokio_io::_tokio_codec::framed_write] framed transport flushed
[TRACE lapin_futures::consumer] consumer poll; consumer_tag="tasks_consumer" acquired inner lock
[TRACE lapin_futures::consumer] delivery; consumer_tag="tasks_consumer" status=NotReady
[TRACE tokio_threadpool::task]     -> not ready
[TRACE tokio_threadpool::worker] Worker::sleep; worker=WorkerId(0)
[TRACE tokio_threadpool::worker]   sleeping -- push to stack; idx=0
[TRACE tokio_threadpool::worker]     -> starting to sleep; idx=0
[TRACE tokio_reactor] loop process - 0 events, 0.000s