百货/超市行业

开发平台：

WINDOWS

DeliverMDBClient.java：源码内容

							/*
 * Created on May 28, 2003
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package testClient;
import java.util.Hashtable;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import mdb.DeliverItem;
/**
 * @author vishal
 *
 * To change the template for this generated type comment go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
public class DeliverMDBClient {
	private InitialContext getContext() throws NamingException {
			Hashtable props = new Hashtable();
			props.put(
				InitialContext.INITIAL_CONTEXT_FACTORY,
				"org.jnp.interfaces.NamingContextFactory");
			props.put(InitialContext.PROVIDER_URL, "jnp://127.0.0.1:1099");
			InitialContext initialContext = new InitialContext(props);
			return initialContext;
	}
	public static void main(String[] args) {
	
		DeliverMDBClient mdbean = new DeliverMDBClient ();
		mdbean.testMDBBean() ;
	}
	
	public void testMDBBean() {
		
		DeliverItem di = new DeliverItem ("TUSX","PASSWD","I1",30);
		
		
			try {
			System.out.println("Looking up the factory ");
		
			InitialContext ctx = getContext();
		
			QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
			
			System.out.println("Looking up the queue ");			
			Queue queue = (Queue) ctx.lookup("queue/DelMdbQueue");			
			System.out.println("Creating the connection ");			
			
			QueueConnection connection = factory.createQueueConnection();
			
			System.out.println("Creating the session ");			
			QueueSession session = connection.createQueueSession(true, 1);
			
			System.out.println("Creating the sender ");			
			QueueSender sender = session.createSender(queue);			
			ObjectMessage message = session.createObjectMessage();
			System.out.println ("Setting the object in message ");						
			message.setObject(di);
			
			System.out.println ("Sending the message ");
			
			sender.send(message);
			System.out.println ("Shuting down");
			session.commit();
			session.close();
			connection.close();
			
			System.out.println ("Done ! ");															
		} catch (Exception e) {
			e.printStackTrace();
		}	
	}
}

						