Applying Complex Event Processing with Drools Fusion. A case study: Analyzing Tweets

2011-11-17T11:41:00.001-08:00

Big Table and HBASE

2011-11-17T11:39:00.001-08:00

Workflow and Web Services Composition II

2011-05-09T08:52:00.000-07:00

Workflow and Web Services Composition I

2011-05-09T08:50:00.000-07:00

Big Table

2010-11-19T08:12:00.001-08:00

Optimal Adaptation in Autonomic Web Processes with Inter-Service Dependencies

2010-10-27T10:04:00.001-07:00

Optimal Adaptation

View more presentations from mcorrea11.

RESTFul Introduction Presentation

2010-10-27T10:03:00.001-07:00

RESTFul Web Services - Intro

View more presentations from mcorrea11.

Map Reduce Presentation

2010-10-27T09:49:00.001-07:00

Map Reduce

View more presentations from mcorrea11.

Spring, ActiveMQ and JMS implementation

2010-07-22T07:11:00.000-07:00

Here is a quick implementation for JMS using Spring and ActiveMQ in Tomcat 6.

First, libraries and frameworks:

ActiveMQ 5.1
Spring 2.5
Tomcat 6
Be sure to add: org.osgi.core-4.1.0.jar, spring-jms.jar, xbean-spring-3.6.jar

For my testing I created two applications: Consumer and Producer. The producer sends a "Hello World: message and the consumer "processes" the message.

Consumer configuration

applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:jms="http://www.springframework.org/schema/jms"
       xmlns:amq="http://activemq.apache.org/schema/core"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/context
                           http://www.springframework.org/schema/context/spring-context.xsd
                           http://www.springframework.org/schema/jms
                           http://www.springframework.org/schema/jms/spring-jms.xsd
                           http://activemq.apache.org/schema/core
                           http://activemq.apache.org/schema/core/activemq-core.xsd">

    <context:component-scan base-package="sample" />

    <!--  Embedded ActiveMQ Broker -->
    <amq:broker id="broker" useJmx="false" persistent="false">
        <amq:transportConnectors>
            <amq:transportConnector uri="tcp://localhost:61616" />
        </amq:transportConnectors>
    </amq:broker>

    <amq:connectionFactory id="jmsFactory" brokerURL="tcp://localhost:61616" />

     <!-- JMS Consumer Configuration -->
    <bean id="jmsConsumerConnectionFactory"
          class="org.springframework.jms.connection.SingleConnectionFactory"
          depends-on="broker"
          p:targetConnectionFactory-ref="jmsFactory" />

    <jms:listener-container container-type="default"
                            connection-factory="jmsConsumerConnectionFactory"
                            acknowledge="auto">
        <jms:listener destination="queue.data" ref="jmsMessageListener" />
    </jms:listener-container>


</beans>

One can see, the broker is embedded within Spring. The destination is queue.data.

JmsMessageListener.java

package sample;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import org.springframework.stereotype.Component;

/**
 *
 * @author mcorrea
 */

@Component
public class JmsMessageListener implements MessageListener {

    public void onMessage(Message message) { 
        try {
            if (message instanceof TextMessage) {
                TextMessage tm = (TextMessage)message;
                String msg = tm.getText();
                System.out.println("Message receive "+msg);
            }
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

}

Producer

applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:jms="http://www.springframework.org/schema/jms"
       xmlns:amq="http://activemq.apache.org/schema/core"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/context
                           http://www.springframework.org/schema/context/spring-context.xsd
                           http://www.springframework.org/schema/jms
                           http://www.springframework.org/schema/jms/spring-jms.xsd
                           http://activemq.apache.org/schema/core
                           http://activemq.apache.org/schema/core/activemq-core.xsd">

    <context:component-scan base-package="sample" />
    <!-- JMS ConnectionFactory to use, configuring the embedded broker using XML -->
    <amq:connectionFactory id="jmsFactory" brokerURL="tcp://localhost:61616" />

      <!--  ActiveMQ Destination  -->
    <amq:queue id="destination" physicalName="queue.data" />

    <!-- JMS Producer Configuration -->
    <bean id="jmsProducerConnectionFactory"
          class="org.springframework.jms.connection.SingleConnectionFactory"
           p:targetConnectionFactory-ref="jmsFactory" />

    <bean id="jmsProducerTemplate" class="org.springframework.jms.core.JmsTemplate"
          p:connectionFactory-ref="jmsProducerConnectionFactory"
          p:defaultDestination-ref="destination" />


</beans>

One can see the jmsFactory and the destination of the broker ( consumer )

JmsMessageProducer.java

package sample;



import javax.annotation.PostConstruct;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;

 
@Component
public class JmsMessageProducer {
  

    @Autowired
    private JmsTemplate template = null;

    /** 
     * Generates JMS messages
     */
    @PostConstruct
    public void generateMessages() throws JMSException {
       
            template.send(new MessageCreator() {
                public Message createMessage(Session session) throws JMSException {
                    TextMessage message = session.createTextMessage("Hello World!!! ");
                    System.out.println("Sending message... " );
                    return message;
                }
            });
       
    }

}

That should do it!! Enjoy.

JSON RFC

2010-02-04T08:55:00.001-08:00

json rfc

Manuel's Blog

Applying Complex Event Processing with Drools Fusion. A case study: Analyzing Tweets

Big Table and HBASE

Workflow and Web Services Composition II

Workflow and Web Services Composition I

Big Table

Optimal Adaptation in Autonomic Web Processes with Inter-Service Dependencies

RESTFul Introduction Presentation

Map Reduce Presentation

Spring, ActiveMQ and JMS implementation

JSON RFC

EMACS 3.1 Spec