Using Cloud Message Queue Service

Hashtable<Object, Object> env = new Hashtable<Object, Object>();
env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
env.put("connectionfactory.factoryLookup", endpoint);
javax.naming.Context context = new javax.naming.InitialContext(env);

// Create a connection factory.
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("factoryLookup");

// Create a pooled connection factory.
PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(connectionFactory);
pooledConnectionFactory.setMaxConnections(10);

// Establish a connection for the producer.
Connection producerConnection = pooledConnectionFactory.createConnection(username, password);
producerConnection.start();

// Create a session.
Session producerSession = producerConnection.createSession(false, ACKNOWLEDGE_MODE);

// Create a queue named "QUEUE".
Destination producerDestination = producerSession.createQueue(QUEUE);

// Create a producer from the session to the queue.
MessageProducer producer = producerSession.createProducer(producerDestination);
producer.setDeliveryMode(DELIVERY_MODE);

long totalMillis  = 0;
while (totalMillis < RUN_MILLISECONDS) {
    // Generate a random UUID to use for the message
    String message =  UUID.randomUUID().toString();
    // byte[] messageBodyBytes = message.getBytes();
    System.out.println(String.format("Publishing message to exchange %s: %s", QUEUE, message));
    TextMessage producerMessage = producerSession.createTextMessage(message);
    // Send the message.
    producer.send(producerMessage);

    Thread.sleep(INTERVAL);
    totalMillis += INTERVAL;
}

producer.close();
producerSession.close();
producerConnection.close();
pooledConnectionFactory.stop();

class ConsumerMessageListener implements MessageListener {
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println("Message received : " + textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }    
}

Hashtable<Object, Object> env =newHashtable<Object, Object>();
env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
env.put("connectionfactory.factoryLookup", endpoint);
javax.naming.Context context =newjavax.naming.InitialContext(env);

// Create a connection factory.ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("factoryLookup");

// Establish a connection for the consumer.Connection consumerConnection = connectionFactory.createConnection(username, password);
consumerConnection.start();

// Create a session.
Session consumerSession = consumerConnection.createSession(false, ACKNOWLEDGE_MODE);

// Create a queue named "QUEUE".
Destination consumerDestination = consumerSession.createQueue(QUEUE);

// Create a message consumer from the session to the queue.
MessageConsumer consumer = consumerSession.createConsumer(consumerDestination);
consumer.setMessageListener(new ConsumerMessageListener());
Thread.sleep(100000);

consumer.close();
consumerSession.close();
consumerConnection.close();