Author: nbelaevski Date: 2011-02-10 09:51:51 -0500 (Thu, 10 Feb 2011) New Revision: 21606 Modified: trunk/examples/push-demo/src/main/java/demo/HornetQInitializer.java Log: https://issues.jboss.org/browse/RF-10487 Modified: trunk/examples/push-demo/src/main/java/demo/HornetQInitializer.java =================================================================== --- trunk/examples/push-demo/src/main/java/demo/HornetQInitializer.java 2011-02-10 14:42:35 UTC (rev 21605) +++ trunk/examples/push-demo/src/main/java/demo/HornetQInitializer.java 2011-02-10 14:51:51 UTC (rev 21606) @@ -40,7 +40,11 @@ import org.hornetq.core.server.HornetQServer; import org.hornetq.core.server.HornetQServers; import org.hornetq.jms.server.JMSServerManager; +import org.hornetq.jms.server.config.ConnectionFactoryConfiguration; +import org.hornetq.jms.server.config.impl.ConnectionFactoryConfigurationImpl; import org.hornetq.jms.server.impl.JMSServerManagerImpl; +import org.richfaces.application.ServiceTracker; +import org.richfaces.application.push.PushContextFactory; /** * @author Nick Belaevski @@ -58,6 +62,9 @@ throw new AbortProcessingException(e); } + //force push context initialization so that its PreDestroyApplicationevent listener is added before HornetQ stopper + ServiceTracker.getService(PushContextFactory.class).getPushContext(); + Application application = FacesContext.getCurrentInstance().getApplication(); application.subscribeToEvent(PreDestroyApplicationEvent.class, this); } else { @@ -101,12 +108,16 @@ serverManager = new JMSServerManagerImpl(server); //if you want to use JNDI, simple inject a context here or don't call this method and make sure the JNDI parameters are set. - serverManager.setContext(new InitialContext()); + InitialContext context = new InitialContext(); + serverManager.setContext(context); serverManager.start(); - serverManager.createConnectionFactory("ConnectionFactory", new TransportConfiguration(NettyConnectorFactory.class.getName()), - "ConnectionFactory"); + ConnectionFactoryConfiguration connectionFactoryConfiguration = new ConnectionFactoryConfigurationImpl("ConnectionFactory", new TransportConfiguration(NettyConnectorFactory.class.getName()), + (String) null); + connectionFactoryConfiguration.setUseGlobalPools(false); + serverManager.createConnectionFactory(false, connectionFactoryConfiguration, "ConnectionFactory"); + serverManager.createTopic(false, "chat", "/topic/chat"); serverManager.createTopic(false, "info", "/topic/info"); }