1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
| public void sendMessage() {
try{
Context contexte =InitContext.getContext().getInitialContext();
//Insertion d'un message dans le bean message
QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)
contexte.lookup("jms/maConnectionFactory");
Queue queue = (Queue)contexte.lookup("jms/demoQueue");
QueueConnection queueConnection =
queueConnectionFactory.createQueueConnection();
QueueSession queueSession =
queueConnection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
QueueSender queueSender = queueSession.createSender(queue);
TextMessage message = queueSession.createTextMessage();
message.setText("Bonjour!");
queueSender.send(message);
}catch(JMSException e) {throw new EJBException(e.toString());
}catch (NamingException e){throw new EJBException("Error looking up home", e);}
} |
Partager