From users-return-31324-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Wed Jul 18 14:17:41 2012 Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DDF639FC1 for ; Wed, 18 Jul 2012 14:17:41 +0000 (UTC) Received: (qmail 38712 invoked by uid 500); 18 Jul 2012 14:17:41 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 38660 invoked by uid 500); 18 Jul 2012 14:17:41 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 38641 invoked by uid 99); 18 Jul 2012 14:17:40 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Jul 2012 14:17:40 +0000 X-ASF-Spam-Status: No, hits=0.6 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_MED,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (nike.apache.org: 194.35.218.66 is neither permitted nor denied by domain of Alistair.Young@uhi.ac.uk) Received: from [194.35.218.66] (HELO gwsmtp.uhi.ac.uk) (194.35.218.66) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Jul 2012 14:17:34 +0000 Received: from UHI-OUT-MTA by gwsmtp.uhi.ac.uk with Novell_GroupWise; Wed, 18 Jul 2012 15:17:14 +0100 Message-Id: <5006D3710200008A0004E5C1@gwsmtp.uhi.ac.uk> X-Mailer: Novell GroupWise Internet Agent 8.0.2 Date: Wed, 18 Jul 2012 15:17:05 +0100 From: "Alistair Young" To: Subject: Re: Searching for a particular message in a topic Mime-Version: 1.0 Content-Type: multipart/mixed; boundary="=__Part8ABBD171.0__=" --=__Part8ABBD171.0__= Content-Type: multipart/alternative; boundary="=__Part8ABBD171.1__=" --=__Part8ABBD171.1__= Content-Type: text/plain; charset=US-ASCII Content-Transfer-Encoding: quoted-printable Perhaps getting at the prefetch buffer would prolly be better in that = case. Would you have a pointer on how to access it? Use case is a consumer that populates Active Directory and uses auto = acknowledge. If the AD bit slows down for any reason the topic should fill = up with messages and I need to provide a way for the support team to see = if an account is in the 'queue', i.e. it's been sent to the broker but not = been consumed yet. The query will be based on a userid which is contained = in the message body. Of course I might have missed an entirely easier way = of doing it. It's in conjunction with Camel routing so I could prolly do = something with a Processor or fancy logging but for the most part the = consumer rarely slows down and logging thousands of usernames seems a bit = over the top on the off chance one might be queried. Alistair mov eax,1 mov ebx,0 int 80h >>> Gary Tully 18/07/12 3:05 PM >>> you would be on the right track. you will need to lock the pending cursor for the duration of the iteration so that will be a little expensive. the pending cursor only gets filled when the prefetch buffer is filled, so you would need a low prefetch and a slow consumer if you expect to find messages in there. What is the use case here? On 18 July 2012 14:46, Alistair Young wrote: > would I be on the right path if I implemented it in TopicSubscriptionView= > and making use of PendingMessageCursor from TopicSubscription to get at = the > pending messages and their content and properties? Or is iterating > PendingMessageCursor expensive? > > > Alistair > > > mov eax,1 > mov ebx,0 > int 80h > >>>> Gary Tully 18/07/12 1:16 PM >>> > > that feature does not exist, it would require some extension to > org.apache.activemq.broker.jmx.TopicSubscriptionView > > On 18 July 2012 11:21, Alistair Young wrote: >> Is there a way to find a particular message in a topic, either via a >> header >> name/value or based on message content? e.g. if I have a message I know >> may >> be in the topic and it has a message body that would match a particular >> regex, or has a header name with a particular value, is it possible to >> find >> it and therefore verify it's in the topic, i.e. it's in the backlog >> waiting >> to be consumed? >> >> thanks, >> >> Alistair >> >> >> mov eax,1 >> mov ebx,0 >> int 80h >> > > > > -- > http://fusesource.com > http://blog.garytully.com --=20 http://fusesource.com http://blog.garytully.com --=__Part8ABBD171.1__= Content-Type: text/html; charset=US-ASCII Content-Transfer-Encoding: quoted-printable Content-Description: HTML Perhaps getting at the prefetch buffer would prolly be = better in that case. Would you have a pointer on how to access it?

U= se case is a consumer that populates Active Directory and uses auto = acknowledge. If the AD bit slows down for any reason the topic should fill = up with messages and I need to provide a way for the support team to see = if an account is in the 'queue', i.e. it's been sent to the broker but not = been consumed yet. The query will be based on a userid which is contained = in the message body. Of course I might have missed an entirely easier way = of doing it. It's in conjunction with Camel routing so I could prolly do = something with a Processor or fancy logging but for the most part the = consumer rarely slows down and logging thousands of usernames seems a bit = over the top on the off chance one might be queried.

Alistair


mov eax,1
mov ebx,0
int = 80h

>>> Gary Tully <gary.tully@gmail.com> = 18/07/12 3:05 PM >>>
you would be on the right track.
you = will need to lock the pending cursor for the duration of the
iteration = so that will be a little expensive.

the pending cursor only gets = filled when the prefetch buffer is
filled, so you would need a low = prefetch and a slow consumer if you
expect to find messages in = there.
What is the use case here?

On 18 July 2012 14:46, = Alistair Young <Alistair.Young@uhi.ac.uk> wrote:
> would I be = on the right path if I implemented it in TopicSubscriptionView
> and = making use of PendingMessageCursor from TopicSubscription to get at = the
> pending messages and their content and properties? Or is = iterating
> PendingMessageCursor expensive?
>
>
> = Alistair
>
>
> mov eax,1
> mov ebx,0
> int = 80h
>
>>>> Gary Tully <gary.tully@gmail.com> = 18/07/12 1:16 PM >>>
>
> that feature does not exist, = it would require some extension to
> org.apache.activemq.broker.jmx.T= opicSubscriptionView
>
> On 18 July 2012 11:21, Alistair Young = <Alistair.Young@uhi.ac.uk> wrote:
>> Is there a way to find = a particular message in a topic, either via a
>> header
>>= ; name/value or based on message content? e.g. if I have a message I = know
>> may
>> be in the topic and it has a message body = that would match a particular
>> regex, or has a header name with = a particular value, is it possible to
>> find
>> it and = therefore verify it's in the topic, i.e. it's in the backlog
>> = waiting
>> to be consumed?
>>
>> thanks,
>= >
>> Alistair
>>
>>
>> mov = eax,1
>> mov ebx,0
>> int 80h
>>
>
>=
>
> --
> http://fusesource.com
> http://blog.garyt= ully.com



--
http://fusesource.com
http://blog.garytul= ly.com
--=__Part8ABBD171.1__=-- --=__Part8ABBD171.0__=--