..

pom.xml

@@ -309,6 +309,13 @@
 			<artifactId>paranamer</artifactId>
 			<version>2.8</version>
 		</dependency>
+		
+		<!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-all -->
+		<dependency>
+			<groupId>org.apache.activemq</groupId>
+			<artifactId>activemq-all</artifactId>
+			<version>5.11.0</version>
+		</dependency>
 	
 	</dependencies>
 	

src/main/java/kr/co/swh/lecture/opensource/activemq/MessageReceiver.java

@@ -0,0 +1,52 @@
+package kr.co.swh.lecture.opensource.activemq; 
+
+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;
+ 
+public class MessageReceiver {
+ 
+    // URL of the JMS server
+//    private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
+    private static String url = "tcp://192.168.0.14:61616";
+    // default broker URL is : tcp://localhost:61616"
+ 
+    // Name of the queue we will receive messages from
+    private static String subject = "JCG_QUEUE";
+ 
+    public static void main(String[] args) throws JMSException {
+        // Getting JMS connection from the server
+        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
+        Connection connection = connectionFactory.createConnection();
+        connection.start();
+ 
+        // Creating session for seding messages
+        Session session = connection.createSession(false,
+                Session.AUTO_ACKNOWLEDGE);
+ 
+        // Getting the queue 'JCG_QUEUE'
+        Destination destination = session.createQueue(subject);
+ 
+        // MessageConsumer is used for receiving (consuming) messages
+        MessageConsumer consumer = session.createConsumer(destination);
+ 
+        // Here we receive the message.
+        Message message = consumer.receive();
+ 
+        // We will be using TestMessage in our example. MessageProducer sent us a TextMessage
+        // so we must cast to it to get access to its .getText() method.
+        if (message instanceof TextMessage) {
+            TextMessage textMessage = (TextMessage) message;
+            System.out.println("Received message '" + textMessage.getText() + "'");
+        }
+        connection.close();
+    }
+}

src/main/java/kr/co/swh/lecture/opensource/activemq/MessageSender.java

@@ -0,0 +1,61 @@
+package kr.co.swh.lecture.opensource.activemq; 
+
+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;
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.activemq 
+ * MessageSender.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 6. 14.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class MessageSender {
+
+	//URL of the JMS server. DEFAULT_BROKER_URL will just mean that JMS server is on localhost
+//	private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
+	private static String url = "tcp://192.168.0.14:61616";
+	
+	// default broker URL is : tcp://localhost:61616"
+	private static String subject = "JCG_QUEUE"; // Queue Name.You can create any/many queue names as per your requirement. 
+
+	public static void main(String[] args) throws JMSException {        
+		// Getting JMS connection from the server and starting it
+		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
+		Connection connection = connectionFactory.createConnection();
+		connection.start();
+
+		//Creating a non transactional session to send/receive JMS message.
+		Session session = connection.createSession(false,
+				Session.AUTO_ACKNOWLEDGE);
+
+		//Destination represents here our queue 'JCG_QUEUE' on the JMS server. 
+		//The queue will be created automatically on the server.
+		Destination destination = session.createQueue(subject); 
+
+		// MessageProducer is used for sending messages to the queue.
+		MessageProducer producer = session.createProducer(destination);
+
+		// We will send a small text message saying 'Hello World!!!' 
+		TextMessage message = session
+				.createTextMessage("Hello !!! Welcome to the world of ActiveMQ.");
+
+		// Here we are sending our message!
+		producer.send(message);
+
+		System.out.println("JCG printing@@ '" + message.getText() + "'");
+		connection.close();
+	}
+}

src/main/java/kr/co/swh/lecture/opensource/rabbitmq/Publisher.java

@@ -7,17 +7,45 @@ import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
 
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.rabbitmq 
+ * Publisher.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 6. 14.
+ * @author : tobby48
+ * @version : v1.0
+ */
 public class Publisher {
 
 	private final static String QUEUE_NAME = "hello";
 
+	/**
+	 * <pre>
+	 * 설명 : 
+	 * 변경이력 : 
+	 * -----------------------------------------------------------------
+	 * 변경일       작성자       변경내용  
+	 * ------------ ------------ ---------------------------------------
+	 * 2020. 6. 14. tobby48          최초 작성 
+	 * -----------------------------------------------------------------
+	 * </pre> 
+	 * @since : 2020. 6. 14.
+	 * @author : tobby48
+	 * @param args
+	 * @throws IOException
+	 * @throws TimeoutException
+	 */ 	
 	public static void main(String[] args) throws IOException, TimeoutException {
 		ConnectionFactory factory = new ConnectionFactory();
 		factory.setHost("dev-swh.ga");
 		Connection connection = factory.newConnection();
 		Channel channel = connection.createChannel();
-
 		channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+		
 		String message = "Hello World!";
 		channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
 		System.out.println(" [x] Sent '" + message + "'");

src/main/java/kr/co/swh/lecture/opensource/rabbitmq/Receiver.java

@@ -9,6 +9,18 @@ import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.Consumer;
 import com.rabbitmq.client.DefaultConsumer;
 import com.rabbitmq.client.Envelope;
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.rabbitmq 
+ * Receiver.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 6. 14.
+ * @author : tobby48
+ * @version : v1.0
+ */
 public class Receiver {
 	private final static String QUEUE_NAME = "hello";
 	public static void main(String[] argv) throws IOException, TimeoutException {
@@ -17,6 +29,7 @@ public class Receiver {
 		Connection connection = factory.newConnection();
 		Channel channel = connection.createChannel();
 		channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+		
 		System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
 		Consumer consumer = new DefaultConsumer(channel) {
 			@Override