Dear Justin,

Thank you so much for your response. My environment is pretty simple. I run a freshly downloaded hornetq-2.2.5.Final server on an Ubuntu machine with java 1.7.0_95. And my Subscriber is very simple Spring Boot application sending a message to a destination on this server and trying to subscribe from it. This application runs on the same Ubuntu machine, basically HornetQ and the java application on the same localhost. I am attaching the Spring boot application, you can simply unzip it and build/run it as a normal Maven application.

I find the same problem in my QA landscape where the HornetQ server configuration is much more complex. So I guess I'm missing something very basic.

Regards,

Sandeep

Hi Justin,

I managed to connect using the native hornetq libraries instead of Spring. Perhaps the Spring implementation has some incompatibilities. But I guess we don't have to waste time trying to find that out for the moment. Below is the working code:

I sincerely appreciate your time and effort intending to help me.

Cheers,

Sandeep

------------------------------------------------------------------------------------------------------------------

package hornetqmessaging;

import java.util.HashMap;

import java.util.Map;

import org.hornetq.api.core.TransportConfiguration;

import org.hornetq.api.core.client.ClientConsumer;

import org.hornetq.api.core.client.ClientMessage;

import org.hornetq.api.core.client.ClientSession;

import org.hornetq.api.core.client.ClientSessionFactory;

import org.hornetq.api.core.client.HornetQClient;

import org.hornetq.api.core.client.ServerLocator;

public class MessageConsumer {

    public static void main(String[] args) throws Exception    {

        String queueName = "q_sandeep";

        //Get a session and consumer to the queue

        ClientSession session = getClientSession();       

        ClientConsumer cc = session.createConsumer(queueName);

        session.start();

        String message;

        do    {

            //Blocking receive

            System.out.println("Waiting (Blocked) for message from " + queueName);

            ClientMessage received = cc.receive();

            received.acknowledge();

            message = received.getBodyBuffer().readString();

            System.out.println("Received a message from " + queueName + ": " + message);

        }

        while(!"stop".equalsIgnoreCase(message));

        session.close();       

    }

    private static ClientSession getClientSession() throws Exception    {

        System.out.println("Initiating connection...");

        Map<String, Object> connectionParams = new HashMap<String, Object>();

        connectionParams.put(org.hornetq.core.remoting.impl.netty.TransportConstants.PORT_PROP_NAME, 5445);

        connectionParams.put(org.hornetq.core.remoting.impl.netty.TransportConstants.HOST_PROP_NAME, "10.97.154.143");

        TransportConfiguration transportConfiguration = new TransportConfiguration(org.hornetq.core.remoting.impl.netty.NettyConnectorFactory.class.getCanonicalName(), connectionParams);

        ServerLocator loc = HornetQClient.createServerLocatorWithoutHA(transportConfiguration);

        ClientSessionFactory sessionFactory = loc.createSessionFactory(transportConfiguration);

        System.out.println("Session Factory Created: " + sessionFactory.toString());

        return sessionFactory.createSession(true, true);       

    }   

}