By using MDB, the application can get the information of the arrival of inbound message. The MDB implements Lu62MessageListener interface and specifies the messaging-type and activation-config-property attributes in deployment descriptor of MDB.
public class MDBtest2Bean implements javax.ejb.MessageDrivenBean, com.ibm.connector2.sna.lu62.Lu62MessageListener { ... public int onIncomingMessage(String msg, Lu62Conversation conversation) { // add the application implementation of handling the inbound message here // handling the message //send reply message back conversation.send(replyMessage); } ... }
Note MDB is anonymous in nature. Therefore, it cannot be directly invoked by a client like session bean or entity bean. When the inbound message comes in, the LU62 Connector will deliver the message to message endpoint, and the onIncomingMessage method will be called by application server.
Inbound Communication for outbound reply message
The outbound message is sent by CCI verb ASYNC_SEND_RECEIVE, and the replied inbound message is received in MDB.
Following is the deployment descriptor of an example MDB:
Note The outgoing, symbolicDestinationName and tpName values must match the values of these fields defined in J2C connection factory custom properties.
The outbound code:
initialContext = new javax.naming.InitialContext(); connectionFactory = (ConnectionFactory) initialContext.lookup("snalu62"); Lu62ConnectionSpec lu62ConnectionSpec = new Lu62ConnectionSpec(); lu62ConnectionSpec.setUserName("sna"); lu62ConnectionSpec.setPassword("sna"); Connection cxn = connectionFactory.getConnection(lu62ConnectionSpec); Interaction ixn = cxn.createInteraction(); Lu62InteractionSpec ixnSpec = new Lu62InteractionSpec(); Lu62Record outgoingData = new Lu62Record(); Lu62Record returnData = new Lu62Record(); ixnSpec.setInteractionVerb(ixnSpec.ASYNC_SEND_RECEIVE); outgoingData.setData(requestData); ixn.execute(ixnSpec, outgoingData, null); ixn.close(); cxn.close();
The MDB handles the reply message for the outbound. The following is the MDB bean class:
public class MDBtest2Bean implements javax.ejb.MessageDrivenBean, com.ibm.connector2.sna.lu62.Lu62MessageListener { ……. public int onOutgoingReplyMessage (String msg) { …….. // handling the reply message for outgoing message send by CCI } …… }