Artemis (ActiveMQ) messaging in Wildfly 10 cluster (domain)

Question

Could someone provide an example of messaging application working under Wildfly 10 cluster (domain)? We are struggling with it and given that it is a new technology, there is a terrible lack of resources.

Currently we have the following:

A domain consisting of two hosts (nodes) and three groups on each, i.e. six separate servers in the domain.

A relevant part of server configuration (in domain.xml):

The configuration is more or less default, except added TestQ queue.

tcphq stack is defined in the JGroups configuration as follows:

                
                    
                    
                        
                          dev1[7660],dev1[7810],dev1[7960],dev2[7660],dev2[7810],dev2[7960]
                        
                        
                            0

I have written a testing application consisting from a simple "server", meaning MDB and a client as follows:

Server (MDB):

@MessageDriven(mappedName = "test", activationConfig = {
    @ActivationConfigProperty(propertyName = "subscriptionDurability", propertyValue = "Durable"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:jboss/exported/jms/queue/testq"),
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})
public class MessageServer implements MessageListener {

    @Override
    public void onMessage(Message message) {

        try {
            ObjectMessage msg = null;

            if (message instanceof ObjectMessage) {
                msg = (ObjectMessage) message;
            }
            System.out.print("The number in the message: "+ msg.getIntProperty("count"));
        } catch (JMSException ex) {
            Logger.getLogger(MessageServer.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

Client:

@Singleton
@Startup
public class ClientBean implements ClientBeanLocal {

    @Resource(mappedName = "java:jboss/exported/jms/RemoteConnectionFactory")
    private ConnectionFactory factory;

    @Resource(mappedName = "java:jboss/exported/jms/queue/testq")
    private Queue queue;

    @PostConstruct
    public void sendMessage() {

        Connection connection = null;
        try {

            connection = factory.createConnection();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer producer = session.createProducer(queue);

            Message message = session.createObjectMessage();
            message.setIntProperty("count", 1);

            producer.send(message);
            System.out.println("Message sent.");

        } catch (JMSException ex) {
            Logger.getLogger(ClientBean.class.getName()).log(Level.SEVERE, null, ex);
        } catch (NamingException ex) {
            Logger.getLogger(ClientBean.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            try {
                if (connection != null) connection.close();
            } catch (JMSException ex) {
                Logger.getLogger(ClientBean.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }

}

It actually works well if both client and server reside in the same group. In such a case it even seems it communicates between hosts (nodes). However if the server and client are in different groups, MDB is not invoked. Moreover, it even seems that MDB is invoked only if it resides in the group with 0 offset. When I moved the server MDB into a different group, it was not responding even if the client was in the same group.

I am a bit confused about JMS in Wildfly 10. There is a lot of examples and materials for older versions with HornetQ, however very few for Artemis. Could someone help? Many thanks.

Artemis (ActiveMQ) messaging in Wildfly 10 cluster (domain)

Answers (1)

Related Questions