Create Active MQ project in git

Author: coderdeepak

activemq/pom.xml

@@ -0,0 +1,41 @@
+<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/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<groupId>com.jms.activemq</groupId>
+	<artifactId>activemq_tutorial</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<dependencies>
+		<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>3.1.0.RELEASE</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>log4j</groupId>
+			<artifactId>log4j</artifactId>
+			<version>1.2.16</version>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-log4j12</artifactId>
+			<version>1.6.4</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-pool</groupId>
+			<artifactId>commons-pool</artifactId>
+			<version>1.5.7</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.geronimo.specs</groupId>
+			<artifactId>geronimo-jta_1.1_spec</artifactId>
+			<version>1.1.1</version>
+		</dependency>
+	</dependencies>
+</project>

activemq/src/main/java/com/test/first/queue/Receiver.java

@@ -0,0 +1,65 @@
+package com.test.first.queue;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+
+/**
+ * 
+ * @author Deepak.Keswani
+ * Simple Receiver
+ */
+
+public class Receiver {
+
+	private ConnectionFactory factory = null;
+	private Connection connection = null;
+	private Session session = null;
+	private Destination destination = null;
+    private MessageConsumer consumer = null;
+
+	public void receiveMessage() {
+		try {
+			factory = new ActiveMQConnectionFactory(
+					ActiveMQConnection.DEFAULT_BROKER_URL);
+			connection = factory.createConnection();
+			connection.start();
+			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+			destination = session.createQueue("SAMPLEQUEUE");
+			consumer = session.createConsumer(destination);
+			System.out.println("b4 receive");
+			Message message = consumer.receive();
+			System.out.println("after receive");
+			if(message instanceof TextMessage){
+				TextMessage textMessage = (TextMessage)message;
+				System.out.println("Received message is -----------> " + textMessage.getText());
+			}
+		} catch (JMSException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}finally{
+			try{
+				session.close();
+				connection.close();
+			}catch (JMSException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		}
+
+	}
+	
+	public static void main(String[] args) {
+		Receiver reciever = new Receiver();
+		reciever.receiveMessage();
+	}
+
+}

activemq/src/main/java/com/test/first/queue/Sender.java

@@ -0,0 +1,63 @@
+package com.test.first.queue;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+
+/**
+ * 
+ * @author Deepak.Keswani
+ *
+ */
+public class Sender {
+
+	private ConnectionFactory factory = null;
+	private Connection connection = null;
+
+	private Session session = null;
+
+	private Destination destination = null;
+
+	private MessageProducer producer = null;
+
+	public void sendMessage() {
+		try {
+			factory = new ActiveMQConnectionFactory(
+					ActiveMQConnection.DEFAULT_BROKER_URL);
+			connection = factory.createConnection();
+			connection.start();
+			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+			destination = session.createQueue("SAMPLEQUEUE");
+			producer = session.createProducer(destination);
+			TextMessage message = session.createTextMessage();
+			message.setText("Hello ...This is a sample message..sending from FirstClient");
+			producer.send(message);
+			System.out.println("Sent: " + message.getText());
+		} catch (JMSException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}finally{
+			try{
+				session.close();
+				connection.close();
+			}catch (JMSException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		}
+	}
+
+	public static void main(String args[]) {
+		Sender sender = new Sender();
+		sender.sendMessage();
+	}
+
+}