> import javax.annotation.PostConstruct;
  
> import javax.annotation.PreDestroy;
  
> import javax.annotation.Resource;
  
> import javax.ejb.ActivationConfigProperty;
  
> import javax.ejb.EJBException;
  
> import javax.ejb.MessageDriven;
  
> import javax.ejb.MessageDrivenBean;
  
> import javax.ejb.MessageDrivenContext;
  
> import javax.inject.Inject;
  
> import javax.jms.Connection;
  
> import javax.jms.ConnectionFactory;
  
> import javax.jms.JMSException;
  
> import javax.jms.Message;
  
> import javax.jms.MessageListener;
  
> import javax.jms.ObjectMessage;
  
> import javax.jms.Session;
> 
> import fr.axopen.logging.message.JmsMessage;
> 
> @MessageDriven(activationConfig = {
  
> @ActivationConfigProperty(propertyName = « acknowledgeMode », propertyValue = « Auto-acknowledge »),
  
> @ActivationConfigProperty(propertyName = « destinationType », propertyValue = « javax.jms.Queue »),
  
> @ActivationConfigProperty(propertyName = « destination », propertyValue = « java:jboss/exported/jms/queue/test »),
> 
> })
  
> public class ListingQueue implements MessageDrivenBean, MessageListener {
  
> /**
  
> *
  
> */
  
> private static final long serialVersionUID = 1L;
  
> @Resource(mappedName = « java:/JmsXA »)
  
> private ConnectionFactory factory;
> 
> private Connection connection;
> 
> private Session session;
> 
> @SuppressWarnings(« unused »)
  
> private MessageDrivenContext messageDrivenContext;
> 
> @PreDestroy
  
> protected void preDestroy() throws JMSException {
  
> session.close();
  
> connection.close();
  
> }
> 
> @PostConstruct
  
> protected void postConstruct() throws JMSException {
  
> connection = factory.createConnection();
  
> session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  
> }
> 
> @Override
  
> public void setMessageDrivenContext(MessageDrivenContext ctx)
  
> throws EJBException {
  
> this.messageDrivenContext = ctx;
  
> }
> 
> @Override
  
> public void ejbRemove() throws EJBException {
  
> }
> 
> @Override
  
> public void onMessage(Message message) {
> 
> try {
> 
> } catch (JMSException jmse) {
  
> throw new RuntimeException(jmse);
  
> }
  
> }
> 
> }

Enfin si vous souhaitez vous connecter à la file JMS à distance, voici un exemple:

## Exemple d’envoi d’un message JMS

import java.io.PrintWriter;

> import java.io.StringWriter;
  
> import java.util.Date;
  
> import java.util.HashMap;
  
> import java.util.List;
  
> import java.util.Map;
  
> import java.util.Properties;
> 
> import javax.jms.Connection;
  
> import javax.jms.JMSException;
  
> import javax.jms.MessageProducer;
  
> import javax.jms.ObjectMessage;
  
> import javax.jms.Queue;
  
> import javax.jms.QueueConnectionFactory;
  
> import javax.jms.Session;
  
> import javax.naming.Context;
  
> import javax.naming.InitialContext;
  
> import javax.naming.NamingException;
  
> import javax.servlet.ServletRequest;
  
> import javax.servlet.http.HttpServletRequest;
> 
> import org.apache.commons.lang.exception.ExceptionUtils;
  
> import org.hornetq.api.core.TransportConfiguration;
  
> import org.hornetq.api.jms.HornetQJMSClient;
  
> import org.hornetq.api.jms.JMSFactoryType;
  
> import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory;
  
> import org.hornetq.core.remoting.impl.netty.TransportConstants;
  
> import org.hornetq.jms.client.HornetQConnectionFactory;
> 
> import com.workinlive.framework.Config;
> 
> import fr.axopen.logging.message.JmsMessage;
  
> import fr.axopen.logging.message.TypeMessageEnum;
> 
> public class JmsConnectionFactory {
  
> private static JmsConnectionFactory instance;
> 
> private Context mContext;
  
> Connection mConnection = null;
> 
> QueueConnectionFactory mConnectionFactory;
  
> Queue mQueue = null;
  
> HornetQConnectionFactory mHornetConnectionFactory;
  
> private boolean mIsOperationnel = false;
> 
> private void connect() {
  
> try {
  
> System.out.println(« JMS Connection »);
  
> Properties props = new Properties();
  
> props.put(Context.INITIAL\_CONTEXT\_FACTORY,
  
> « org.jboss.naming.remote.client.InitialContextFactory »);
  
> props.put(Context.PROVIDER\_URL, Config.JMS\_PROVIDER_URL);
  
> props.put(Context.SECURITY\_PRINCIPAL, Config.JMS\_SECURITY_PRINCIPAL);
  
> props.put(Context.SECURITY_CREDENTIALS,
  
> Config.JMS\_SECURITY\_CREDENTIALS);
> 
> mContext = new InitialContext(props);
> 
> final Map<String, Object> p = new HashMap<String, Object>();
  
> TransportConfiguration tc;
> 
> p.put(TransportConstants.HOST\_PROP\_NAME, Config.JMS\_HOST\_LOGGING);
  
> p.put(TransportConstants.PORT\_PROP\_NAME, Config.JMS\_HOST\_PORT);
> 
> tc = new TransportConfiguration(
  
> NettyConnectorFactory.class.getName(), p);
> 
> mHornetConnectionFactory = HornetQJMSClient
  
> .createConnectionFactoryWithoutHA(JMSFactoryType.QUEUE_CF,
  
> tc);
> 
> mQueue = (Queue) mContext.lookup(Config.JMS\_JNDI\_QUEUE);
> 
> mConnection = mHornetConnectionFactory.createConnection();
> 
> mIsOperationnel = true;
  
> } catch (NamingException e) {
  
> e.printStackTrace();
  
> System.err.println(« Problème de connexion JMS »);
  
> } catch (JMSException e) {
  
> e.printStackTrace();
  
> System.err.println(« Erreur de connexion JMS »);
  
> }
> 
> }
> 
> private JmsConnectionFactory() {
  
> connect();
> 
> }
> 
> public static JmsConnectionFactory getInstance() {
  
> if (instance == null) // 1
  
> instance = new JmsConnectionFactory(); // 2
  
> return instance; // 3
  
> }
> 
> public Connection getConnection() {
  
> if (mConnection == null || !mIsOperationnel) {
  
> closeSession();
  
> mIsOperationnel = true;
  
> connect();
  
> }
> 
> return mConnection;
  
> }
> 
> public Queue getQueue() {
  
> return mQueue;
  
> }
> 
> public void closeSession() {
  
> try {
  
> if (mContext != null) {
  
> mContext.close();
  
> }
  
> } catch (NamingException e) {
  
> e.printStackTrace();
  
> }
  
> try {
  
> if (mHornetConnectionFactory != null)
  
> mHornetConnectionFactory.close();
  
> } catch (Exception e) {
  
> e.printStackTrace();
  
> }
  
> try {
  
> if (mConnection != null)
  
> mConnection.close();
  
> } catch (JMSException e) {
  
> e.printStackTrace();
  
> }
> 
> }
> 
> public boolean isOperationnel() {
  
> return mIsOperationnel;
  
> }
> 
> public void setOperationnel(boolean pIsOperationnel) {
  
> mIsOperationnel = pIsOperationnel;
  
> }