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>