Below is a sample MDB that i use
import javax.ejb.EJBException;
| import javax.ejb.MessageDrivenBean;
| import javax.ejb.MessageDrivenContext;
| import javax.jms.Message;
| import javax.jms.MessageListener;
| import javax.jms.TextMessage;
|
|
|
|
| public class MyMDB implements MessageDrivenBean, MessageListener
| {
| private static final String COB_ID = "COB_ID";
| private static final String CONTAINER = "CONTAINER";
| private static final String ITEM_ID = "ITEM_ID";
| private static final String INFO_ID = "INFO_ID";
| private static final String LAST_UPDATED = "LAST_UPDATED";
| private static final String MEM_ID = "MEM_ID";
|
| private MessageDrivenContext mdbContext = null;
|
| public void onMessage(Message message)
| {
| try
| {
| TextMessage textMessage = (TextMessage) message;
| System.out.println("My MDB get called");
| String cobrandId = message.getStringProperty(COB_ID);
| String container = message.getStringProperty(CONTAINER);
| String cacheItemId = message.getStringProperty(ITEM_ID);
| String sumInfoId = message.getStringProperty(INFO_ID);
| String lastUpdated =
message.getStringProperty(LAST_UPDATED);
| String memId = message.getStringProperty(MEM_ID);
|
| System.out.println("message contains :" );
| System.out.println("cobId : " + cobId);
| System.out.println("container : " + container);
| System.out.println("ItemId : " + ItemId);
| System.out.println("InfoId : " + InfoId);
| System.out.println("lastUpdated : " + lastUpdated);
| System.out.println("mem id: " + memId);
| //Calling functions to process the message
| }
| catch(Exception e)
| {
| e.printStackTrace();
| }
| }
|
| public void setMessageDrivenContext(MessageDrivenContext context)
| throws EJBException {
| this.mdbContext = context;
| }
|
| public void ejbCreate() {
| }
|
| public void ejbRemove() {
| }
| }
|
jms-ds.xml
<?xml version="1.0" encoding="UTF-8"?>
|
| <connection-factories>
|
| <!-- ====================================================================
-->
| <!-- WSMQ connection factories
-->
| <!-- ====================================================================
-->
|
| <!-- non XA provider loader and connection factory -->
| <mbean code="org.jboss.jms.jndi.JMSProviderLoader"
| name="jboss.mq:service=JMSProviderLoader,name=JMSProvider">
| <attribute name="ProviderName">DefaultJMSProvider</attribute>
| <attribute name="ProviderAdapterClass">
| org.jboss.jms.jndi.JNDIProviderAdapter
| </attribute>
| <attribute name="QueueFactoryRef">MDBDLQCF</attribute>
| <attribute name="TopicFactoryRef">MDBTestQueueCF</attribute>
| <attribute
name="Properties">java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory</attribute>
| <attribute
name="Properties">java.naming.provider.url=localhost:1099</attribute>
| <attribute
name="Properties">java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces</attribute>
| </mbean>
|
| </connection-factories>
|
|
Entries of the above mentioned CFs in connection-factories-service.xml
<mbean code="org.jboss.jms.server.connectionfactory.ConnectionFactory"
| name="jboss.messaging.connectionfactory:service=MDBDLQCF"
| xmbean-dd="xmdesc/ConnectionFactory-xmbean.xml">
| <depends
optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
| <depends
optional-attribute-name="Connector">jboss.messaging:service=Connector,transport=socket</depends>
| <depends>jboss.messaging:service=PostOffice</depends>
|
| <attribute name="JNDIBindings">
| <bindings>
| <binding>/MDBDLQCF</binding>
| </bindings>
| </attribute>
|
| <attribute name="Clustered">true</attribute>
| <attribute
name="LoadBalancingFactory">org.jboss.jms.client.plugin.RoundRobinLoadBalancingFactory</attribute>
| </mbean>
|
| <mbean code="org.jboss.jms.server.connectionfactory.ConnectionFactory"
| name="jboss.messaging.connectionfactory:service=MDBTestQueueCF"
| xmbean-dd="xmdesc/ConnectionFactory-xmbean.xml">
| <depends
optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
| <depends
optional-attribute-name="Connector">jboss.messaging:service=Connector,transport=socket</depends>
| <depends>jboss.messaging:service=PostOffice</depends>
|
| <attribute name="JNDIBindings">
| <bindings>
| <binding>/MDBTestQueueCF</binding>
| </bindings>
| </attribute>
|
| <attribute name="Clustered">true</attribute>
| <attribute
name="LoadBalancingFactory">org.jboss.jms.client.plugin.RoundRobinLoadBalancingFactory</attribute>
| </mbean>
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4022347#4022347
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4022347
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
