Setelah postingan sebelumnya membahas cara install ActiveMQ di Linux. Pada kesempatan kali ini saya akan memberikan tutorial implementasi ActiveMQ dengan menggunakan Spring JMS. Lets Begin…

1. Tools yang digunakan

1. Apache ActiveMQ
2. Spring JMS
3. Apache Maven
4. Log4j

Project Structure

2. Project Dependency

Tambahkan dependency activeMQ, Spring dan Log4j di pom.xml

File:pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <groupId>com.yudi</groupId>
 <artifactId>SpringMQ</artifactId>
 <packaging>war</packaging>
 <version>1.0-SNAPSHOT</version>
 <name>SpringMQ Maven Webapp</name>
 <url>http://maven.apache.org</url>
 <properties>
 <releaseCandidate>1</releaseCandidate>
 <spring.version>3.1.1.RELEASE</spring.version>
 <java.version>1.5</java.version>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 <maven.javadoc.reporting.version>2.7</maven.javadoc.reporting.version>
 <commons.logging.version>1.1.1</commons.logging.version>
 <log4j.version>1.2.16</log4j.version>
 <context.path>spring-activemq-sample</context.path>
 </properties>
 <dependencies>
 <dependency>
 <groupId>log4j</groupId>
 <artifactId>log4j</artifactId>
 <version>${log4j.version}</version>
 </dependency>
 <dependency>
 <groupId>org.apache.activemq</groupId>
 <artifactId>activemq-all</artifactId>
 <version>5.1.0</version>
 <scope>compile</scope>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-jms</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-aspects</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-web</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-webmvc</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>javax.servlet</groupId>
 <artifactId>servlet-api</artifactId>
 <version>2.4</version>
 </dependency>
 </dependencies>
 <build>
 <finalName>SpringMQ</finalName>
 <plugins>
 <plugin>
 <groupId>org.apache.maven.plugins</groupId>
 <artifactId>maven-war-plugin</artifactId>
 <configuration>
 <warName>${context.path}</warName>
 </configuration>
 </plugin>
 </plugins>
 </build>
</project>

3. OutgoingMessageSender

File:OutgoingMessageSender.java

package com.yudi.jms;

import javax.jms.JMSException;
import javax.jms.Queue;

import org.apache.log4j.Logger;
import org.springframework.jms.core.JmsTemplate;

public class OutgoingMessageSender {

private static final Logger LOG = Logger.getLogger(OutgoingMessageSender.class);

 private JmsTemplate jmsTemplate;
 private Queue queue;

 public void sendMessage(String message) throws JMSException {
 LOG.info("Message yang akan di taruh di queue. Queue[" + queue.toString() + "] Message[" + message + "]");
 jmsTemplate.convertAndSend(queue, message);

 }

 public void setJmsTemplate(JmsTemplate jmsTemplate) {
 this.jmsTemplate = jmsTemplate;
 }

 public void setQueue(Queue queue) {
 this.queue = queue;
 }
}

4. IncomingListener

File:IncomingListener.java

package com.yudi.jms;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import javax.management.JMException;

import org.apache.log4j.Logger;

public class IncomingListener implements MessageListener {

private OutgoingMessageSender outgoingMessageSender;

private static final Logger LOG = Logger.getLogger(IncomingListener.class);

public void setOutgoingMessageSender(
 OutgoingMessageSender outgoingMessageSender) {
 this.outgoingMessageSender = outgoingMessageSender;
 }

public void onMessage(Message message) {
 // TODO Auto-generated method stub
 LOG.info("Terima message dari queue" + message);

if (message instanceof TextMessage) {

try {
 String msgText = ((TextMessage) message).getText();
 LOG.info("proses message " + msgText);

outgoingMessageSender.sendMessage(msgText);
 } catch (JMSException e) {
 // TODO: handle exception
 LOG.info("Error :" + e.getMessage());
 }
 } else {
 String errMsg = "Message Salah";
 LOG.error(errMsg);
 throw new RuntimeException(errMsg);
 }
 }

}

5. Spring Configuration

Buat spring configurationnya.

File:spring-config.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:context="http://www.springframework.org/schema/context"
 xmlns:jee="http://www.springframework.org/schema/jee"
 xsi:schemaLocation="http://www.springframework.org/schema/beans
 http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
 http://www.springframework.org/schema/context
 http://www.springframework.org/schema/context/spring-context-3.0.xsd
 http://www.springframework.org/schema/beans
 http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
 http://www.springframework.org/schema/jee
 http://www.springframework.org/schema/jee/spring-jee-3.0.xsd">

<jee:jndi-lookup id="mqConnectionFactory" jndi-name="java:comp/env/jms/mqConnectionFactory" />
 <jee:jndi-lookup id="incomingQueues" jndi-name="java:comp/env/jms/incomingQueues" />
 <jee:jndi-lookup id="outgoingQueues" jndi-name="java:comp/env/jms/outgoingQueues" />
 <bean id="incomingListener" class="com.yudi.jms.IncomingListener">
 <property name="outgoingMessageSender" ref="outgoingMessageSender" />
 </bean>

<bean id="outgoingMessageSender" class="com.yudi.jms.OutgoingMessageSender">
 <property name="jmsTemplate" ref="jmsTemplate" />
 <property name="queue" ref="outgoingQueues" />
 </bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
 <property name="connectionFactory" ref="mqConnectionFactory" />
 </bean>

<bean id="yudiMessageListenerContainer"
 class="org.springframework.jms.listener.DefaultMessageListenerContainer">
 <property name="connectionFactory" ref="mqConnectionFactory" />
 <property name="destination" ref="incomingQueues" />
 <property name="messageListener" ref="incomingListener" />
 <property name="concurrentConsumers" value="4" />
 </bean>

</beans>

6. Context Configuration

File:context.xml

<Context>

<Resource name="jms/mqConnectionFactory"
 auth="Container"
 type="org.apache.activemq.ActiveMQConnectionFactory"
 description="JMS Connection Factory"
 factory="org.apache.activemq.jndi.JNDIReferenceFactory"
 brokerURL="tcp://localhost:61616" />

<Resource name="jms/incomingQueues"
 auth="Container"
 type="org.apache.activemq.command.ActiveMQQueue"
 factory="org.apache.activemq.jndi.JNDIReferenceFactory"
 physicalName="IncomingQueues"/>

<Resource name="jms/outgoingQueues"
 auth="Container"
 type="org.apache.activemq.command.ActiveMQQueue"
 factory="org.apache.activemq.jndi.JNDIReferenceFactory"
 physicalName="OutgoingQueues"/>

</Context>

7. Log4j

File:log4j.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">

<!-- Appenders -->
 <appender name="console" class="org.apache.log4j.ConsoleAppender">
 <param name="Target" value="System.out" />
 <layout class="org.apache.log4j.PatternLayout">
 <param name="ConversionPattern" value="%-5p: [%d{MMM-dd HH:mm:ss,SSS}] %c{3} - %m%n" />
 </layout>
 </appender>

<!-- File Appender -->
 <appender name="file" class="org.apache.log4j.RollingFileAppender">
 <param name="File" value="/home/yudi/log/springMQ.log"/>
 <param name="MaxFileSize" value="10000KB"/>
 <param name="MaxBackupIndex" value="20"/>
 <layout class="org.apache.log4j.PatternLayout">
 <param name="ConversionPattern" value="%-5p: [%d{MMM-dd HH:mm:ss,SSS}] %c{3} - %m%n" />
 </layout>
 </appender>

<logger name="org.springframework.beans">
 <level value="warn" />
 </logger>

<logger name="org.springframework.web">
 <level value="debug" />
 </logger>

<logger name="com.yudi.jms">
 <level value="debug" />
 </logger>
 <!-- Root Logger -->
 <root>
 <priority value="info" />
 <appender-ref ref="file" />
 </root>

</log4j:configuration>

8. Web.XML

File:web.xml

<!DOCTYPE web-app PUBLIC
 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
 "http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>
 <display-name>Archetype Created Web Application</display-name>
 <context-param>
 <param-name>contextConfigLocation</param-name>
 <param-value>
 /WEB-INF/config/spring-config.xml
 </param-value>
 </context-param>

<!-- Loads the Spring web application context using the config file defined
 above. -->
 <listener>
 <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
 </listener>
</web-app>

Bersambung ke posting selanjutnya…