JBOSS5.1 Configuration and Run(一)SimpleMDB

JBOSS5.1 Configuration and Run(一)SimpleMDB

1. the consumer bean HelloMDB.java:
package com.sillycat.mdb;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;

@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/HelloQueue") })
public class HelloMDB implements MessageListener {

public void onMessage(Message arg0) {
System.out.println("----------------");
System.out.println("Received message");
System.out.println("----------------");
}

}

2. the message sender bean HelloMessageClient.java:
package com.sillycat.mdb;

import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.InitialContext;

public class HelloMessageClient {

public static void main(String[] args) throws Exception {
QueueConnection cnn = null;
QueueSender sender = null;
QueueSession session = null;
InitialContext ctx = new InitialContext();
Queue queue = (Queue) ctx.lookup("queue/HelloQueue");
QueueConnectionFactory factory = (QueueConnectionFactory) ctx
.lookup("ConnectionFactory");
cnn = factory.createQueueConnection();
session = cnn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
TextMessage msg = session.createTextMessage("Hello World");
sender = session.createSender(queue);
sender.send(msg);
System.out.println("Message sent successfully to remote queue.");
}
}

3. the configure file for ear application.xml:
<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE application PUBLIC '-//Sun Microsystems, Inc.//DTD J2EE Application 1.3//EN' 'http://java.sun.com/dtd/application_1_3.dtd'>

<application>
<display-name>HelloMDB</display-name>
<description>Application description</description>
<module>
<ejb>easyejb-mdb.jar</ejb>
</module>
</application>

4. the build.xml file to compile, jar, ear, and deploy mdb to jboss
<target name="mdb.jar" depends="compile">
<jar jarfile="${dist.dir}\${app.name}-mdb.jar">
<fileset dir="${build.dir}/WEB-INF/classes">
<include name="com/sillycat/mdb/**/*.class" />
</fileset>
</jar>
</target>

<target name="mdb.ear" depends="mdb.jar">
<ear destfile="${dist.dir}\${app.name}-mdb.ear" appxml="${conf.dir}/application.xml">
<fileset dir="${dist.dir}" includes="${app.name}-mdb.jar," />
</ear>
</target>

<target name="mdb.deploy" depends="mdb.ear">
<copy file="${dist.dir}\${app.name}-mdb.ear" todir="${jboss.dir}\server\${jboss.server}\deploy" />
</target>

5. modify the configure file under jboss
E:\jboss-5.1.0.GA\server\default\deploy\messaging\destinations-service.xml:
<?xml version="1.0" encoding="UTF-8"?>

<!--
     Messaging Destinations deployment descriptor.

     $Id: destinations-service.xml 85945 2009-03-16 19:45:12Z [e-mail] $
-->

<server>

   <!--
      The Default Dead Letter Queue. This destination is a dependency of an EJB MDB container.
   -->

   <mbean code="org.jboss.jms.server.destination.QueueService"
      name="jboss.messaging.destination:service=Queue,name=DLQ"
      xmbean-dd="xmdesc/Queue-xmbean.xml">
      <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
      <depends>jboss.messaging:service=PostOffice</depends>
   </mbean>
  
   <!--
      The Default Expiry Queue.
   -->

   <mbean code="org.jboss.jms.server.destination.QueueService"
      name="jboss.messaging.destination:service=Queue,name=ExpiryQueue"
      xmbean-dd="xmdesc/Queue-xmbean.xml">
      <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
      <depends>jboss.messaging:service=PostOffice</depends>
   </mbean>  
  
   <mbean code="org.jboss.mq.server.jmx.Queue"
      name="jboss.mq.destination:service=Queue,name=HelloQueue">
      <attribute name="JNDIName">queue/HelloQueue</attribute>
      <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
   </mbean>
     
</server>