tag:blogger.com,1999:blog-29871611.post9146106741236123564..comments2015-07-24T12:03:30.908-04:00Comments on Side Notes: Get started with RabbitMQAndrey Paramonovhttp://www.blogger.com/profile/14375033587137190103noreply@blogger.comBlogger4125tag:blogger.com,1999:blog-29871611.post-91581356847404403642012-09-28T18:22:25.001-04:002012-09-28T18:22:25.001-04:00Thanks Matt!Thanks Matt!Andrey Paramonovhttps://www.blogger.com/profile/14375033587137190103noreply@blogger.comtag:blogger.com,1999:blog-29871611.post-76902177803611121302012-09-28T16:43:37.067-04:002012-09-28T16:43:37.067-04:00Thanks for the nice little example!
I've upda...Thanks for the nice little example!<br /><br />I've updated the code to work with the latest Java client and posted it as a Gist on GitHub - <a href="https://gist.github.com/3801945" rel="nofollow">https://gist.github.com/3801945</a>Matt Passellhttps://www.blogger.com/profile/08333337257678227054noreply@blogger.comtag:blogger.com,1999:blog-29871611.post-67173171839506335442010-09-03T20:26:46.746-04:002010-09-03T20:26:46.746-04:00Hi Wolfgang, thank you for the update!Hi Wolfgang, thank you for the update!Andrey Paramonovhttps://www.blogger.com/profile/14375033587137190103noreply@blogger.comtag:blogger.com,1999:blog-29871611.post-49446218086015990312010-09-03T08:49:39.950-04:002010-09-03T08:49:39.950-04:00Hi Andrey,
thanks for this nice tutorial.
I trie...Hi Andrey,<br /><br />thanks for this nice tutorial.<br /><br />I tried it with the newly released RabbitMQ 2.0 and had to adjust some parts due to API changes in the corresponding java client.<br /><br />The connection part now looks like this:<br /><br />@Grab(group='com.rabbitmq', module='amqp-client', version='2.0.0')<br />import com.rabbitmq.client.*<br /><br />params = [<br /> username: 'guest',<br /> password: 'guest',<br /> virtualHost: '/',<br /> requestedHeartbeat: 0<br />]<br />factory = new ConnectionFactory(params)<br />conn = factory.newConnection(['localhost', 5672] as Address)<br />channel = conn.createChannel()<br /><br /><br />Note that class ConnectionParameters no longer exists and ConnectionFactory.newConnection() expects an Address as parameter.<br /><br /><br />When declaring a queue, some more parameters are necessary as well:<br /><br /><br />channel.queueDeclare queueName, false, false, true, [:]<br /><br /><br />Otherwise the scripts run just fine.<br /><br />Thanks again,<br /><br />WolfgangWolfgang Schellhttps://www.blogger.com/profile/04425267088286089720noreply@blogger.com