package jms;
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class MainEntry {
public static void main(String[] args){
ConnectionFactory connectionFactory = null;
InitialContext context = null;
try {
Properties env = new Properties( );
env.put(Context.SECURITY_PRINCIPAL, "weblogic");
env.put(Context.SECURITY_CREDENTIALS, "weblogic");
env.put(Context.INITIAL_CONTEXT_FACTORY,
"weblogic.jndi.WLInitialContextFactory");
env.put(Context.PROVIDER_URL,
"t3://localhost:7001");
context = new InitialContext(env);
connectionFactory = (ConnectionFactory) context
.lookup("MyJMSConnectionFactory");
Queue stockQueue;
stockQueue = (Queue) context.lookup("MyDistributedQueue");
Connection connection;
connection = connectionFactory.createConnection();
Session session;
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer sender;
sender = session.createProducer(stockQueue);
MessageConsumer receiver;
receiver = session.createConsumer(stockQueue);
StockListener myListener = new StockListener();
receiver.setMessageListener(myListener);
connection.start();
TextMessage message;
for(int i=0;i<1000;i++){
//Thread.sleep(1000);
System.out.println("Sending Message--------");
String stockData="AAAAA"+(i);
message = session.createTextMessage();
message.setText(stockData);
sender.send(message);
}
} catch (NamingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch(Exception e){
e.printStackTrace();
}
}
}