My setup is below.
When i throw exception the messages are redeliverd to the queue and after
they are read again from the queue/topic. This read/resend/read process
happens once sometimes twice. How can i control the number of resending?
<bean id="transactionManager"
class="org.jencks.factory.TransactionManagerFactoryBean"/>
<bean id="connectionManager"
class="org.jencks.factory.ConnectionManagerFactoryBean">
<property name="transactionManager" ref="transactionManager"/>
</bean>
<bean id="activeMQResourceAdapter"
class="org.apache.activemq.ra.ActiveMQResourceAdapter">
<property name="serverUrl" value="tcp://192.168.2.2:61616" />
</bean>
<bean id="managedConnectionFactory"
class="org.apache.activemq.ra.ActiveMQManagedConnectionFactory">
<property name="resourceAdapter" ref="activeMQResourceAdapter"/>
</bean>
<bean id="jencksConnectionFactory"
class="org.jencks.factory.ConnectionFactoryFactoryBean">
<property name="managedConnectionFactory"
ref="managedConnectionFactory"/>
<property name="connectionManager" ref="connectionManager"/>
</bean>
<bean id="jcaContainer" class="org.jencks.JCAContainer">
<property name="transactionManager" ref="transactionManager"/>
<property name="threadPoolSize" value="20"/>
<property name="resourceAdapter" ref="activeMQResourceAdapter" />
</bean>
<!-- configuration details for queue and topic -->
<bean id="queueActivationSpec"
class="org.apache.activemq.ra.ActiveMQActivationSpec">
<property name="destination" value="tempTRANSIS"/>
<property name="destinationType" value="javax.jms.Queue"/>
</bean>
<bean id="topicActivationSpec"
class="org.apache.activemq.ra.ActiveMQActivationSpec">
<property name="destination" value="tempTRANSIS"/>
<property name="destinationType" value="javax.jms.Topic"/>
<property name="subscriptionDurability" value="Durable" />
<property name="clientId" value="someID" />
<property name="subscriptionName" value="someName" />
</bean>
<!-- listeners -->
<bean id="queueListenerConnector" class="org.jencks.JCAConnector">
<property name="jcaContainer" ref="jcaContainer" />
<property name="activationSpec" ref="queueActivationSpec" />
<property name="ref" value="queueListener"/>
</bean>
<bean id="topicListenerConnector" class="org.jencks.JCAConnector">
<property name="jcaContainer" ref="jcaContainer" />
<property name="activationSpec" ref="topicActivationSpec"/>
<property name="ref" value="topicListener" />
</bean>
--
View this message in context:
http://www.nabble.com/exception-within-onMessage%28%29-tf3939713.html#a11173915
Sent from the jencks - user mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe from this list please visit:
http://xircles.codehaus.org/manage_email
