HI

I have this client Client Jms

            Queue queue = new HornetQQueue("testQueue");

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

            connectionParams.put(TransportConstants.CLUSTER_CONNECTION, "231.7.7.7:9876");    

            TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName(), connectionParams);

            ConnectionFactory cf = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(new DiscoveryGroupConfiguration(groupAddress, groupPort),

JMSFactoryType.QUEUE_CF);    

When i run the codes following:

             MessageConsumer consumer = session.createConsumer(queue);

            //Message can also be consumed from here:

            for (int i = 0; i < 1000; i++) {  

                message = (TextMessage) consumer.receive(3000);

                LOGGER.info(message.getText());

            }

I consumer the messages only on JBOSSA ?

Why does this happen?

If I run my client Jms for second time  I consume the messages on JBOSSB

add my code cluster-connections

<cluster-connections>

                    <cluster-connection name="my-cluster">

                        <address>jms</address>

                        <connector-ref>netty</connector-ref>

                        <retry-interval>500</retry-interval>

                        <use-duplicate-detection>true</use-duplicate-detection>

                        <forward-when-no-consumers>true</forward-when-no-consumers>

                        <max-hops>1</max-hops>

                        <discovery-group-ref discovery-group-name="my-discovery-group"/>

                    </cluster-connection>

                </cluster-connections>

Thank You