A JMS modul bekapcsolása a Wildfly alkalmazás szerverben. A JMS komponens, a standalone-full.xml konfigurációban szerepel, az alap konfiguráció (standalone.xml) nem tartalmazza. Az Jboss Dev. Studio “Launch configurations”-nál be kell állítani a ”–server-config=standalone-full.xml” és újraindítani a wildfly-t. A pirossal jelzett checkboxot is ki kell kapcsolni.

Az alkalmazásszerver újraindítása után, az admin felületen a Subsystems/Messaging/Queues Topics alatt létrehozhatjuk az üzenetsorokat:

Majd az alábbi kép alapján hozzunk létre egy üzenetsort a megadott néven és JNDI névvel:

Az üzenetsor már a java:/jms/queue/TaskQueue JNDI néven elérhető erőforrás. Hozzunk létre egy projekt-et: dinamikus web vagy ejb projekt is lehet, és az alábbi osztályt adjuk meg:

 package org.me;
 
 import java.util.Date;
 
 import javax.ejb.ActivationConfigProperty;
 import javax.ejb.MessageDriven;
 import javax.jms.JMSException;
 import javax.jms.Message;
 import javax.jms.MessageListener;
 import javax.jms.TextMessage;
 
 @MessageDriven(activationConfig = {
 		@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
 		@ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/jms/queue/TaskQueue") })
 public class TaskGenerator implements MessageListener {
 
 	@Override
 	public void onMessage(Message message) {
 		try {
 			if (message instanceof TextMessage) {
 				System.out.println("Az üzenet ekkor megérkezett: " + new Date());
 				TextMessage msg = (TextMessage) message;
 				System.out.println("Az üzenet: " + msg.getText());
 			} else {
 				System.out.println("hibás üzenet");
 			}
 		} catch (JMSException e) {
 			e.printStackTrace();
 		}
 
 	}
 
 }

Ahhoz, hogy távolról is el lehessen érni egy üzenetsort, a JNDI nevének “java:jboss/exported/” kell kezdődnie. A wildfly admin oldalon ez megtehető, hiszen egy üzenetsor több jndi néven is elérhető. Hozzuk létre újra a TaskQueue sort két JNDI névvel: “java:/jms/queue/TaskQueue” és “java:jboss/exported/TaskQueue”

A MDB-ben az annotációt értelem szerűen változtatni kell:

  @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/jms/queue/TaskQueue, java:jboss/exported/TaskQueue") })

A wildfly /bin/add-user.bat futtatásával létrehozhatunk egy felhasználót quser/Password_1 belépéssel a guest csoportban:

  
  What type of user do you wish to add?
   a) Management User (mgmt-users.properties)
   b) Application User (application-users.properties)
  (a): b
  
  Enter the details of the new user to add.
  Using realm 'ApplicationRealm' as discovered from the existing property files.
  Username : quser
  Password recommendations are listed below. To modify these restrictions edit the add-user.properties configuration file.
   - The password should be different from the username
   - The password should not be one of the following restricted values {root, admin, administrator}
   - The password should contain at least 8 characters, 1 alphabetic character(s), 1 digit(s), 1 non-alphanumeric symbol(s)
  Password :
  Re-enter Password :
  What groups do you want this user to belong to? (Please enter a comma separated list, or leave blank for none)[  ]: guest
  About to add user 'quser' for realm 'ApplicationRealm'
  Is this correct yes/no? yes
  Added user 'quser' to file 'C:\projects\devstudio\runtimes\wildfly-10.0.0.Final\standalone\configuration\application-users.properties'
  Added user 'quser' to file 'C:\projects\devstudio\runtimes\wildfly-10.0.0.Final\domain\configuration\application-users.properties'
  Added user 'quser' with groups guest to file 'C:\projects\devstudio\runtimes\wildfly-10.0.0.Final\standalone\configuration\application-roles.properties'
  Added user 'quser' with groups guest to file 'C:\projects\devstudio\runtimes\wildfly-10.0.0.Final\domain\configuration\application-roles.properties'
  Is this new user going to be used for one AS process to connect to another AS process?
  e.g. for a slave host controller connecting to the master or for a Remoting connection for server to server EJB calls.
  yes/no? yes
  To represent the user add the following to the server-identities definition <secret value="UGFzc3dvcmRfMQ==" />
  Press any key to continue . . .

Az MDB klienst most ne a dinamikus web projektben, hanem egy külön java projektben hozzuk létre. A projektre jobb egérgombbal kattintva: Properties/Java Build Path/Add External Jar - segítségével adjuk hozzá a jboss-client.jar-t a [wildfly]\bin\client\ könyvtárból.

A kliens kódja legyen a következő:

  
  import java.util.Hashtable;
  
  import javax.jms.Connection;
  import javax.jms.Queue;
  import javax.jms.QueueConnection;
  import javax.jms.QueueConnectionFactory;
  import javax.jms.QueueSender;
  import javax.jms.QueueSession;
  import javax.jms.Session;
  import javax.jms.TextMessage;
  import javax.naming.Context;
  import javax.naming.InitialContext;
  import javax.naming.NamingException;
  
  public class TestRemoteQueue {
  
  	public static void main(String[] args) throws Exception {
  		Connection connection = null;
  		InitialContext initialContext = null;
  		try {
  			initialContext = getInitialContext();
  			QueueConnectionFactory qconFactory = (QueueConnectionFactory) initialContext
  					.lookup("jms/RemoteConnectionFactory");
  			QueueConnection qcon = qconFactory.createQueueConnection("quser", "Password_1");
  			QueueSession qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  			Queue queue = (Queue) initialContext.lookup("TaskQueue");
  			QueueSender qsender = qsession.createSender(queue);
  			qcon.start();
  			TextMessage msg = qsession.createTextMessage();
  			msg.setText("Hello world");
  			qsender.send(msg);
  			qsender.close();
  			qsession.close();
  			qcon.close();
  		} catch (Exception e) {
  			e.printStackTrace();
  		}
  	}
  	
  	private static InitialContext getInitialContext() throws NamingException {
  		Hashtable env = new Hashtable();
  		env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.naming.remote.client.InitialContextFactory");
  		env.put(Context.PROVIDER_URL, "http-remoting://127.0.0.1:8080");
  		env.put("jboss.naming.client.ejb.context", false);
  		env.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
  		return new InitialContext(env);
  	}
  }

Indítás után a szerver consol-ban megjelenik a “Hello world” szöveg.

A következő MDB megállapítja, hogy újra lett-e küldve az üzenet és ha igen, akkor visszavonja a tranzakciót. A visszavont tranzakció miatt az üzenetsor újra megpróbálja elküldeni az üzenetet, mivel ez már egyszer el lett küldve, ezért fogadjuk. A getJMSRedelivered() true értéket fog adni.

@MessageDriven(name = "RollbackOnly", activationConfig = {
		@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
		@ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/RemoteQueue") })
@TransactionManagement(value = TransactionManagementType.CONTAINER)
@TransactionAttribute(value = TransactionAttributeType.REQUIRED)

public class RollbackOnly implements MessageListener {
@Resource
MessageDrivenContext ctx;

public void onMessage(final Message message) {
	try {
		TextMessage textMessage = (TextMessage) message;

		String text = textMessage.getText();

		if (!textMessage.getJMSRedelivered()) {
			System.out.println("message " + text
					+ " received for the first time");
			ctx.setRollbackOnly();
		} else {
			System.out.println("message " + text
					+ " received for the second time");
		}

	} catch (JMSException e) {
		e.printStackTrace();
	}
}
}

A hozzá tartozó kliens kódja ugyanaz is lehet mint az előző példában.

Állítsuk be az előző példánál, hogy csak 1x próbálja újra az üzenet kézbesítést: [jbdevstudio]\runtimes\jboss-eap\standalone\configuration\standalone-full.xml -ban keressük meg a következő részt:

<address-settings>
  <address-setting match="#">

És illesszük be a következő sort, majd indítsuk újra a JBoss szervert.

<max-delivery-attempts>1</max-delivery-attempts> 

Ilyenkor az üzenet a dead letter queue-ra kerül 1 próbálkozás után.

A Dead Letter Queue-ról a következő osztály leveszi az üzeneteket:

package org.ait;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

@MessageDriven(name = "DeadLetter", activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/DLQ") })
public class DeadLetterQueue implements MessageListener {
    public void onMessage(final Message message) {
        try {
            TextMessage textMessage = (TextMessage) message;
            String text = textMessage.getText();
            System.out.println("DEAD Letter QUEUE got a message:" + text);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}