Page Comparison

...

Create a custom proxy service with the following configuration. For more information on creating proxy services, see Working with Proxy Services.

Code Block

<?xml version="1.0" encoding="UTF8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse" name="AMQPProducerSample" transports="http" statistics="disable" trace="disable" startOnLoad="true">
<target>
 <inSequence>
    <property name="OUT_ONLY" value="true"/>
    <property name="FORCE_SC_ACCEPTED" value="true" scope="axis2"/>
     <send>
      <endpoint>
       <address uri="rabbitmq:/AMQPProducerSample?rabbitmq.server.host.name=localhost&amp;rabbitmq.server.port=5672&amp;rabbitmq.queue.name=queue&amp;rabbitmq.queue.route.key=route&amp;rabbitmq.exchange.name=exchange"/>
      </endpoint>
    </send>
 </inSequence>
 <outSequence>
        <send/>
 </outSequence>
</target>
<description/>
</proxy>

Use the following as a RabbitMQ consumer that will consume and display the incoming messages to the RabbitMQ queue.

Code Block

language	java

ConnectionFactoryfactory = new ConnectionFactory();
factory.setHost("localhost");
factory.setUsername("guest");
factory.setPassword("guest");
factory.setPort(5672);
 
Connectionconnection = factory.newConnectionnew Connection();
Channelchannel = connection.createChannel();
channel.queueDeclare("queue",false,false,false,null);
channel.exchangeDeclare("exchange","direct",true);
channel.queueBind("queue","exchange","route");
 
//Createtheconsumer
QueueingConsumerconsumer = new QueueingConsumer(channel);
channel.basicConsume("queue",true,consumer);
 
//Startconsumingmessages
while(true)
 {
 QueueingConsumer.Deliverydelivery = consumer.nextDelivery();
 StringmessageString message = new String(delivery.getBody());
 }

...

Versions Compared

Old Version 6

New Version 7

Key