An example of creating a reliable, distributed, and elastic STOMP server using HazelcastMQ on top of Hazelcast.

HazelcastMQStompExample.java

HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance();

HazelcastMQConfig mqConfig = new HazelcastMQConfig();
mqConfig.setHazelcastInstance(hazelcast);
HazelcastMQInstance mqInstance = HazelcastMQ.newHazelcastMQInstance(mqConfig);

// Create the server.
HazelcastMQStompConfig stompConfig = new HazelcastMQStompConfig(mqInstance);
HazelcastMQStompInstance stompServer = HazelcastMQStomp.newHazelcastMQStompInstance(stompConfig);

// Create a client.
StompClient stompClient = new StompClient("localhost", stompConfig.getPort());
stompClient.connect();

// Send a message.
Frame frame = FrameBuilder.send("/queue/demo.test", "Hello World!").build();
stompClient.send(frame);

// Sit back and enjoy! More at https://github.com/mpilone/hazelcastmq