exception within onMessage()

View: New views
1 Messages — Rating Filter:   Alert me  

exception within onMessage()

by keneida :: Rate this Message:

Reply to Author | View Threaded | Show Only this Message

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>