activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: TempQueue advisory flood
Date Mon, 14 May 2012 22:19:04 GMT
this is expected, but the flooding impact should be minimal with a
small number of brokers in the network and a reasonable number of
connections.

each network bridge will register interest in all temp destination
advisories, so that it will be in a position to receive messages for
those destinations. It can't know in advance which messages may be
routed though it, so it needs to react to each advisory message and
create a local temp destination. When the connection that creates the
temp is closes, the temp destination gets closed and each broker
reacts to that event via the remove temp advisory.

Temp destinations are often pooled for serial request reply messages
or multiplexed using selectors, to reduce the overhead of creation and
propagation, in a network scenario. The other option is to use regular
destinations for replys

For temp destinations, there is an alternative solution that would
require a little more configuration but which would reduce the
overhead of unnecessary temp destination propagation.
You can disable auto temp destination propagation through the network
bridge, ie: bridgeTempDestinations=false.
Then you need to allow temp destination creation on the fly for a
producer, broker.allowTempAutoCreationOnSend=true
To finish, you need to configure
broker.schedulePeriodForDestinationPurge>0 to have the on the fly
created temp destinations purged when they are empty and enable it for
temp destinations. policy entry gcInactiveDestinations=true (this is
important because the auto created temp destination cannot be
associated with a connection in any sensible way)

There is a test that exercises these options
http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java


On 11 May 2012 17:45, Chris Robison <chrisdrobison@gmail.com> wrote:
> Another interesting observation: as a test, I connected all producers and
> consumers to MSTMIP102 (the machine that doesn't have the network
> connector). I then started MSIPAP101 so that its network connector could
> start and connect to MSTMIP102. Request request-reply works fine between
> all producers and consumers, but after 1 or 2 request-replies, MSIPAP101 is
> flooded with the temp queue advisories--even though there are no producers
> or consumers connected to it.
>
> On Fri, May 11, 2012 at 10:09 AM, Chris Robison <chrisdrobison@gmail.com>wrote:
>
>> Here is the log from the latest run with the TTL down to 1. It still
>> floods after about 1 or 2 request-reply calls. It just seems to be
>> alternating between add temp queue and remove temp queue messages.
>>
>> On Fri, May 11, 2012 at 9:52 AM, Chris Robison <chrisdrobison@gmail.com>wrote:
>>
>>> Yes, because we have a spoke and hub topology where a client in one spoke
>>> may need to request info from a client connected to a different spoke. I
>>> suppose I could lower that value.
>>>
>>>
>>> On Fri, May 11, 2012 at 9:47 AM, Gary Tully <gary.tully@gmail.com> wrote:
>>>
>>>> Do you have a good reason to have networkTTL="5", if there is only one
>>>> broker, the default value of 1 will be fine.
>>>>
>>>> On 11 May 2012 16:32, Chris Robison <chrisdrobison@gmail.com> wrote:
>>>> > If it helps, I've attached the configuration files for both machines.
>>>> >
>>>> >
>>>> > On Fri, May 11, 2012 at 9:07 AM, Chris Robison <
>>>> chrisdrobison@gmail.com>
>>>> > wrote:
>>>> >>
>>>> >> One thing I have noticed though is that when I restart the broker
on
>>>> the
>>>> >> other end, everything starts to work again until it floods again.
>>>> >>
>>>> >>
>>>> >> On Fri, May 11, 2012 at 9:05 AM, Chris Robison <
>>>> chrisdrobison@gmail.com>
>>>> >> wrote:
>>>> >>>
>>>> >>> I'm on 5.6. And all brokers remain up and running.
>>>> >>>
>>>> >>>
>>>> >>> On Fri, May 11, 2012 at 8:48 AM, Gary Tully <gary.tully@gmail.com>
>>>> wrote:
>>>> >>>>
>>>> >>>> what version are you on?
>>>> >>>> Is there any chance that the broker at the other end of
the network
>>>> >>>> bridge is shutting down?
>>>> >>>>
>>>> >>>> On 11 May 2012 14:34, Chris Robison <chrisdrobison@gmail.com>
>>>> wrote:
>>>> >>>> > I have a network of brokers and I am using a request-reply
system
>>>> >>>> > across
>>>> >>>> > that network, but I've noticed that after a few request-replys,
>>>> the
>>>> >>>> > broker
>>>> >>>> > network will get flooded with TempQueue advisory messages,
then
>>>> some
>>>> >>>> > of the
>>>> >>>> > of the brokers will be reported as slow consumers and
the
>>>> consumers
>>>> >>>> > won't
>>>> >>>> > receive messages after that. The advisory messages
seem to be
>>>> repeated
>>>> >>>> > (e.g. add temp destination, remove temp destination)
for the same
>>>> temp
>>>> >>>> > destinations. Not quite sure how to handle this. Any
suggestions?
>>>> >>>> >
>>>> >>>> > Here are some of the errors are other things I'm seeing
>>>> repeatedly in
>>>> >>>> > logs
>>>> >>>> > when I enable debug. In fact, when this flood occurs,
tons of log
>>>> gets
>>>> >>>> > generated all at once.
>>>> >>>> >
>>>> >>>> > 2012-05-11 05:24:37,248 | DEBUG | Error occured while
processing
>>>> async
>>>> >>>> > command: DestinationInfo {commandId = 40578, responseRequired
=
>>>> false,
>>>> >>>> > connectionId = ID:MSTMIP102-59588-1336713700699-3:2,
destination =
>>>> >>>> > temp-queue://ID:POTMIP102-54337-634722930065323786-1:18:1,
>>>> >>>> > operationType =
>>>> >>>> > 0, timeout = 0, brokerPath =
>>>> [ID:MSSD5D101-38580-1336708634042-0:1]},
>>>> >>>> > exception: java.lang.IllegalStateException: Timer already
>>>> cancelled. |
>>>> >>>> > org.apache.activemq.broker.TransportConnection.Service
| ActiveMQ
>>>> >>>> > Transport: ssl:///10.60.252.28:54493
>>>> >>>> > java.lang.IllegalStateException: Timer already cancelled.
>>>> >>>> > at java.util.Timer.sched(Timer.java:397)
>>>> >>>> > at java.util.Timer.schedule(Timer.java:248)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.thread.Scheduler.schedualPeriodically(Scheduler.java:49)
>>>> >>>> > at org.apache.activemq.broker.region.Queue.start(Queue.java:889)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:143)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:289)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:161)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.security.AuthorizationBroker.addDestination(AuthorizationBroker.java:81)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.security.AuthorizationBroker.addDestinationInfo(AuthorizationBroker.java:51)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.MutableBrokerFilter.addDestinationInfo(MutableBrokerFilter.java:223)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection.processAddDestination(TransportConnection.java:477)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.command.DestinationInfo.visit(DestinationInfo.java:122)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:135)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:124)
>>>> >>>> > at
>>>> >>>> >
>>>> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:103)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:588)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:420)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:151)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport.java:91)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
>>>> >>>> > at
>>>> >>>> >
>>>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
>>>> >>>> >
>>>> >>>> >
>>>> >>>> >
>>>> >>>> > 2012-05-11 05:24:37,248 | WARN  | Async error occurred:
>>>> >>>> > java.lang.IllegalStateException: Timer already cancelled.
|
>>>> >>>> > org.apache.activemq.broker.TransportConnection.Service
| ActiveMQ
>>>> >>>> > Transport: ssl:///10.60.252.28:54493
>>>> >>>> > java.lang.IllegalStateException: Timer already cancelled.
>>>> >>>> > at java.util.Timer.sched(Timer.java:397)
>>>> >>>> > at java.util.Timer.schedule(Timer.java:248)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.thread.Scheduler.schedualPeriodically(Scheduler.java:49)
>>>> >>>> > at org.apache.activemq.broker.region.Queue.start(Queue.java:889)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:143)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:289)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:161)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.security.AuthorizationBroker.addDestination(AuthorizationBroker.java:81)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.security.AuthorizationBroker.addDestinationInfo(AuthorizationBroker.java:51)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.MutableBrokerFilter.addDestinationInfo(MutableBrokerFilter.java:223)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection.processAddDestination(TransportConnection.java:477)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.command.DestinationInfo.visit(DestinationInfo.java:122)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:135)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:124)
>>>> >>>> > at
>>>> >>>> >
>>>> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:103)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:588)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:420)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:151)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport.java:91)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
>>>> >>>> > at
>>>> >>>> >
>>>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
>>>> >>>> >
>>>> >>>> > 2012-05-11 05:24:37,249 | DEBUG | mstmip102.vosh.net
adding
>>>> >>>> > destination:
>>>> >>>> > topic://ActiveMQ.Advisory.Connection |
>>>> >>>> > org.apache.activemq.broker.region.AbstractRegion |
StopAsync:vm://
>>>> >>>> > mstmip102.vosh.net#0-23
>>>> >>>> > 2012-05-11 05:24:37,250 | WARN  | Failed to remove
connection
>>>> >>>> > ConnectionInfo {commandId = 3, responseRequired = false,
>>>> connectionId
>>>> >>>> > =
>>>> >>>> > ID:msipap102-50908-1336690011745-7:1, clientId =
>>>> >>>> > mstmip102_msipap102.vosh.net_outbound, clientIp =
>>>> >>>> > vm://mstmip102.vosh.net#0,
>>>> >>>> > userName = mqipauser, password = *****, brokerPath
= null,
>>>> >>>> > brokerMasterConnector = false, manageable = false,
clientMaster =
>>>> >>>> > true,
>>>> >>>> > faultTolerant = false, failoverReconnect = false},
reason:
>>>> >>>> > java.lang.IllegalStateException: Timer already cancelled.
|
>>>> >>>> > org.apache.activemq.broker.TransportConnection.Service
|
>>>> >>>> > StopAsync:vm://
>>>> >>>> > mstmip102.vosh.net#0-23
>>>> >>>> > 2012-05-11 05:24:37,250 | DEBUG | Exception detail:
|
>>>> >>>> > org.apache.activemq.broker.TransportConnection.Service
|
>>>> >>>> > StopAsync:vm://
>>>> >>>> > mstmip102.vosh.net#0-23
>>>> >>>> > java.lang.IllegalStateException: Timer already cancelled.
>>>> >>>> > at java.util.Timer.sched(Timer.java:397)
>>>> >>>> > at java.util.Timer.schedule(Timer.java:248)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.thread.Scheduler.schedualPeriodically(Scheduler.java:49)
>>>> >>>> > at org.apache.activemq.broker.region.Topic.start(Topic.java:530)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:143)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:286)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:161)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.security.AuthorizationBroker.addDestination(AuthorizationBroker.java:81)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:481)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:305)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:533)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:464)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:459)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.advisory.AdvisoryBroker.removeConnection(AdvisoryBroker.java:234)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.removeConnection(BrokerFilter.java:113)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransactionBroker.removeConnection(TransactionBroker.java:351)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.removeConnection(BrokerFilter.java:113)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.security.JaasAuthenticationBroker.removeConnection(JaasAuthenticationBroker.java:95)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.BrokerFilter.removeConnection(BrokerFilter.java:113)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.MutableBrokerFilter.removeConnection(MutableBrokerFilter.java:119)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection.processRemoveConnection(TransportConnection.java:766)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1068)
>>>> >>>> > at
>>>> >>>> >
>>>> >>>> >
>>>> org.apache.activemq.broker.TransportConnection$4.run(TransportConnection.java:996)
>>>> >>>> > at java.lang.Thread.run(Thread.java:722)
>>>> >>>> >
>>>> >>>> > 2012-05-11 05:24:37,252 | DEBUG | mstmip102.vosh.net
adding
>>>> >>>> > destination:
>>>> >>>> > temp-queue://ID:POTMIP102-54337-634722930065323786-1:18:1
|
>>>> >>>> > org.apache.activemq.broker.region.AbstractRegion |
ActiveMQ
>>>> Transport:
>>>> >>>> > ssl:///172.17.5.78:59658
>>>> >>>> >
>>>> >>>> > 2012-05-11 05:24:37,341 | DEBUG | bridging (mstmip102.vosh.net
->
>>>> >>>> > msipap101.vosh.net)
>>>> ID:MSTMIP102-59588-1336713700699-1:1:0:0:25184,
>>>> >>>> > consumer: ID:MSTMIP102-59588-1336713700699-4:2:1:1,
destination
>>>> >>>> > topic://ActiveMQ.Advisory.TempQueue, brokerPath:
>>>> >>>> > [ID:MSTMIP102-59588-1336713700699-0:1], message: ActiveMQMessage
>>>> >>>> > {commandId
>>>> >>>> > = 0, responseRequired = false, messageId =
>>>> >>>> > ID:MSTMIP102-59588-1336713700699-1:1:0:0:25184,
>>>> originalDestination =
>>>> >>>> > null,
>>>> >>>> > originalTransactionId = null, producerId =
>>>> >>>> > ID:MSTMIP102-59588-1336713700699-4:1:1:1, destination
=
>>>> >>>> > topic://ActiveMQ.Advisory.TempQueue, transactionId
= null,
>>>> expiration
>>>> >>>> > = 0,
>>>> >>>> > timestamp = 0, arrival = 0, brokerInTime = 1336713871588,
>>>> >>>> > brokerOutTime =
>>>> >>>> > 1336713877341, correlationId = null, replyTo = null,
persistent =
>>>> >>>> > false,
>>>> >>>> > type = Advisory, priority = 0, groupID = null, groupSequence
= 0,
>>>> >>>> > targetConsumerId = null, compressed = false, userID
= null,
>>>> content =
>>>> >>>> > null,
>>>> >>>> > marshalledProperties =
>>>> org.apache.activemq.util.ByteSequence@567edec8,
>>>> >>>> > dataStructure = DestinationInfo {commandId = 0, responseRequired
=
>>>> >>>> > false,
>>>> >>>> > connectionId = ID:MSTMIP102-59588-1336713700699-3:2,
destination =
>>>> >>>> > temp-queue://ID:POTMIP102-54337-634722930065323786-1:18:1,
>>>> >>>> > operationType =
>>>> >>>> > 0, timeout = 0, brokerPath = null}, redeliveryCounter
= 0, size =
>>>> >>>> > 1024,
>>>> >>>> > properties = {originBrokerURL=ssl://MSTMIP102:61616,
>>>> >>>> > originBrokerId=ID:MSTMIP102-59588-1336713700699-0:1,
>>>> originBrokerName=
>>>> >>>> > mstmip102.vosh.net}, readOnlyProperties = false, readOnlyBody
=
>>>> false,
>>>> >>>> > droppable = false} |
>>>> >>>> > org.apache.activemq.network.DemandForwardingBridgeSupport
|
>>>> ActiveMQ
>>>> >>>> > Connection Dispatcher: vm://mstmip102.vosh.net#4
>>>> >>>> >
>>>> >>>> > 2012-05-11 05:24:37,341 | DEBUG | bridging (mstmip102.vosh.net
->
>>>> >>>> > msipap101.vosh.net)
>>>> ID:MSTMIP102-59588-1336713700699-1:1:0:0:25185,
>>>> >>>> > consumer: ID:MSTMIP102-59588-1336713700699-4:2:1:1,
destination
>>>> >>>> > topic://ActiveMQ.Advisory.TempQueue, brokerPath:
>>>> >>>> > [ID:MSTMIP102-59588-1336713700699-0:1], message: ActiveMQMessage
>>>> >>>> > {commandId
>>>> >>>> > = 0, responseRequired = false, messageId =
>>>> >>>> > ID:MSTMIP102-59588-1336713700699-1:1:0:0:25185,
>>>> originalDestination =
>>>> >>>> > null,
>>>> >>>> > originalTransactionId = null, producerId =
>>>> >>>> > ID:MSTMIP102-59588-1336713700699-4:1:1:1, destination
=
>>>> >>>> > topic://ActiveMQ.Advisory.TempQueue, transactionId
= null,
>>>> expiration
>>>> >>>> > = 0,
>>>> >>>> > timestamp = 0, arrival = 0, brokerInTime = 1336713871588,
>>>> >>>> > brokerOutTime =
>>>> >>>> > 1336713877341, correlationId = null, replyTo = null,
persistent =
>>>> >>>> > false,
>>>> >>>> > type = Advisory, priority = 0, groupID = null, groupSequence
= 0,
>>>> >>>> > targetConsumerId = null, compressed = false, userID
= null,
>>>> content =
>>>> >>>> > null,
>>>> >>>> > marshalledProperties =
>>>> org.apache.activemq.util.ByteSequence@235448d5,
>>>> >>>> > dataStructure = DestinationInfo {commandId = 0, responseRequired
=
>>>> >>>> > false,
>>>> >>>> > connectionId = ID:MSTMIP102-59588-1336713700699-3:2,
destination =
>>>> >>>> > temp-queue://ID:POTMIP102-54337-634722930065323786-1:18:1,
>>>> >>>> > operationType =
>>>> >>>> > 1, timeout = 0, brokerPath = null}, redeliveryCounter
= 0, size =
>>>> >>>> > 1024,
>>>> >>>> > properties = {originBrokerURL=ssl://MSTMIP102:61616,
>>>> >>>> > originBrokerId=ID:MSTMIP102-59588-1336713700699-0:1,
>>>> originBrokerName=
>>>> >>>> > mstmip102.vosh.net}, readOnlyProperties = false, readOnlyBody
=
>>>> false,
>>>> >>>> > droppable = false} |
>>>> >>>> > org.apache.activemq.network.DemandForwardingBridgeSupport
|
>>>> ActiveMQ
>>>> >>>> > Connection Dispatcher: vm://mstmip102.vosh.net#4
>>>> >>>> >
>>>> >>>> > 2012-05-11 13:29:40,053 | WARN  | TopicSubscription:
>>>> >>>> > consumer=ID:MSTMIP102-32947-1336741838889-4:2:1:1,
destinations=7,
>>>> >>>> > dispatched=1000, delivered=7723, matched=1001, discarded=0:
has
>>>> twice
>>>> >>>> > its
>>>> >>>> > prefetch limit pending, without an ack; it appears
to be slow |
>>>> >>>> > org.apache.activemq.broker.region.TopicSubscription
| ActiveMQ
>>>> >>>> > Transport:
>>>> >>>> > ssl:///10.60.252.28:54614
>>>> >>>> >
>>>> >>>> > 2012-05-11 13:29:42,540 | WARN  | TopicSubscription:
>>>> >>>> > consumer=ID:MSTMIP102-32947-1336741838889-3:2:1:1,
destinations=6,
>>>> >>>> > dispatched=1000, delivered=9922, matched=1001, discarded=0:
has
>>>> twice
>>>> >>>> > its
>>>> >>>> > prefetch limit pending, without an ack; it appears
to be slow |
>>>> >>>> > org.apache.activemq.broker.region.TopicSubscription
| ActiveMQ
>>>> >>>> > Transport:
>>>> >>>> > ssl:///10.60.252.28:54614
>>>> >>>>
>>>> >>>>
>>>> >>>>
>>>> >>>> --
>>>> >>>> http://fusesource.com
>>>> >>>> http://blog.garytully.com
>>>> >>>
>>>> >>>
>>>> >>
>>>> >
>>>>
>>>>
>>>>
>>>> --
>>>> http://fusesource.com
>>>> http://blog.garytully.com
>>>>
>>>
>>>
>>



-- 
http://fusesource.com
http://blog.garytully.com

Mime
View raw message