Problem in using SonicMQ as JMS provider on JBoss
Hi
I'm trying to use SonicMQ as the JMS provider in JBoss 4.0.3. I have an MDB that listens to a queue existing on SonicMQ. The MDB is able to receive the message correctly. However, when I shutdown the JBoss then the messages that the MDB had consumed reappear on the SonicMQ. Below are the relevant portions from the configuration files.
I'm not able to figure out what am I missing in setting up the JMS provider.
Any help would be greatly appreciated.
Regards.
MDB class:
package test;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.ejb.EJBException;
import javax.jms.MessageListener;
import javax.jms.Message;
import javax.jms.TextMessage;
import javax.jms.JMSException;
public class JBossMDB implements MessageDrivenBean, MessageListener {
private MessageDrivenContext ctx;
public void setMessageDrivenContext(MessageDrivenContext messageDrivenContext) throws EJBException {
ctx = messageDrivenContext;
}
public void ejbCreate() throws EJBException {
System.out.println("Created MDB. ");
}
public void ejbRemove() throws EJBException {
System.out.println("Removed MDB. ");
}
public void onMessage(Message message) {
if (message instanceof TextMessage) {
try {
String msg = ((TextMessage)message).getText();
System.out.println("Message: "+msg);
} catch (JMSException e) {
e.printStackTrace();
}
} else {
System.out.println("Non-text message received! ");
}
}
}
META-INF/jboss.xml:
<jboss> <enterprise-beans> <message-driven> <ejb-name>JBossMDB</ejb-name> <destination-jndi-name>queue/test-in-queue</destination-jndi-name> <invoker-bindings> <invoker> <invoker-proxy-binding-name>message-driven-bean</invoker-proxy-binding-name> </invoker> </invoker-bindings> </message-driven> </enterprise-beans> </jboss>
META-INF/ejb-jar.xml:
<ejb-jar> <enterprise-beans> <message-driven> <ejb-name>JBossMDB</ejb-name> <ejb-class>test.JBossMDB</ejb-class> <transaction-type>Container</transaction-type> <message-driven-destination> <destination-type>javax.jms.Queue</destination-type> </message-driven-destination> </message-driven> </enterprise-beans> <assembly-descriptor> <container-transaction> <method> <ejb-name>JBossMDB</ejb-name> <method-name>*</method-name> </method> <trans-attribute>NotSupported</trans-attribute> </container-transaction> </assembly-descriptor> </ejb-jar>
/server/myInstance/conf/sonicloader-conf.xml:
<sonicloader xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="file://d:\atProjects\JBossProvider\sonicloader.xsd"> <jndiEnvironment> <property name="java.naming.provider.url">jnp://localhost:1099</property> <property name="java.naming.factory.initial">org.jnp.interfaces.NamingContextFactory</property> <property name="java.naming.factory.url.pkgs">org.jboss.naming:org.jnp.interfaces</property> <property name="java.naming.referral">throw</property> </jndiEnvironment> <entities> <entity jndiName="sonicqcf" class="progress.message.jclient.xa.XAQueueConnectionFactory"> <property name="brokerURL">tcp://localhost:2506</property> <property name="connectionURLs">tcp://localhost:2506</property> <property name="defaultUser">admin</property> <property name="defaultPassword">admin</property> <property name="prefetchCount">3</property> <property name="prefetchThreshold">1</property> <property name="sequential">true</property> </entity> <!-- Destinations --> <!-- Make sure you create the queues on the message broker --> <entity jndiName="queue/SonicDLQ" class="progress.message.jclient.Queue"> <property name="queueName">SonicMQ.deadMessage</property> </entity> <entity jndiName="queue/test-in-queue" class="progress.message.jclient.Queue"> <property name="queueName">test.in.queue</property> </entity> </entities> </sonicloader>
sonicmq-service.xml:
<server> <mbean code="com.sonicsw.pso.jndiloader.jboss.JBossLoader" name="sonic.mq:service=JNDILoader"> <attribute name="LoaderConfigURL">file:///C:/etc/jboss-4.0.3/server/myInstance/conf/sonicloader-conf.xml</attribute> <depends>jboss:service=Naming</depends> </mbean> <!-- The JMS provider loader --> <mbean code="org.jboss.jms.jndi.JMSProviderLoader" name="jboss.mq:service=JMSProviderLoader,name=SonicJBossMQProvider"> <attribute name="ProviderName">SonicJMSProvider</attribute> <attribute name="ProviderAdapterClass"> org.jboss.jms.jndi.JNDIProviderAdapter </attribute> <attribute name="QueueFactoryRef">sonicqcf</attribute> <attribute name="TopicFactoryRef">sonicqcf</attribute> </mbean> <!-- The Sonic server session pool for Message Driven Beans --> <mbean code="org.jboss.jms.asf.ServerSessionPoolLoader" name="jboss.mq:service=ServerSessionPoolMBean,name=SonicStdJMSPool"> <depends optional-attribute-name="XidFactory">jboss:service=XidFactory</depends> <attribute name="PoolName">SonicStdJMSPool</attribute> <attribute name="PoolFactoryClass"> com.sonicsw.pso.jboss.v1.SonicMQServerSessionPoolFactory </attribute> </mbean> </server>
conf/standardjboss.xml:
<invoker-proxy-binding> <name>message-driven-bean</name> <invoker-mbean>default</invoker-mbean> <proxy-factory>org.jboss.ejb.plugins.jms.JMSContainerInvoker</proxy-factory> <proxy-factory-config> <JMSProviderAdapterJNDI>SonicJMSProvider</JMSProviderAdapterJNDI> <ServerSessionPoolFactoryJNDI>StdJMSPool</ServerSessionPoolFactoryJNDI> <CreateJBossMQDestination>true</CreateJBossMQDestination> <!-- WARN: Don't set this to zero until a bug in the pooled executor is fixed --> <MinimumSize>1</MinimumSize> <MaximumSize>15</MaximumSize> <KeepAliveMillis>30000</KeepAliveMillis> <MaxMessages>1</MaxMessages> <MDBConfig> <ReconnectIntervalSec>10</ReconnectIntervalSec> <DLQConfig> <DestinationQueue>queue/SonicDLQ</DestinationQueue> <MaxTimesRedelivered>10</MaxTimesRedelivered> <TimeToLive>0</TimeToLive> </DLQConfig> </MDBConfig> </proxy-factory-config> </invoker-proxy-binding>
