activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Pesochinskiy, Vadim \(MSCIBARRA\)" <Vadim.Pesochins...@mscibarra.com>
Subject RE: SM + AMQ + Jencks with DeadLetterQueue
Date Mon, 26 Jun 2006 23:51:21 GMT
<HTML xmlns:eXclaimer="http://www.exclaimer.co.uk" xmlns:msxsl="urn:schemas-microsoft-com:xslt"
xmlns:exc="http://www.exclaimer.co.uk/rtf">
<HEAD>
<META http-equiv="Content-Type" content="text/html; charset=UTF-16">

</HEAD>
<BODY >
<DIV><HTML dir=ltr><HEAD><TITLE>SM + AMQ + Jencks with DeadLetterQueue</TITLE>
<META http-equiv=Content-Type content="text/html; charset=unicode">
<META content="MSHTML 6.00.2900.2180" name=GENERATOR><BASE href=HEAD>
<BODY>
<DIV id=idOWAReplyText71722 dir=ltr>
<DIV dir=ltr><FONT face=Arial color=#000000 size=2>Sorry to answer with a question,
but I am wondering were do you get Jenks? Jencks.org web site is perpetually down.</FONT></DIV><FONT
face=Arial size=2></FONT></DIV>
<DIV dir=ltr>&nbsp;</DIV>
<DIV dir=ltr>
<DIV dir=ltr><BR></DIV>
<DIV dir=ltr>
<HR tabIndex=-1>
</DIV>
<DIV dir=ltr><FONT face=Tahoma size=2><B>From:</B> vineetc [mailto:vinichadha@gmail.com]<BR><B>Sent:</B>
Mon 6/26/2006 6:03 PM<BR><B>To:</B> activemq-users@geronimo.apache.org<BR><B>Subject:</B>
SM + AMQ + Jencks with DeadLetterQueue<BR></FONT><BR></DIV></DIV>
<DIV><BR>
<P><FONT size=2>Hello,<BR>I have built SerivceMix JBI JMS components using
ComponentSupport which are<BR>essentially extensions of JmsInBinding and JmsInUsingJcaBinding
for sending<BR>and recv. JMS meesages using AMQ 3.2 and Jecnks 1.1.1.<BR>Sending
and Receiving (using JCA) JMS messages work fine but i am having<BR>troubles with redelivery
and setting up DLQ.<BR>For test purposes i throw out runtime exception from onMessage()
method of<BR>the listener for the message sent. Although the spec JMS says its an error<BR>to
throw RuntimeException its easier to just test the use case of redelivery<BR>and dead
letter Q. >From the log it looks like the message is neither getting<BR>redelivered
nor sent to DLQ.<BR><BR>Following are the exceprts from the AMQ broker, Receiver
and sender<BR>component XML files.<BR><BR>RECEIVER:<BR>&lt;beans&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;!-- primary Q handling the messages --&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="activationSpec"<BR>class="org.activemq.ra.ActiveMQActivationSpec"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="destination"<BR>value="org.wkhmr.cornerstone.business.intell.stats.jms.q"
/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="destinationType" value="javax.jms.Queue" /&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;!-- dead letter Q for handling poisoned messages --&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="dlqActivationSpec"<BR>class="org.activemq.ra.ActiveMQActivationSpec"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="destination"<BR>value="org.wkhmr.cornerstone.business.intell.stats.jms.dlq"
/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="destinationType" value="javax.jms.Queue" /&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;!-- the JCA container --&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="jencks" name="jcaContainer"<BR>class="org.jencks.JCAContainer" singleton="true"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="bootstrapContext"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean<BR>class="org.jencks.factory.BootstrapContextFactoryBean"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="threadPoolSize" value="18"<BR>/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="transactionManager"<BR>ref="transactionManager"/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/property&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;!-- the JCA Resource Adapter --&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="resourceAdapter"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="activeMQResourceAdapter"<BR>class="org.activemq.ra.ActiveMQResourceAdapter"
singleton="true"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="serverUrl"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;value&gt;tcp://localhost:61616&lt;/value&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/property&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="endpointWorkerType"<BR>value="asf"/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/property&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="transactionManager"<BR>class="org.jencks.factory.TransactionManagerFactoryBean"/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="transactionContextManager"<BR>class="org.jencks.factory.TransactionContextManagerFactoryBean"
/&gt;<BR>&lt;/beans&gt;.<BR><BR>SENDER:<BR>&lt;beans&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;!-- message broker --&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="broker" class="org.activemq.spring.BrokerFactoryBean"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="config"<BR>value="<A href="">file:C:/etc/opt/cornerstone/bus-intell/stats/statsActiveMQ.xml</A>"
/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="jmsFactory"<BR>class="org.activemq.pool.PooledConnectionFactory"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="connectionFactory"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean<BR>class="org.activemq.ActiveMQConnectionFactory"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="brokerURL"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;value&gt;tcp://localhost:61616&lt;/value&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/property&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/property&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/bean&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;bean id="template"<BR>class="org.springframework.jms.core.JmsTemplate"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="connectionFactory"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;ref local="jmsFactory" /&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/property&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="defaultDestinationName"<BR>value="org.cornerstone.business.intell.stats.jms.q"
/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="pubSubDomain" value="false" /&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;!--&nbsp; transactional properties --&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="sessionTransacted" value="true" /&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;property name="sessionAcknowledgeMode" value="0"/&gt;<BR>&lt;/beans&gt;<BR><BR>AMQ
Broker Config Xml:<BR>&lt;beans&gt;<BR>&nbsp; &lt;broker name="StatsBroker"&gt;<BR>&nbsp;&nbsp;&nbsp;
&lt;connector&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;tcpServerTransport
uri="tcp://localhost:61616" backlog="999"<BR>useAsyncSend="true" maxOutstandingMessages="45"&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;wireFormat class="org.activemq.io.impl.DefaultWireFormat"/&gt;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;/tcpServerTransport&gt;<BR>&nbsp;&nbsp;&nbsp; &lt;/connector&gt;<BR><BR>&nbsp;&nbsp;&nbsp;
&lt;persistence&gt;&lt;vmPersistence&gt;&lt;/vmPersistence&gt;<BR>&nbsp;&nbsp;&nbsp;
&lt;/persistence&gt;<BR>&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;
&lt;redeliveryPolicy backOffMode="true" maximumRetryCount="1"&gt;<BR>&nbsp;&nbsp;&nbsp;
&lt;/redeliveryPolicy&gt;<BR>&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&lt;deadLetterPolicy<BR>&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
deadLetterEnabled="true"<BR>&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
storeNonPersistentMessages="true"<BR>&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
deadLetterPerDestinationName="false"<BR>&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
deadLetterPrefix="org.wkhmr.cornerstone.business.intell.stats.jms."<BR>&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp; deadLetterName="dlq"<BR>&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp; allowDuplicates="false" &gt;<BR>&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp; &lt;!--&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; deadLetterQueueTTL="120000"
deadLetterTopicTTL="120000" ONLY when we<BR>need to expire messages<BR>&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; useDatabaseLocking="true"
ONLY When JDBC persistence is enabled<BR>&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
--&gt;<BR>&nbsp;&nbsp;&nbsp; &lt;/deadLetterPolicy&gt;<BR>&nbsp;&nbsp;<BR>&nbsp;
&lt;/broker&gt;<BR><BR>Both the sender and receiver files correspond to
separate JBI components for<BR>sending and receiving.<BR>I also had problems with
the using GeronimoTransactionManagerFactoryBean.<BR>The problem reported was that the
object returned by the bean is not of type<BR>ExtendedtransactionManager.<BR><BR>Following
is the stacktrace for the exception:<BR><BR>2006-06-26 00:03:23,625&nbsp;
INFO [Thread-36] ActiveMQSession:572 - Caught<BR>:java.lang.RuntimeException: javax.jms.JMSException:
Message id 3 should be<BR>picked up on DLQ<BR>java.lang.RuntimeException: javax.jms.JMSException:
Message id 3 should be<BR>picked up on DLQ<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at<BR>com.wkhmr.cornerstone.bi.stats.binding.jms.base.StatsJmsInBinding.onMessage(Unknown<BR>Source)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at org.jencks.XAEndpoint.onMessage(XAEndpoint.java:126)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at<BR>org.activemq.ra.MessageEndpointProxy$MessageEndpointAlive.onMessage(MessageEndpointProxy.java:136)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at<BR>org.activemq.ra.MessageEndpointProxy.onMessage(MessageEndpointProxy.java:75)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at org.activemq.ActiveMQSession.deliver(ActiveMQSession.java:568)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at org.activemq.ActiveMQSession.run(ActiveMQSession.java:550)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at org.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:165)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at<BR>org.apache.geronimo.connector.work.WorkerContext.run(WorkerContext.java:291)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(Unknown<BR>Source)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at java.lang.Thread.run(Thread.java:595)<BR>Caused by: javax.jms.JMSException: Message
id 3 should be picked up on DLQ<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
at<BR>com.wkhmr.cornerstone.bi.stats.binding.jms.StatsReceiver.processReceviedMessage(Unknown<BR>Source)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
... 10 more<BR><BR>I have tried hunting thru the Jecks website but culdnt find
anything related<BR>to handling Redelivery or DLQ.<BR>Any insight into where or
what i am doing wrong?<BR>Thanks in advance for your help.<BR>Vineet<BR>--<BR>View
this message in context: <A href="http://www.nabble.com/SM-%2B-AMQ-%2B-Jencks-with-DeadLetterQueue-t1851775.html#a5055822">http://www.nabble.com/SM-%2B-AMQ-%2B-Jencks-with-DeadLetterQueue-t1851775.html#a5055822</A><BR>Sent
from the ActiveMQ - User forum at Nabble.com.<BR><BR></FONT></P></DIV></BODY></HTML>
</DIV>
<DIV>
<HR>
</DIV>
<P CLASS="BulletedList" STYLE="MARGIN: 0in 0in 0pt; TEXT-INDENT: 0in; mso-list: none; tab-stops:
.5in"><SPAN STYLE="FONT-SIZE: 8pt; COLOR: gray; mso-bidi-font-family: Arial"><FONT
FACE="Arial">NOTICE: If received in error, please destroy and notify sender.<SPAN STYLE="mso-spacerun:
yes">&nbsp; </SPAN>Sender does not waive confidentiality or privilege, and use
is prohibited.</FONT></SPAN></P>
<DIV>
</DIV></BODY></HTML>

Mime
View raw message