package test;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;

import org.apache.qpid.jms.JmsConnectionFactory;

public class AMQPQueueExample {

  /**
   * 
   * Work with wildfly-11.0.0.Alpha1-SNAPSHOT(2017-02-16)
   * 
   * but only on queue. XXX
   * 
   * @param args
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
    Connection connection = null;
    ConnectionFactory connectionFactory = new JmsConnectionFactory("amqp://localhost:61616");

    try {

      // Step 1. Create an amqp qpid 1.0 connection
      connection = connectionFactory.createConnection("jopens", "jopens10$");

      // Step 2. Create a session
      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

      // Step 3. Create a sender
      //Topic queue =session.createTopic("jms.topic.rts.nop");
      Queue queue = session.createQueue("jms.queue.eqim.GD.A");
      MessageProducer sender = session.createProducer(queue);

      // Step 4. send a few simple message
      sender.send(session.createTextMessage("Hello world"));

      connection.start();

      // Step 5. create a moving receiver, this means the message will be
      // removed from the queue
      MessageConsumer consumer = session.createConsumer(queue);

      // Step 7. receive the simple message
      TextMessage m = (TextMessage) consumer.receive(5000);
      System.out.println("message = " + m.getText());
    }
    finally {
      if (connection != null) {
        // Step 9. close the connection
        connection.close();
      }
    }
  }
}