{"action":"created","issue":{"url":"https://api.github.com/repos/pika/pika/issues/752","repository_url":"https://api.github.com/repos/pika/pika","labels_url":"https://api.github.com/repos/pika/pika/issues/752/labels{/name}","comments_url":"https://api.github.com/repos/pika/pika/issues/752/comments","events_url":"https://api.github.com/repos/pika/pika/issues/752/events","html_url":"https://github.com/pika/pika/issues/752","id":156136180,"number":752,"title":"in another thread with hearbeat?","user":{"login":"daoiqi","id":2141872,"avatar_url":"https://avatars.githubusercontent.com/u/2141872?v=3","gravatar_id":"","url":"https://api.github.com/users/daoiqi","html_url":"https://github.com/daoiqi","followers_url":"https://api.github.com/users/daoiqi/followers","following_url":"https://api.github.com/users/daoiqi/following{/other_user}","gists_url":"https://api.github.com/users/daoiqi/gists{/gist_id}","starred_url":"https://api.github.com/users/daoiqi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/daoiqi/subscriptions","organizations_url":"https://api.github.com/users/daoiqi/orgs","repos_url":"https://api.github.com/users/daoiqi/repos","events_url":"https://api.github.com/users/daoiqi/events{/privacy}","received_events_url":"https://api.github.com/users/daoiqi/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2016-05-22T05:33:49Z","updated_at":"2016-05-31T05:47:54Z","closed_at":"2016-05-24T00:53:28Z","body":"https://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v1.6.0/rabbitmq-dotnet-client-1.6.0-user-guide.pdf\r\n``9.1. Connections, Channels, Sessions and Models``\r\n> Each AMQP connection is represented by an instance of ConnectionBase. Each connection has one\r\nthread running in the background, which reads and dispatches frames from the connection socket, as well as acting as a serialization point for outbound AMQP commands. There may also be two additional threads responsible for Heartbeat support (In and Outbound), if it was negotiated during the\r\nconnection open process.\r\n\r\nbut in BlockConnection, this is all in one thread. It is necessary with another thread to deal hearbeat ?"},"comment":{"url":"https://api.github.com/repos/pika/pika/issues/comments/222597657","html_url":"https://github.com/pika/pika/issues/752#issuecomment-222597657","issue_url":"https://api.github.com/repos/pika/pika/issues/752","id":222597657,"user":{"login":"daoiqi","id":2141872,"avatar_url":"https://avatars.githubusercontent.com/u/2141872?v=3","gravatar_id":"","url":"https://api.github.com/users/daoiqi","html_url":"https://github.com/daoiqi","followers_url":"https://api.github.com/users/daoiqi/followers","following_url":"https://api.github.com/users/daoiqi/following{/other_user}","gists_url":"https://api.github.com/users/daoiqi/gists{/gist_id}","starred_url":"https://api.github.com/users/daoiqi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/daoiqi/subscriptions","organizations_url":"https://api.github.com/users/daoiqi/orgs","repos_url":"https://api.github.com/users/daoiqi/repos","events_url":"https://api.github.com/users/daoiqi/events{/privacy}","received_events_url":"https://api.github.com/users/daoiqi/received_events","type":"User","site_admin":false},"created_at":"2016-05-31T05:47:54Z","updated_at":"2016-05-31T05:47:54Z","body":"I have some  long time I/O. (more than 10 min )\r\n\r\nWhen recive data, consumer do something, but it is long time task.  When  consumer has done, then ack to MQ, and publish new data.\r\n\r\nIf all in one thread, consumer doing task  with block, then the heartbeats not any thread to deal with.\r\n\r\nOr I'm using `ack` mechanism error?   \r\n\r\nwhich is  better?\r\n\r\n```\r\n1. revice data then ack to MQ  \r\n2. do long time.         ----- if server is crash, heartbeats is not significance.\r\n3. publish new data.\r\n```\r\n\r\nor\r\n\r\n```\r\n1. recive data\r\n2. do long time and hearbeat check    --- if crash, mq will resend message\r\n3. publish new data and ack to MQ.\r\n```\r\n\r\nCan I start thread to do I/O task, and another thread do `BlockingConnection.process_data_events`? \r\n"}}
{"actor":{"display_login":"daoiqi"}}