JMS implementation

In this example I am creating an JMS implementation of  Point to Point Messaging Domain.

Step 1: Create a simple maven project using you favorite IDE. I am using IntelliJ

Below I have mentioned dependencies required for the project. Add the dependency in your pom.xml

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/xsd/maven-4.0.0.xsd">  
  <modelVersion>4.0.0</modelVersion>  
  <groupId>com.dipenjms</groupId>  
  <artifactId>JMS</artifactId>  
  <version>1.0-SNAPSHOT</version>  
   <build>  
     <plugins>  
       <plugin>  
         <groupId>org.apache.maven.plugins</groupId>  
         <artifactId>maven-compiler-plugin</artifactId>  
         <configuration>  
           <source>1.7</source>  
           <target>1.7</target>  
         </configuration>  
       </plugin>  
     </plugins>  
   </build>  
   <packaging>jar</packaging>  
  <name>JMS</name>  
  <url>http://maven.apache.org</url>  
  <properties>  
   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
  </properties>  
  <dependencies>  
   <!-- https://mvnrepository.com/artifact/javax.jms/javax.jms-api -->  
   <dependency>  
    <groupId>javax.jms</groupId>  
    <artifactId>javax.jms-api</artifactId>  
    <version>2.0</version>  
   </dependency>  
   <dependency>  
    <groupId>junit</groupId>  
    <artifactId>junit</artifactId>  
    <version>3.8.1</version>  
    <scope>test</scope>  
   </dependency>  
  </dependencies>  
 </project>  

Step 2:
Create a MyReceiver class which is a message consumer.
Note: java:comp/DefaultJMSConnectionFactory in initialContext.lookup() must match name Logical JNDI Name in server and also queue name.

MyReceiver.java

 package javatpoint.dipen.jms;  
 import javax.jms.*;  
 import javax.naming.InitialContext;  
 import javax.naming.NamingException;  
 /**  
  * Created by dipen on 5/5/2017.  
  */  
 public class MyReceiver {  
   public static void main(String[] args) {  
     try {  
       InitialContext initialContext = new InitialContext();  
       QueueConnectionFactory queueConnectionFactory= (QueueConnectionFactory) initialContext.lookup("java:comp/DefaultJMSConnectionFactory");  
       QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();  
       queueConnection.start();  
       QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);  
       Queue queue = (Queue) initialContext.lookup("myQueue");  
       QueueReceiver queueReceiver = queueSession.createReceiver(queue);  
       final TextMessage[] textMessage = new TextMessage[1];  
       queueReceiver.setMessageListener(   new MessageListener(){  
         @Override  
         public void onMessage(Message message) {  
           System.out.print("Inside Message Receiver" + message);  
           textMessage[0] = (TextMessage) message;  
         }  
       });  
       System.out.print(textMessage[0]);  
       queueConnection.close();  
     } catch (NamingException | JMSException e) {  
       e.printStackTrace();  
     }  
   }  
 }  

Step 3:
Create a MySender class which is a message producer.

MySender.java

 package javatpoint.dipen.jms;  
 import javax.jms.*;  
 import javax.naming.Context;  
 import javax.naming.InitialContext;  
 import javax.naming.NamingException;  
 import javax.xml.soap.Text;  
 import java.util.Properties;  
 /**  
  * Created by dipen on 5/5/2017.  
  */  
 public class MySender {  
   public static void main(String[] args) {  
     Properties env = new Properties( );  
     env.put(Context.INITIAL_CONTEXT_FACTORY,  
         "com.sun.jndi.fscontext.RefFSContextFactory");  
     /* env.put(Context.PROVIDER_URL,  
         "ts://localhost:4848");*/  
     try {  
       InitialContext initialContext = new InitialContext();  
       QueueConnectionFactory queueConnectionFactory= (QueueConnectionFactory) initialContext.lookup("java:comp/DefaultJMSConnectionFactory");  
       QueueConnection queueConnection = queueConnectionFactory.createQueueConnection();  
       queueConnection.start();  
       QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);  
       Queue queue = (Queue) initialContext.lookup("myQueue");  
       QueueSender queueSender = queueSession.createSender(queue);  
       TextMessage textMessage = queueSession.createTextMessage();  
       textMessage.setText("Hello Dipen! This is JMS Testing");  
       queueSender.send(textMessage);  
       queueConnection.close();  
     } catch (NamingException | JMSException e) {  
       e.printStackTrace();  
     }  
   }  
 }  

Step 4:
Install  Glassfish4 Server from official site or Click Here and unzip in your desired directory.
Note: Download Java EE 7 Full Platform version.

Open bin directory from recently extracted Server directory and run asadmin.bat
For me it is: F:\IDE\Servers\glassfish4\bin

Then start the server using the command: start-domain

Now on your browser load the server admin page :http://localhost:4848/common/index.jsf

Step 5:
Click on the JMS Resource -> Connection Factories -> New, now write the pool name and select the Resource Type as QueueConnectionFactory then click on ok button.

Click on the JMS Resource -> Destination Resources -> New, now write the JNDI name and physical destination name then click on ok button.

Step 6: Run both MySender and MyReceiver.

Note : If there is error while running the project, add javaee.jar and appserv-rt.jar into your library from <yourpath>\glassfish\lib
For me it's: F:\IDE\Servers\glassfish4\glassfish\lib

Sender output

Receiver output

Download Source for GitHub : Click Here