{"action":"created","issue":{"url":"https://api.github.com/repos/zeromq/netmq/issues/572","repository_url":"https://api.github.com/repos/zeromq/netmq","labels_url":"https://api.github.com/repos/zeromq/netmq/issues/572/labels{/name}","comments_url":"https://api.github.com/repos/zeromq/netmq/issues/572/comments","events_url":"https://api.github.com/repos/zeromq/netmq/issues/572/events","html_url":"https://github.com/zeromq/netmq/issues/572","id":162817473,"number":572,"title":"NetMQ.FaultException: Cannot close an uninitialised Msg.","user":{"login":"lianghugg","id":11206959,"avatar_url":"https://avatars.githubusercontent.com/u/11206959?v=3","gravatar_id":"","url":"https://api.github.com/users/lianghugg","html_url":"https://github.com/lianghugg","followers_url":"https://api.github.com/users/lianghugg/followers","following_url":"https://api.github.com/users/lianghugg/following{/other_user}","gists_url":"https://api.github.com/users/lianghugg/gists{/gist_id}","starred_url":"https://api.github.com/users/lianghugg/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lianghugg/subscriptions","organizations_url":"https://api.github.com/users/lianghugg/orgs","repos_url":"https://api.github.com/users/lianghugg/repos","events_url":"https://api.github.com/users/lianghugg/events{/privacy}","received_events_url":"https://api.github.com/users/lianghugg/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-06-29T00:36:37Z","updated_at":"2016-09-09T06:20:09Z","closed_at":null,"body":"### Environment\r\n\r\n    NetMQ Version:    3.3.31\r\n    Operating System: win7 x64\r\n    .NET Version:     4.0\r\n\r\n### Expected behaviour\r\n\r\nNetMQ.FaultException: Cannot close an uninitialised Msg.\r\n   at NetMQ.Msg.Close()\r\n   at NetMQ.Core.Transports.V2Encoder.MessageReady()\r\n   at NetMQ.Core.Transports.V2Encoder.Next()\r\n   at NetMQ.Core.Transports.EncoderBase.GetData(ByteArraySegment& data, Int32& size, Int32& offset)\r\n   at NetMQ.Core.Transports.StreamEngine.BeginSending()\r\n   at NetMQ.Core.Transports.StreamEngine.Handle(Action action, SocketError socketError, Int32 bytesTransferred)\r\n   at NetMQ.Core.Transports.StreamEngine.FeedAction(Action action, SocketError socketError, Int32 bytesTransferred)\r\n   at NetMQ.Core.Transports.StreamEngine.ActivateOut()\r\n   at NetMQ.Core.SessionBase.ReadActivated(Pipe pipe)\r\n   at NetMQ.Core.Pipe.ProcessActivateRead()\r\n   at NetMQ.Core.ZObject.ProcessCommand(Command cmd)\r\n   at NetMQ.Core.IOThread.Ready()\r\n   at NetMQ.Core.Utils.Proactor.Loop()\r\n   at System.Threading.ThreadHelper.ThreadStart_Context(Object state)\r\n   at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)\r\n   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)\r\n   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)\r\n   at System.Threading.ThreadHelper.ThreadStart()\r\n\r\n### Actual behaviour\r\n\r\n\r\n\r\n### Steps to reproduce the behaviour\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/zeromq/netmq/issues/comments/245829135","html_url":"https://github.com/zeromq/netmq/issues/572#issuecomment-245829135","issue_url":"https://api.github.com/repos/zeromq/netmq/issues/572","id":245829135,"user":{"login":"answerfly","id":8877193,"avatar_url":"https://avatars.githubusercontent.com/u/8877193?v=3","gravatar_id":"","url":"https://api.github.com/users/answerfly","html_url":"https://github.com/answerfly","followers_url":"https://api.github.com/users/answerfly/followers","following_url":"https://api.github.com/users/answerfly/following{/other_user}","gists_url":"https://api.github.com/users/answerfly/gists{/gist_id}","starred_url":"https://api.github.com/users/answerfly/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/answerfly/subscriptions","organizations_url":"https://api.github.com/users/answerfly/orgs","repos_url":"https://api.github.com/users/answerfly/repos","events_url":"https://api.github.com/users/answerfly/events{/privacy}","received_events_url":"https://api.github.com/users/answerfly/received_events","type":"User","site_admin":false},"created_at":"2016-09-09T06:20:09Z","updated_at":"2016-09-09T06:20:09Z","body":"Dear somdoron, I met the same NetMQ.FaultException. I have make a pub-sub demo and did some pressure test. There were two threads in my client. One thread did the \"recieve\" operation  and the other did the \"SubscriberSocket.subscribe\" operation every 3 seconds with 1000 different subscribes. I want to ask whether the operations to the SubscriberSocket must be done in one thread?  If so ,how can I do when I want to change the subscriber frequently while the  SubscriberSocket receive the data from the Pub server at the same time.  \r\nThanks a lot."}}
{"actor":{"display_login":"answerfly"}}