This example shows how to setup and run HornetQ embedded with remote clients connecting.
HornetQ was designed to use POJOs (Plain Old Java Objects), what makes embedding HornetQ as simple as instantiating a few objects.
We have limited the server classpath on this example:
Similarly we have also limited the classpath on client:
HornetQ Embedded could be used from very simple use cases with only InVM support to very complex cases with clustering, persistence and fail over.
To run the example, simply type ./build.sh
(or build.bat
on windows) from this directory
In this we don't use any configuration files. (Everything is embedded). We simply instantiate ConfigurationImpl, HornetQServer, start it and operate on JMS regularly
process = startRemoteEmbedded();
Configuration configuration = new ConfigurationImpl(); configuration.setEnablePersistence(false); configuration.setSecurityEnabled(false);
HornetQServer server = HornetQ.newHornetQServer(configuration); server.start();
ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(NettyConnectorFactory.class.getName())); ClientSessionFactory sf = serverLocator.createSessionFactory();
ClientSession coreSession = sf.createSession(false, false, false); final String queueName = "queue.exampleQueue"; coreSession.createQueue(queueName, queueName, true); coreSession.close();
session = sf.createSession(); ClientProducer producer = session.createProducer(queueName);
ClientMessage message = session.createMessage(false); message.putStringProperty(propName, "Hello sent at " + new Date()); System.out.println("Sending the message."); producer.send(message);
ClientConsumer messageConsumer = session.createConsumer(queueName); session.start();
ClientMessage messageReceived = messageConsumer.receive(1000); System.out.println("Received TextMessage:" + messageReceived.getProperty(propName));
if (sf != null) { sf.close(); }
process.destroy();