{"id":219,"date":"2013-01-14T14:33:47","date_gmt":"2013-01-14T14:33:47","guid":{"rendered":"http:\/\/www.andreagirardi.it\/blog\/?p=219"},"modified":"2018-03-27T09:48:53","modified_gmt":"2018-03-27T09:48:53","slug":"camel-and-rabbitmq-finally-how-to","status":"publish","type":"post","link":"https:\/\/www.andreagirardi.it\/blog\/camel-and-rabbitmq-finally-how-to\/","title":{"rendered":"Camel and RabbitMQ : Finally, how to!"},"content":{"rendered":"

Define a RabbitMQ broker endpoint in Camel is possible with the Bluelock camel-spring-amqp (https:\/\/github.com\/Bluelock\/camel-spring-amqp) library. It’s an Apache Camel component that allows to natively communicate with a RabbitMQ broker and it’s implemented using Spring’s AMQP.<\/p>\n

For first, with Eclipse IDE create a new Maven Project with Artifact ID camel-arthetype-spring. This allows using Spring DSL to configure Camel route and execute the run:camel goal of Camel Mavel Pluing (Camel Maven Plugin) in a forked JVM from Maven.<\/p>\n

To resolve the dependencies, these entries are mandatory:<\/p>\n

\r\n\r\n\tcom.bluelock<\/groupId>\r\n\tcamel-spring-amqp<\/artifactId>\r\n\t1.2<\/version>\r\n<\/dependency>\r\n\r\n\r\n\r\n\torg.apache.camel<\/groupId>\r\n\tcamel-test<\/artifactId>\r\n\t${org.camel.version}<\/version>          \r\n<\/dependency>\r\n\r\n\torg.apache.camel<\/groupId>\r\n\tcamel-spring<\/artifactId>\r\n\t${org.camel.version}<\/version>        \r\n\t\r\n\t\t\r\n\t\t\tspring-tx<\/artifactId>\r\n\t\t\torg.springframework<\/groupId>\r\n\t\t<\/exclusion>\r\n\t\t\r\n\t\t\tspring-context<\/artifactId>\r\n\t\t\torg.springframework<\/groupId>\r\n\t\t<\/exclusion>\r\n\t<\/exclusions>\r\n<\/dependency>\r\n\r\n\torg.apache.camel<\/groupId>\r\n\tcamel-xstream<\/artifactId>\r\n\t${org.camel.version}<\/version>            \r\n<\/dependency>\r\n<\/pre>\n
At this point edit the camel-context.xml available on src\/main\/resource\/META-INF\/spring folder:<\/p>\n
\r\n\r\n\r\n\r\n\r\n       \r\n\t\r\n\t\t\t\r\n\t\t\t\r\n\t\t\t\t\t\t\r\n\t\t\t\r\n\t\t<\/route>\r\n\t<\/camelContext>\r\n\r\n\t\r\n\t\r\n\t\r\n\t\r\n\t\r\n\t    \r\n\t    \r\n\t    \r\n\t    \r\n\t    \r\n\t<\/bean>\r\n\t\r\n    \r\n    \r\n    \r\n        \r\n            \r\n                \r\n                \r\n            <\/map>\r\n        <\/property>\r\n        \r\n    <\/bean>\r\n    \r\n<\/beans>\r\n<\/pre>\n
In this case, a route starting from a RabbitMQ queue to a system log and a listener on your queue that will be active until you terminate your maven came:run process has been created.<\/p>\n
It’s very important to note that, on Spring XML & has to be quoted &amp;<\/p>\n
The following Java code should be used send a message to the Exchange defined on Camel Route:<\/p>\n
@Test\r\npublic void test() throws KeyManagementException, NoSuchAlgorithmException, URISyntaxException, IOException {\r\n\tConnectionFactory factory = new ConnectionFactory();\r\n\tfactory.setHost(\"10.211.55.20\");\r\n\tfactory.setPort(5672);\r\n\tfactory.setVirtualHost(\"\/\");\r\n\tfactory.setUsername(\"guest\");\r\n\tfactory.setPassword(\"guest\");\r\n\tConnection connection = factory.newConnection();\r\n\tChannel channel = connection.createChannel();\r\n\r\n\tchannel.exchangeDeclare(\"KipcastDirect\", \"direct\", \r\n\t\t   true, \t\/* durable *\/\r\n\t\t   true, \t\/* autodelete *\/\r\n\t\t   null); \t\/* *\/\r\n\r\n\tbyte[] messageBodyBytes = \"Hello, world!\".getBytes();\r\n\r\n\tAMQP.BasicProperties.Builder basic = new AMQP.BasicProperties.Builder();\r\n\tAMQP.BasicProperties minBasic = basic.build();\r\n\r\n\tminBasic = basic.priority(0).deliveryMode(1).build();\r\n\r\n\tchannel.basicPublish(\"KipcastDirect\", \"KipcastRouting\", minBasic, messageBodyBytes);\r\n\tSystem.out.println(\" [x] Sent \");\r\n\r\n\tchannel.close();\r\n}<\/pre>\n
To test if listener works, for first run the queue listener and, after that, run the Junit class to send message. The output will be:<\/p>\n
[pache.camel.spring.Main.main()] MainSupport                    INFO  Apache Camel 2.10.3 starting\r\n[pache.camel.spring.Main.main()] SpringCamelContext             INFO  Apache Camel 2.10.3 (CamelContext: camel-1) is starting\r\n[pache.camel.spring.Main.main()] ManagementStrategyFactory      INFO  JMX enabled.\r\n[pache.camel.spring.Main.main()] DefaultTypeConverter           INFO  Loaded 177 type converters\r\n[pache.camel.spring.Main.main()] SpringAMQPComponent            INFO  Found AMQP ConnectionFactory in registry for 10.211.55.20\r\n[pache.camel.spring.Main.main()] SpringAMQPComponent            INFO  Found AMQP Template in registry\r\n[pache.camel.spring.Main.main()] SpringAMQPComponent            INFO  Found AMQP Administrator in registry\r\n[pache.camel.spring.Main.main()] SpringAMQPEndpoint             INFO  Creating endpoint for KipcastDirect:KipcastQueue:KipcastRouting\r\n[pache.camel.spring.Main.main()] SpringAMQPConsumer             INFO  Declared exchange KipcastDirect\r\n[pache.camel.spring.Main.main()] SpringAMQPConsumer             INFO  Declared queue KipcastQueue\r\n[pache.camel.spring.Main.main()] SpringAMQPConsumer             INFO  Declaring binding KipcastRouting\r\n[pache.camel.spring.Main.main()] SpringAMQPConsumer             INFO  Started AMQP Async Listeners for spring-amqp:\/\/KipcastDirect:KipcastQueue:KipcastRouting?autodelete=true&durable=true&type=direct\r\n[pache.camel.spring.Main.main()] SpringCamelContext             INFO  Route: route1 started and consuming from: Endpoint[spring-amqp:\/\/KipcastDirect:KipcastQueue:KipcastRouting?autodelete=true&durable=true&type=direct]\r\n[pache.camel.spring.Main.main()] ultManagementLifecycleStrategy INFO  StatisticsLevel at All so enabling load performance statistics\r\n[pache.camel.spring.Main.main()] SpringCamelContext             INFO  Total 1 routes, of which 1 is started.\r\n[pache.camel.spring.Main.main()] SpringCamelContext             INFO  Apache Camel 2.10.3 (CamelContext: camel-1) started in 0.505 seconds\r\n[     SimpleAsyncTaskExecutor-1] route1                         INFO  Message available on a RabbitMQ Queue<\/pre>\n
At this point, you can have fun with Camel and RabbitMQ!!!!! <\/p>\n
NOTES:<\/p>\n
1 – Please be careful: the URI (from and to) on Camel Spring DSL context and JUnit class must refer to same Exchange and Queue to prevent a reply-text=PRECONDITION_FAILED – parameters for queue ‘QUEUE’ in vhost ‘\/’ not equivalen error or similar. To check the queues\/exchanges configuration parameter using:<\/p>\n
rabbitmqadmin -V \/ list queue\r\nrabbitmqadmin -V test list exchanges<\/pre>\n
if you like this post, please click on the advertise :)<\/strong><\/p>\n
[AdSense-A]<\/p>\n
Share this:<\/h3>