[SOLVED] Push between multiple webapps?

[smithh032772]

Got it working with JMS: ActiveMQ + a simple web listener to read messages from the topic.

Can you share code?

[FkJ]

Code: Select all

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.InitialContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import org.primefaces.push.PushContext;
import org.primefaces.push.PushContextFactory;

@WebListener
public class JmsMessageListener implements ServletContextListener
{
	private TopicConnection connection;
	private TopicSession    session;
	private TopicSubscriber subscriber;

	@Override
	public void contextInitialized(ServletContextEvent sce)
	{
		try
		{
			InitialContext initCtx = new InitialContext();
			TopicConnectionFactory connectionFactory = (TopicConnectionFactory) initCtx.lookup("java:comp/env/jms/ConnectionFactory");
			connection = connectionFactory.createTopicConnection();
			session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
			Topic topic = (Topic) initCtx.lookup("java:comp/env/jms/AtmosphereTopic");
			subscriber = session.createSubscriber(topic);
			subscriber.setMessageListener(new MessageListener()
			{
				@Override
				public void onMessage(Message message)
				{
					try
					{
						ObjectMessage objectMessage = (ObjectMessage) message;
						PushMessage pushMessage = (PushMessage) objectMessage.getObject();
						
						PushContext pushContext = PushContextFactory.getDefault().getPushContext();
						pushContext.push(pushMessage.getChannel(), pushMessage.getData());
					}
					catch(JMSException e)
					{
						throw new RuntimeException(e);
					}
				}
			});
			connection.start();
		}
		catch(Exception e)
		{
			throw new RuntimeException(e);
		}
	}

	@Override
	public void contextDestroyed(ServletContextEvent sce)
	{
		try
		{
			if(subscriber != null)
			{
				subscriber.close();
			}

			if(session != null)
			{
				session.close();
			}

			if(connection != null)
			{
				connection.close();
			}
		}
		catch(Exception e)
		{
			throw new RuntimeException(e);
		}
	}
}

I didn't wrote the final version of the message publisher yet, I'm waiting to see if I'm going to use the Atmosphere JMSBroadcaster or not to continue the implementation. PushMesage is a serializable java bean with the properties String channel and Object data.

I configured ActiveMQ in the Tomcat context.xml file.

Code: Select all

	<Resource
		auth="Container"
		name="jms/ConnectionFactory"
		type="org.apache.activemq.ActiveMQConnectionFactory"
		description="JMS Connection Factory"
		factory="org.apache.activemq.jndi.JNDIReferenceFactory"
		brokerURL="tcp://localhost:61616?daemon=true"
		useEmbeddedBroker="false"
		brokerName="localhost" 
        />

	<Resource
		auth="Container"
		name="jms/AtmosphereTopic"
		type="org.apache.activemq.command.ActiveMQTopic"
		description="JMS Topic"
		factory="org.apache.activemq.jndi.JNDIReferenceFactory"
		physicalName="ATMOSPHERE.TOPIC" 
        />

Tomcat was hanging on shutdown, adding daemon=true solved it.

pom.xml

Code: Select all

		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-client</artifactId>
			<version>5.9.1</version>
		</dependency>

		<dependency>
			<groupId>javax.jms</groupId>
			<artifactId>jms</artifactId>
			<version>1.1</version>
		</dependency>

		<dependency>
			<groupId>javax.management.j2ee</groupId>
			<artifactId>javax.management.j2ee-api</artifactId>
			<version>1.1.1</version>
		</dependency>

[smithh032772]

Very good. Thanks.

[marc.bouvier.agipi]

Here is how I did it.

I actually used Spring to instanciate Jms Topic...

Code: Select all

    <!-- Connection to Tibco EMS -->
    <bean id="tibjmsConnectionFactory" class="com.tibco.tibjms.TibjmsConnectionFactory">
        <property name="serverUrl" value="${instance.jms.server}" />
        <property name="userName" value="${instance.jms.login}"/>
        <property name="userPassword" value="${instance.jms.password}"/>
    </bean>
    
    <bean id="jmsTemplateEms" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="tibjmsConnectionFactory" />
        <property name="explicitQosEnabled" value="true" />
        <property name="deliveryMode" value="2" />
        <property name="sessionAcknowledgeModeName" value="CLIENT_ACKNOWLEDGE" />
        <property name="sessionTransacted" value="false" />
        <property name="receiveTimeout" value="${instance.wait.timeout}" />
    </bean>
    
    <bean id="pushJmsMessageListener" class="com.agipi.g2a.tiana.web.utils.PushJmsMessageListener" />
    
    <bean id="atmosphereTopic" class="com.tibco.tibjms.TibjmsTopic">
        <!-- nom du topic-->
        <constructor-arg index="0" value="${instance.jms.atmosphere.topic.name}" />
    </bean>
    <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="tibjmsConnectionFactory"/>
        <property name="destination" ref="atmosphereTopic"/>
        <property name="messageListener" ref="pushJmsMessageListener" />
    </bean>

... and created a MessageListener which listen to atmosphere topic and publish received message to Push event bus ...

Code: Select all

    class PushJmsMessageListener implements MessageListener {
        private static final Logger LOGGER = LoggerFactory.getLogger(PushJmsMessageListener.class);
    
        private static final String PROPERTY_PUSH_CHANNEL = "pushChannel";
    
        @Override
        public void onMessage(Message message) {
    
            try {
                EventBus eventBus = EventBusFactory.getDefault().eventBus();
                TextMessage testMessage = (TextMessage) message;
                LOGGER.info("Reception d'un message du topic atmosphere : {}", testMessage);
    
                String canal = testMessage.getStringProperty(PROPERTY_PUSH_CHANNEL);
                Object decodedObject = new JSONDecoder().decode(testMessage.getText());
                LOGGER.info("Envoi du message sur le endpoint push [canal={},objet={}]", canal, decodedObject);
                eventBus.publish(canal, decodedObject);
            } catch (JMSException e) {
                LOGGER.error("error.receiving.jms.message", e);
    
            }
        }
    }

... and created a Spring service to publish my message to the topic instead of push ...

Code: Select all

    @Service
    @Scope(value = "singleton")
    public class JmsAtmosphereServiceImpl implements JmsAtmosphereService {
    
        @Autowired
        @Qualifier("jmsTemplateEms")
        private JmsTemplate jmsTemplate;
    
        @Autowired
        @Qualifier("atmosphereTopic")
        private Topic atmosphereTopic;
    
    
        @Override
        public void sendMessage(String pushChannel, String jsonContent) {
            jmsTemplate.send(atmosphereTopic, session -> {
                TextMessage textMessage = session.createTextMessage(jsonContent);
                textMessage.setStringProperty("pushChannel", pushChannel);
                return textMessage;
            });
    
        }
    
    }

... some utility to abstract ...

Code: Select all

    @Service
    public class PushJmsUtils {
    
        private static final String PUSH_DEFAULT_CHANNEL = "atmosphere";
    
        @Autowired
        private JmsAtmosphereService jmsAtmosphereService;
    
        /**
         * Propagate message JMS as JSON to JMS Atmosphere topic.
         *
         * @param channel push channel
         * @param message object to send via push
         */
        public void propagateMessage(String channel, Object message) {
            String id = channel;
            if (id.startsWith("/*")) {
                id = PUSH_DEFAULT_CHANNEL;
            }
            jmsAtmosphereService.sendMessage(id, new JSONEncoder().encode(message));
        }
    
    }

.. and then, I publish my message to several instances of my application listening to the same atmosphere topic (including the application sending the message).

Code: Select all

     pushJmsUtils.propagateMessage(canal,pushMessage);

[soekris]

Thanks to post one solution