Intermittent error "org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long."

[Nige]

We started using activeMQ to send messages from our EDI gateway to our
application systems. Everything had gone well during testing, which included
volume testing. However, we have experienced a time outs on 2 separate
occasions which resulting in no messages being exchanged between the 2
systems which has caused us to roll back to our FTP based solution.
We use a java application to queue and dequeue messages on server B and use
Sterling Commerce's Gentran Integration Suite on Server B.

I have seen some information posted in this forum about setting timeout
values but we have been unable to get these set up in the activemq.xml file.

Being an activeMQ novice, and not being a Java programmer, I would
appreciate some advice on this issue and, if possible, what specifically I
should set in the xml configuration file.

The details of our configuration is listed below (including the full error
message).

Thanks in advance for any help.

Server A Environment
====================
O/S = Solaris 9 9/04
activeMQ Version = 4.1.1
Java Version = 1.4.2_12

Server B Environment
====================
O/S = Tru64 4.0F
activeMQ Version = 4.1.1
Java Version = 1.4.2-6 (highest available for Tru64)

Error on Server B
=================
INFO  DemandForwardingBridge         - Network connection between
vm://Server B#4 and tcp:///Server A:61616 shutdown due to a local error:
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long.

Netstat details
===============
tcp        0      0  Server B.61616    Server A.44031     ESTABLISHED
tcp     6907      0  Server B.1337     Server A.61616     CLOSE_WAIT

activemq.xml from Server A
==========================
<beans>

  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  
  <broker brokerName="Server A" useJmx="true"
xmlns="http://activemq.org/config/1.0";>
  
    <!-- In ActiveMQ 4, you can setup destination policies -->  
    <destinationPolicy>
      <policyMap><policyEntries>
        
          <policyEntry topic="FOO.>">
            <dispatchPolicy>
              <strictOrderDispatchPolicy />
            </dispatchPolicy>
            <subscriptionRecoveryPolicy>
              <lastImageSubscriptionRecoveryPolicy />
            </subscriptionRecoveryPolicy>
          </policyEntry>

      </policyEntries></policyMap>
    </destinationPolicy>
  
    <persistenceAdapter>
      <journaledJDBC journalLogFiles="5" dataDirectory="./activemq-data"
dataSource="#oracle-ds"/>
    </persistenceAdapter>
  
    <transportConnectors>
       <transportConnector name="openwire" uri="tcp://localhost:61616"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
    </transportConnectors>
    
    <networkConnectors>
      <networkConnector name="Server B"
uri="static://(tcp://XX.XXX.XX.XX:61616)"/>
    </networkConnectors>
    
  </broker>
  
  <!-- Oracle DataSource Sample Setup -->
  <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
    <property name="driverClassName"
value="oracle.jdbc.driver.OracleDriver"/>
    <property name="url" value="jdbc:oracle:thin:@XX.XXX.XX.XX:1521:XXXXX"/>
    <property name="username" value="XXXXX"/>
    <property name="password" value="XXXXX"/>
    <property name="poolPreparedStatements" value="false"/>
  </bean>
        
</beans>

activemq.xml from Server B
==========================
<beans>

  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  
  <broker brokerName="Server B" useJmx="true"
xmlns="http://activemq.org/config/1.0";>
  
    <destinationPolicy>
      <policyMap><policyEntries>
          <policyEntry topic="FOO.>">
            <dispatchPolicy>
              <strictOrderDispatchPolicy />
            </dispatchPolicy>
            <subscriptionRecoveryPolicy>
              <lastImageSubscriptionRecoveryPolicy />
            </subscriptionRecoveryPolicy>
          </policyEntry>
      </policyEntries></policyMap>
    </destinationPolicy>
  
    <persistenceAdapter>
      <journaledJDBC journalLogFiles="5" dataDirectory="./data"
dataSource="#derby-ds"/>
    </persistenceAdapter>
  
    <transportConnectors>
       <transportConnector name="openwire" uri="tcp://localhost:61616"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
    </transportConnectors>
    
    <networkConnectors>
      <networkConnector name="Server A"
uri="static://(tcp://XX.XXX.XX.XX:61616)"/>
    </networkConnectors>
    
  </broker>
  
  <!-- Embedded Derby DataSource Setup -->
  <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
    <property name="databaseName" value="derbydb"/>
    <property name="createDatabase" value="create"/>
  </bean>

</beans>
-- 
View this message in context: 
http://www.nabble.com/Intermittent-error-%22org.apache.activemq.transport.InactivityIOException%3A-Channel-was-inactive-for-too-long.%22-tf4651314s2354.html#a13288940
Sent from the ActiveMQ - User mailing list archive at Nabble.com.