activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bruce Snyder" <bruce.sny...@gmail.com>
Subject Re: Channel was inactive for too long/Durable consumer is in use for client
Date Fri, 03 Oct 2008 19:30:27 GMT
On Fri, Oct 3, 2008 at 1:08 PM, Thomas R. Corbin
<thomas.corbin@gmail.com> wrote:
>
> I'm using 5.1.0 with durable topics and durable messages.  I'm using the derby
> persistence and have removed all the derby persistence stores just prior to
> starting my processes.
>
> I'm assuming I've got something configured poorly, I just don't know what.
>
> When I run one server process with an embedded broker and it tries to connect
> to my central office broker, I get the following from the server process....
>
> ==================
> org.apache.activemq.transport.InactivityIOException: Channel was inactive for
> too long: oms9/127.0.0.2:61616
>        at
> org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:225)
>        at
> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:83)
>        at
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:100)
>        at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
> ====================
>
>
> And from the central office broker I get this:
>
> ======================
> javax.jms.JMSException: Durable consumer is in use for client: NC_sam-
> dataService_inboundmasterJms and subscriptionName:
> com.coned.damage.assign.ReceivedDamageAssignmentConsumer
>        at
> org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:75)
>        at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:383)
>        at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
>        at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:83)
>        at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> ======================

What is the URI you're using in the embedded broker to connect to the
remote broker?

Also, are there any errors or exceptions in the data/activemq.log file?

Bruce
-- 
perl -e 'print unpack("u30","D0G)U8V4\@4VYY9&5R\"F)R=6-E+G-N>61E<D\!G;6%I;\"YC;VT*"
);'

Apache ActiveMQ - http://activemq.org/
Apache Camel - http://activemq.org/camel/
Apache ServiceMix - http://servicemix.org/

Blog: http://bruceblog.org/

Mime
View raw message