deliveritemsbean

Enterprise Java Bean的PPT文档,很好的东西.

/*
 * Created on Jun 19, 2003
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package au.com.tusc.mdb;

import javax.ejb.MessageDrivenBean;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.naming.InitialContext;

import au.com.tusc.cmp.ItemLocal;
import au.com.tusc.cmp.ItemLocalHome;
import au.com.tusc.cmp.ItemUtil;
import au.com.tusc.cmp.SupplierData;

import au.com.tusc.session.StoreAccess;
import au.com.tusc.session.StoreAccessHome;
import au.com.tusc.session.StoreAccessUtil;

/**
 * @ejb.bean name="DeliverItems" 
 *     acknowledge-mode="Auto-acknowledge" 
 *     destination-type="javax.jms.Queue" 
 *     subscription-durability="NonDurable" 
 *     transaction-type="Bean" 
 * 
 * @ejb.ejb-ref
 *      ejb-name="StoreAccess"
 *      view-type="remote"
 *      ref-name="StoreAccess"
 * 
 * @ejb.ejb-ref
 *      ejb-name="Item"
 *      view-type="local"
 *      ref-name="ItemLocal"
 *  
 * @jboss.ejb-ref-jndi ref-name="ItemLocal"
 *		jndi-name="ItemLocal"
 
 * @jboss.ejb-ref-jndi ref-name="StoreAccess"
 *		jndi-name="StoreAccessBean"
 * 
 * @jboss.destination-jndi-name
 *      name="queue/DelMdbQueue"
 * 
 **/

public class DeliverItemsBean implements MessageDrivenBean, MessageListener {

	/** Required method for container to set context. */
	public void setMessageDrivenContext(
		javax.ejb.MessageDrivenContext messageContext)
		throws javax.ejb.EJBException {
		this.messageContext = messageContext;
	}
	/** 
	* Required creation method for message-driven beans. 
	* 
	* @ejb.create-method 
	*/
	public void ejbCreate() {
		// no specific action required for message-driven beans 
	}

	/** Required removal method for message-driven beans. */
	public void ejbRemove() {
		messageContext = null;
	}

	/** 
	* This method implements the business logic for the EJB. 
	* 
	* <p>Make sure that the business logic accounts for asynchronous message processing. 
	* For example, it cannot be assumed that the EJB receives messages in the order they were 
	* sent by the client. Instance pooling within the container means that messages are not 
	* received or processed in a sequential order, although individual onMessage() calls to 
	* a given message-driven bean instance are serialized. 
	* 
	* <p>The <code>onMessage()</code> method is required, and must take a single parameter 
	* of type javax.jms.Message. The throws clause (if used) must not include an application 
	* exception. Must not be declared as final or static. 
	*/
	public void onMessage(javax.jms.Message message) {
		System.out.println("Message Driven Bean got message " + message);
		// do business logic here
		
		System.out.println ("Entering DeliverItemsBean.onMessage()");
						
		try {
			
			if (message instanceof ObjectMessage) {
				DeliverItem di =  (DeliverItem) ((ObjectMessage) message).getObject();
				
				StoreAccess access = StoreAccessUtil.getHome().create();				
				itemLocalHome = ItemUtil.getLocalHome();
				
				String suppAccessID = access.loginUser(di.getUsername(),di.getPasswd());				
				System.out.println(" Login is sucessful with "+ suppAccessID);
				SupplierData sd = access.getSupplierData(suppAccessID);
				String suppID = sd.getSupplierID();
				
				if ( suppID != null ) {
					ItemLocal item = this.itemLocalHome.findByPrimaryKey(di.getItemID());			
					String itemSuppID = item.getSupplierID() ;	
				
					if ( suppID.equals(itemSuppID)) {					
							System.out.println ("Delivering items in store now... :");
							Integer quantity = new Integer (di.getQuantity());
							item.fillStock(quantity);
							System.out.println ("Stock of iten after dleivery is :" + item.getItemData());											
					}
				  }				 				
				}						
				}catch (Exception e) {
					System.out.println ("In DeliverItems.onMessage  " +  e.getMessage() );																
				}			
				System.out.println("Entering DeliverItemsBean.onMessage()");						
	}
	
	/** The context for the message-driven bean, set by the EJB container. */
	private javax.ejb.MessageDrivenContext messageContext = null;
	
	private InitialContext context = null;

	private StoreAccessHome storeAccess = null;
	private ItemLocalHome itemLocalHome = null;

}