activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: Variable volume of messages across consumers
Date Thu, 11 Jul 2013 16:21:36 GMT
Add logging configuration to turn on logging for the bridge.

e.g.,

to your log4j.properties, add

log4j.logger.org.apache.activemq.network.DemandForwardingBridgeSupport=DEBUG


On Thu, Jul 11, 2013 at 3:38 AM, Praveen Bysani <praveen.iiith@gmail.com>wrote:

> Hi,
>
> I found the following lines in the subscriber log
>
> | org.apache.activemq.transport.InactivityMonitor | DEBUG | 2013-07-11
> 07:34:44,384 | 30000 ms elapsed since last read check.
> | org.apache.activemq.transport.InactivityMonitor | DEBUG | 2013-07-11
> 07:34:44,384 |
> org.apache.activemq.transport.InactivityMonitor$2@61726a5c9999
> ms elapsed since last write check.
>
> I have disabled the inactivity period in the broker connection url by
> setting maxInactivityDuration to 0. Does it have anything to do with
> messages not being received ?
>
> On 11 July 2013 12:18, Praveen Bysani <praveen.iiith@gmail.com> wrote:
>
> > Hi Christian,
> >
> > Thanks for your input. But i have little idea of what those terms mean.
> > Could you elaborate please.
> >
> >
> > On 10 July 2013 21:06, Christian Posta <christian.posta@gmail.com>
> wrote:
> >
> >> Your best bet would be to set logging to debug on the network bridge
> >> (DemandForwardingBridgeSupport) and possibly the RegionBroker to see
> what
> >> is happening.
> >>
> >> On Wednesday, July 10, 2013, Praveen Bysani wrote:
> >>
> >> > Hi,
> >> > I have the following setup in my project,
> >> >
> >> >    1. multiple producers (p1,p2,p3) in Hongkong region sending
> variable
> >> >    size non-persistent messages to a topic t1 on the broker (b1) in
> >> >    Phillippines region
> >> >    2. p1,p2 and p3 send messages frequently (~1 second)
> >> >    3. each message has a time to live of 30 seconds
> >> >    4. a tcp network bridge from b1 to a new broker b2 in HK region
> >> >    5. consumers c1 in hongkong and c2 in europe subscribed to b2
> through
> >> >    ssl and a consumer c3 subscribed to t1 on b1 through tcp
> >> >
> >> > I don't see the same amount of messages received across c1, c2 and c3.
> >> The
> >> > number of messages received is in the following order c3 > c1 > c2.
I
> >> use
> >> > the default settings for prefetch values and *vmCursor *for
> >> > *pendingSubscriberPolicy
> >> > *and *strictOrderDisptachpolicy*.
> >> >
> >> > While i understand there could be delays in passing the message to
> these
> >> > consumers as c3 could be slow consumer and c1 is fast, shouldn't the
> >> > message eventually be received to all consumers of a topic. Why do i
> see
> >> > different volumes of messages across different consumers ? Someone
> >> please
> >> > help me understand what is going on !!
> >> >
> >> > Another strange thing is after a while, there are no messages received
> >>  by
> >> > c2 for a very long period. I suppose it is due to the prefetch size ?
> >> Since
> >> > i am using a non persistent topic, the default value is quite high
> >> > (according to activemq documentation), which again baffles me if that
> is
> >> > really the reason.
> >> > --
> >> > Regards,
> >> > Praveen Bysani
> >> > http://www.praveenbysani.com
> >> >
> >>
> >>
> >> --
> >> *Christian Posta*
> >> http://www.christianposta.com/blog
> >> twitter: @christianposta
> >>
> >
> >
> >
> > --
> > Regards,
> > Praveen Bysani
> > http://www.praveenbysani.com
> >
>
>
>
> --
> Regards,
> Praveen Bysani
> http://www.praveenbysani.com
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message