before you run it, create a Queue ""scavazza_SAFImportedDestinationsscavazza_localSAFQueue_0"
(in my case, it was a SAF destination)
package com.pierre.jms;
import java.util.Date;
import javax.jms.*;
import javax.naming.InitialContext;
import javax.naming.NamingException;
/**
* Add these jars:
* javax.jms_1.1.jar
* wls-api.jar
*
* @author vernetto
*
*/
public class JMSSender {
public static void main(String[] args) throws NamingException, JMSException {
send();
}
private static void send() throws NamingException, JMSException {
String url = "t3://localhost:7001";
InitialContext ctx = JNDIHelper.getInitialContext(url);
QueueConnectionFactory qConFactory = (QueueConnectionFactory)ctx.lookup("javax/jms/QueueConnectionFactory");
QueueConnection qConnection = qConFactory.createQueueConnection();
QueueSession qSession = qConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue)ctx.lookup("scavazza_SAFImportedDestinationsscavazza_localSAFQueue_0");
QueueSender qSender = qSession.createSender(queue);
TextMessage msg = qSession.createTextMessage();
msg.setJMSCorrelationID("iamanidagains");
msg.setIntProperty("sonoscemo", 27);
msg.setJMSPriority(7);
qConnection.start();
msg.setText("Hello this is Pierre " + new Date());
qSender.send(msg);
qSender.setDeliveryMode(DeliveryMode.PERSISTENT);
qSender.close();
qSession.close();
qConnection.close();
System.out.println("done");
}
}
