rabbitmq sample

gistfile1.java

/*
<dependencies>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>3.1.1</version>
        </dependency>
    </dependencies>

*/

ConnectionFactory factory = new ConnectionFactory();
        factory.setUri("amqp://test:test@my.test");
        Connection connection = factory.newConnection();
        final Channel ngnixChannel = connection.createChannel();
        final Channel visaChannel = connection.createChannel();
        // queue,   durable,  exclusive,  autoDelete, arguments
        ngnixChannel.queueDeclare(MY_QUEUE_NAME, true, false, false, null);


ngnixChannel.basicPublish("", NGNIX_QUEUE_NAME, null, logProducer.getLog().getBytes());