{"pull_request":{"state":"open","merged_by":null,"user":{"avatar_url":"https://secure.gravatar.com/avatar/9483eb6d259b3be26eaa7bccd93f835a?d=https://a248.e.akamai.net/assets.github.com%2Fimages%2Fgravatars%2Fgravatar-140.png","gravatar_id":"9483eb6d259b3be26eaa7bccd93f835a","url":"https://api.github.com/users/freelas","login":"freelas","id":740419},"deletions":9,"updated_at":"2011-10-28T13:20:01Z","base":{"ref":"master","user":{"avatar_url":"https://secure.gravatar.com/avatar/e0b5787d1a1935a2800e0bbffc81c196?d=https://a248.e.akamai.net/assets.github.com%2Fimages%2Fgravatars%2Fgravatar-140.png","gravatar_id":"e0b5787d1a1935a2800e0bbffc81c196","url":"https://api.github.com/users/jboner","login":"jboner","id":10701},"repo":{"name":"akka-modules","master_branch":null,"fork":false,"pushed_at":"2011-09-19T16:34:28Z","homepage":"http://akka.io","clone_url":"https://github.com/jboner/akka-modules.git","open_issues":1,"updated_at":"2011-10-28T12:47:57Z","svn_url":"https://svn.github.com/jboner/akka-modules","private":false,"forks":9,"language":"Scala","url":"https://api.github.com/repos/jboner/akka-modules","owner":{"avatar_url":"https://secure.gravatar.com/avatar/e0b5787d1a1935a2800e0bbffc81c196?d=https://a248.e.akamai.net/assets.github.com%2Fimages%2Fgravatars%2Fgravatar-140.png","gravatar_id":"e0b5787d1a1935a2800e0bbffc81c196","url":"https://api.github.com/users/jboner","login":"jboner","id":10701},"html_url":"https://github.com/jboner/akka-modules","description":"Akka Modules Repository","size":160,"id":951231,"watchers":60,"git_url":"git://github.com/jboner/akka-modules.git","created_at":"2010-09-30T13:13:19Z","ssh_url":"git@github.com:jboner/akka-modules.git"},"label":"jboner:master","sha":"e463f2a1de769c78db3014a2283f9ed19f8d193a"},"commits":2,"closed_at":null,"comments":0,"diff_url":"https://github.com/jboner/akka-modules/pull/1.diff","head":{"ref":"master","user":{"avatar_url":"https://secure.gravatar.com/avatar/9483eb6d259b3be26eaa7bccd93f835a?d=https://a248.e.akamai.net/assets.github.com%2Fimages%2Fgravatars%2Fgravatar-140.png","gravatar_id":"9483eb6d259b3be26eaa7bccd93f835a","url":"https://api.github.com/users/freelas","login":"freelas","id":740419},"repo":{"name":"akka-modules","master_branch":null,"fork":true,"pushed_at":"2011-10-28T12:55:29Z","homepage":"http://akka.io","clone_url":"https://github.com/freelas/akka-modules.git","open_issues":0,"updated_at":"2011-10-28T12:55:29Z","svn_url":"https://svn.github.com/freelas/akka-modules","private":false,"forks":0,"language":"Scala","url":"https://api.github.com/repos/freelas/akka-modules","owner":{"avatar_url":"https://secure.gravatar.com/avatar/9483eb6d259b3be26eaa7bccd93f835a?d=https://a248.e.akamai.net/assets.github.com%2Fimages%2Fgravatars%2Fgravatar-140.png","gravatar_id":"9483eb6d259b3be26eaa7bccd93f835a","url":"https://api.github.com/users/freelas","login":"freelas","id":740419},"html_url":"https://github.com/freelas/akka-modules","description":"Akka Modules Repository","size":160,"id":2665051,"watchers":1,"git_url":"git://github.com/freelas/akka-modules.git","created_at":"2011-10-28T12:47:57Z","ssh_url":"git@github.com:freelas/akka-modules.git"},"label":"freelas:master","sha":"e39022efd804e6cdec413a8584ac37db6bddd722"},"url":"https://api.github.com/repos/jboner/akka-modules/pulls/1","additions":25,"merged":false,"body":"Here at work we have to deal with this not queued messages ...\r\n\r\n// FIXME: If channel is not available, messages should be queued back into the actor mailbox and actor should only react on 'Start'\r\n\r\nnot using the producer actor. using another actor who knows what to do (could send a error message, store and try to send again later when the channel is ok, ..., ..., ... ) \r\n\r\nActorRef errorCallbackActor = Actors.actorOf(ErrorCallbackActor.class).start();\r\n\r\nProducerParameters producerParameters = new ProducerParameters(exchangeParameters, \"producerActor\", channelParameters, errorCallbackActor);\r\n\r\ntry to send again:\r\n\r\nclass PocChannelCallbackActor extends UntypedActor {\r\n    public void onReceive(Object message) throws Exception {\r\n        if (Started.getInstance().getClass().isAssignableFrom(message.getClass())) {\r\n            //producer.tell(not queued message rescued from errorCallbackActor )\r\n\r\n\r\nwe also updated the amqp client (2.6.1) to suppor high availability\r\n\r\nAMQP.ExchangeParameters exchangeParameters = new AMQP.ExchangeParameters(\"poc.exchange\", Topic.getInstance(), activeDeclaration, new scala.collection.immutable.HashMap<String, Object>().$plus(new Tuple2<String, Object>(\"x-ha-policy\", \"all\")));\r\n\r\n","merged_at":null,"review_comments":0,"html_url":"https://github.com/jboner/akka-modules/pull/1","issue_url":"https://github.com/jboner/akka-modules/issues/1","_links":{"comments":{"_href":"https://api.github.com/repos/jboner/akka-modules/issues/1/comments"},"html":{"_href":"https://github.com/jboner/akka-modules/pull/1"},"review_comments":{"_href":"https://api.github.com/repos/jboner/akka-modules/pulls/1/comments"},"self":{"_href":"https://api.github.com/repos/jboner/akka-modules/pulls/1"}},"number":1,"title":"(suggestion of) changes in ProducerActor and ProducerParameters","mergeable":null,"changed_files":2,"id":442700,"patch_url":"https://github.com/jboner/akka-modules/pull/1.patch","created_at":"2011-10-28T13:20:01Z"},"action":"opened","number":1}