public class MyJmsClient {
 
    private ConnectionFactory factory;
    private Queue queue;
    private Connection connection;
 
    public MyJmsClient(final Properties properties) {
        try {
            final InitialContext context = new InitialContext(properties);
            this.factory = (ConnectionFactory) context.lookup(properties.getProperty("jms.out.factory" ));
            this.queue = (Queue) context.lookup(properties.getProperty("jms.out.queue" ));
            try {
                this.connection = this.factory.createConnection();
            } catch (final JMSException e) {
                MY_LOGGER.fatal("Error while trying to create JMS connection.", e);
                System.exit(-1);
            }
        } catch (final NamingException e) {
            MY_LOGGER.fatal("Naming error for JMS client.", e);
            System.exit(-1);
        }
    }
 
    public void sendMessageToService(final MyObject object) {
        Session session = null;
        try {
            session = this.connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            final MessageProducer sender = session.createProducer(this.queue);
            final MapMessage messageToSend = session.createMapMessage();
            // Je construis mon message
            sender.send(messageToSend);
        } catch (final JMSException e) {
            MY_LOGGER.error("Error while sendind message " + message + " to JMS queue.", e);
        } finally {
            try {
                session.close();
            } catch (final NullPointerException e) {
                MY_LOGGER.error("No session to close on JMS connection.", e);
            } catch (final JMSException e) {
                MY_LOGGER.error("Error while trying to close JMS session.", e);
            }
        }
    }

1. public interface SampleDao {
3.     void envoyer(MyObject object);
4. }

1. public class SampleJMS implements SampleDao {
3.     private JmsOperations jms;
4.     private String queueName;
6.     public void setConnectionFactory(ConnectionFactory connectionFactory) {
7.         this.jms = new JmsTemplate(connectionFactory);
8.     }
10.     public void setQueueName(String queueName) {
11.         this.queueName = queueName;
12.     }
14.     public void envoyer(MyObject object) {
15.         jms.convertAndSend(queueName, object);
16.     }
17. }

1. public static void main(String[] args) {
2.     ApplicationContext ctx = new ClassPathXmlApplicationContext("/applicationContext.xml" );
4.     SampleDao dao = (SampleDao) ctx.getBean("sampleDao" );
5.     dao.envoyer(new MyObject());
6. }