The documentation for HornetQ version 2.2.5.Final, under JMS Pojo Instantiation (section 43.2) has this code as an example...
Configuration configuration = new ConfigurationImpl(); | |
configuration.setPersistenceEnabled(false); | |
configuration.setSecurityEnabled(false); | |
configuration.getAcceptorConfigurations() | |
.add(new TransportConfiguration(NettyAcceptorFactory.class.getName())); |
// Step 2. Create the JMS configuration
JMSConfiguration jmsConfig = new JMSConfigurationImpl(); |
// Step 3. Configure the JMS ConnectionFactory
TransportConfiguration connectorConfig = new TransportConfiguration(NettyConnectorFactory.class.getName()); | |
ConnectionFactoryConfiguration cfConfig = new ConnectionFactoryConfigurationImpl("cf", connectorConfig, "/cf"); | |
jmsConfig.getConnectionFactoryConfigurations().add(cfConfig); |
// Step 4. Configure the JMS Queue
JMSQueueConfiguration queueConfig = new JMSQueueConfigurationImpl("queue1", null, false, "/queue/queue1"); | |
jmsConfig.getQueueConfigurations().add(queueConfig); |
// Step 5. Start the JMS Server using the HornetQ core server and the JMS configuration
EmbeddedJMS jmsServer = new EmbeddedJMS(); | |
jmsServer.setConfiguration(configuration); | |
jmsServer.setJmsConfiguration(jmsConfig); | |
jmsServer.start(); |
...which does not compile. The constructor 'ConnectionFactoryConfiguration cfConfig = new ConnectionFactoryConfigurationImpl("cf", connectorConfig, "/cf");' is unavailable. I've tried some alternates but can't seem to get this right. Anyone have the documentation for the working example?
Thanks,
David
Thanks for raising this.. we will take a look...
But we have all the examples under the source code being executed on every release. You should refer to those.