{"action":"created","issue":{"url":"https://api.github.com/repos/hazelcast/hazelcast/issues/8705","repository_url":"https://api.github.com/repos/hazelcast/hazelcast","labels_url":"https://api.github.com/repos/hazelcast/hazelcast/issues/8705/labels{/name}","comments_url":"https://api.github.com/repos/hazelcast/hazelcast/issues/8705/comments","events_url":"https://api.github.com/repos/hazelcast/hazelcast/issues/8705/events","html_url":"https://github.com/hazelcast/hazelcast/issues/8705","id":170670235,"number":8705,"title":"ReliableTopic loosing messages","user":{"login":"BogdanEM","id":10814337,"avatar_url":"https://avatars.githubusercontent.com/u/10814337?v=3","gravatar_id":"","url":"https://api.github.com/users/BogdanEM","html_url":"https://github.com/BogdanEM","followers_url":"https://api.github.com/users/BogdanEM/followers","following_url":"https://api.github.com/users/BogdanEM/following{/other_user}","gists_url":"https://api.github.com/users/BogdanEM/gists{/gist_id}","starred_url":"https://api.github.com/users/BogdanEM/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/BogdanEM/subscriptions","organizations_url":"https://api.github.com/users/BogdanEM/orgs","repos_url":"https://api.github.com/users/BogdanEM/repos","events_url":"https://api.github.com/users/BogdanEM/events{/privacy}","received_events_url":"https://api.github.com/users/BogdanEM/received_events","type":"User","site_admin":false},"labels":[{"id":137752575,"url":"https://api.github.com/repos/hazelcast/hazelcast/labels/Team:%20Core","name":"Team: Core","color":"109def","default":false},{"id":1740690,"url":"https://api.github.com/repos/hazelcast/hazelcast/labels/Type:%20Defect","name":"Type: Defect","color":"eb6420","default":false}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":{"url":"https://api.github.com/repos/hazelcast/hazelcast/milestones/76","html_url":"https://github.com/hazelcast/hazelcast/milestones/3.8","labels_url":"https://api.github.com/repos/hazelcast/hazelcast/milestones/76/labels","id":1774122,"number":76,"title":"3.8","description":"","creator":{"login":"degerhz","id":8373100,"avatar_url":"https://avatars.githubusercontent.com/u/8373100?v=3","gravatar_id":"","url":"https://api.github.com/users/degerhz","html_url":"https://github.com/degerhz","followers_url":"https://api.github.com/users/degerhz/followers","following_url":"https://api.github.com/users/degerhz/following{/other_user}","gists_url":"https://api.github.com/users/degerhz/gists{/gist_id}","starred_url":"https://api.github.com/users/degerhz/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/degerhz/subscriptions","organizations_url":"https://api.github.com/users/degerhz/orgs","repos_url":"https://api.github.com/users/degerhz/repos","events_url":"https://api.github.com/users/degerhz/events{/privacy}","received_events_url":"https://api.github.com/users/degerhz/received_events","type":"User","site_admin":false},"open_issues":165,"closed_issues":427,"state":"open","created_at":"2016-05-18T14:13:56Z","updated_at":"2016-12-07T15:45:04Z","due_on":null,"closed_at":null},"comments":15,"created_at":"2016-08-11T15:11:31Z","updated_at":"2016-12-07T16:36:38Z","closed_at":null,"body":"I'm using a reliable topic to send messages across the two servers in my cluster. When some event happens on one of the servers the other one needs to be notified (and vice versa). Actually I publish a message and both servers receive it and act on it.\n\nThis works nicely most of the times, but sometimes a message gets lost one one machine. There is no exception in the logs, nothing. All indicates that the message is either not sent to both servers or not received by one of them. Just one of the two messages is lost not both. Most of the times I get two messages, but sometimes just one.\n\nI was unable to figure out a pattern, looks random. It doesn't seem to mater which server it is either. Sometimes the message is lost on one server, sometimes on the other.\n\nI publish the message like this:\n\n```\nhazelcastInstance.getReliableTopic(\"myTopic\");\ntopic.publish(message);\n```\n\nwith the Hazelcast instance being configured like this:\n\n```\n@Bean(name = \"hazelcastInstance\", destroyMethod = \"shutdown\")\npublic HazelcastInstance buildHazelcastInstance() {\n\n    Config hazelcastConfig = new Config();\n\n    setProperties(hazelcastConfig);\n    setNetworkConfigs(hazelcastConfig);\n    setReliableTopic(hazelcastConfig);\n    setExecutorConfigs(hazelcastConfig);\n\n    return Hazelcast.newHazelcastInstance(hazelcastConfig);\n}\n\n.......\n.......\n\nprivate void setReliableTopic(Config hazelcastConfig) {\n\n    EventListener implementation = new MessageListener<String>() {\n        @Override\n        public void onMessage(Message<String> message) {\n            // use message.getMessageObject() here\n            // ........\n        }\n    };\n    ListenerConfig listenerConfig = new ListenerConfig(implementation);\n\n    ReliableTopicConfig topicConfig = new ReliableTopicConfig(\"myTopic\")\n            .setStatisticsEnabled(false) \n            .setReadBatchSize(10) \n            .setTopicOverloadPolicy(TopicOverloadPolicy.BLOCK) \n            .addMessageListenerConfig(listenerConfig);\n\n    hazelcastConfig.addReliableTopicConfig(topicConfig);\n}\n```\n\nThe message is a plain String, nothing custom that might cause serialization issues.\n"},"comment":{"url":"https://api.github.com/repos/hazelcast/hazelcast/issues/comments/265497906","html_url":"https://github.com/hazelcast/hazelcast/issues/8705#issuecomment-265497906","issue_url":"https://api.github.com/repos/hazelcast/hazelcast/issues/8705","id":265497906,"user":{"login":"mmedenjak","id":17194871,"avatar_url":"https://avatars.githubusercontent.com/u/17194871?v=3","gravatar_id":"","url":"https://api.github.com/users/mmedenjak","html_url":"https://github.com/mmedenjak","followers_url":"https://api.github.com/users/mmedenjak/followers","following_url":"https://api.github.com/users/mmedenjak/following{/other_user}","gists_url":"https://api.github.com/users/mmedenjak/gists{/gist_id}","starred_url":"https://api.github.com/users/mmedenjak/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mmedenjak/subscriptions","organizations_url":"https://api.github.com/users/mmedenjak/orgs","repos_url":"https://api.github.com/users/mmedenjak/repos","events_url":"https://api.github.com/users/mmedenjak/events{/privacy}","received_events_url":"https://api.github.com/users/mmedenjak/received_events","type":"User","site_admin":false},"created_at":"2016-12-07T16:36:38Z","updated_at":"2016-12-07T16:36:38Z","body":"Glad to hear that. I have an idea as to why this is happening so we will try and solve this so you don't need a workaround."}}
{"actor":{"display_login":"mmedenjak"}}