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: Does the ">" destination wildcard require at least one character preceding it?
Date Wed, 27 Mar 2013 20:19:19 GMT
Steve,

I'm still a bit curious about this one.
The tests I mentioned previously that were failing I have since found a
solution/explanation.
Are you still seeing the issues related to prioritized messages?


On Tue, Feb 5, 2013 at 8:57 PM, Steve.V. <stephen.vincent@sas.com> wrote:

> Yes, I am using the default kahaDB as the broker store.
>
> My tests seem to run fine if I access a broker that is running on my PC,
> and
> I specify the prioritizedMessages="true" policy using the queue name
> instead
> of the ">" wildcard.  However, they frequently encounter trouble when the
> broker is running on a UNIX box.  More frequently on our UNIX boxes that
> run
> HP-UX and Linux.
>
> I just installed a local copy of the 05Feb snapshot of 5.8 on a box running
> HP-UX 11.31, and it failed on the twentieth iteration of the aforementioned
> test.   I was thinking that most of my problems where being caused by
> having
> the persistence store on a network drive.  While I see more trouble when it
> is on a network drive, recent tests are still failing frequently even when
> the store is local to the UNIX machine.
>
> The results from my tests against the 05Feb snapshot of 5.8 on a UNIX
> machine fail due to messages not being available but should have been.  For
> some reason, they appear to be expiring.  Here is an excerpt from the 5.8.0
> log:
>
> ...
> ...snip...
> 2013-02-05 22:46:10,041 | DEBUG | queue://testq expiring messages .. |
> org.apache.activemq.broker.region.Queue | ActiveMQ Broker[l
> ocalhost] Scheduler
> 2013-02-05 22:46:10,041 | DEBUG | testq toPageIn: 13, Inflight: 0,
> pagedInMessages.size 0, enqueueCount: 104, dequeueCount: 91 | o
> rg.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost]
> Scheduler
> 2013-02-05 22:46:10,042 | DEBUG | queue://testq expiring messages done. |
> org.apache.activemq.broker.region.Queue | ActiveMQ Broke
> r[localhost] Scheduler
> 2013-02-05 22:46:10,052 | DEBUG | testq toPageIn: 0, Inflight: 0,
> pagedInMessages.size 13, enqueueCount: 104, dequeueCount: 91 | o
> rg.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost]
> Task-1
> 2013-02-05 22:46:10,101 | DEBUG | Checkpoint started. |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkp
> oint Worker
> 2013-02-05 22:46:10,111 | DEBUG | queue://testq expiring messages .. |
> org.apache.activemq.broker.region.Queue | ActiveMQ Broker[l
> ocalhost] Scheduler
> 2013-02-05 22:46:10,111 | DEBUG | testq toPageIn: 0, Inflight: 0,
> pagedInMessages.size 13, enqueueCount: 104, dequeueCount: 91 | o
> rg.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost]
> Scheduler
> 2013-02-05 22:46:10,111 | DEBUG | queue://testq expiring messages done. |
> org.apache.activemq.broker.region.Queue | ActiveMQ Broke
> r[localhost] Scheduler
> 2013-02-05 22:46:10,111 | DEBUG | testq toPageIn: 0, Inflight: 0,
> pagedInMessages.size 13, enqueueCount: 104, dequeueCount: 91 | o
> rg.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost]
> Task-1
> 2013-02-05 22:46:10,202 | DEBUG | Checkpoint done. |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
> Checkpoin
> t Worker
> 2013-02-05 22:46:11,822 | DEBUG | created
> SCEP@18bff68{l(/10.24.8.124:58682)<->r(/10.24.8.124:8161
> ),d=false,open=true,ishut=false,
> oshut=false,rb=false,wb=false,w=true,i=0}-{AsyncHttpConnection@2d2da4
> ,g=HttpGenerator{s=0,h=-1,b=-1,c=-1},p=HttpParser{s=-14,l=0,c
> =0},r=0} | org.eclipse.jetty.io.nio | qtp3916193-28 Selector0
> 2013-02-05 22:46:11,823 | DEBUG | filled 294/294 |
> org.eclipse.jetty.http.HttpParser | qtp3916193-24
> 2013-02-05 22:46:11,823 | DEBUG | REQUEST /api/message on
> AsyncHttpConnection@2d2da4,g=HttpGenerator{s=0,h=-1,b=-1,c=-1},p=HttpPar
> ser{s=-5,l=5,c=0},r=1 | org.eclipse.jetty.server.Server | qtp3916193-24 -
> /api/message?destination=testq&type=queue&clientId=BFB20
> 400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,823 | DEBUG | scope null||/api/message @
> o.e.j.w.WebAppContext{/admin,file:/c/bb04na2a/vol/home_tst/h6i94/sav/
> amq/58/webapps/admin/} | org.eclipse.jetty.server.handler.ContextHandler |
> qtp3916193-24 - /api/message?destination=testq&type=que
> ue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,823 | DEBUG | scope null||/api/message @
> o.e.j.w.WebAppContext{/fileserver,file:/c/bb04na2a/vol/home_tst/h6i94
> /sav/amq/58/webapps/fileserver/} |
> org.eclipse.jetty.server.handler.ContextHandler | qtp3916193-24 -
> /api/message?destination=test
> q&type=queue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,823 | DEBUG | scope null||/api/message @
> o.e.j.w.WebAppContext{/api,file:/c/bb04na2a/vol/home_tst/h6i94/sav/am
> q/58/webapps/api/} | org.eclipse.jetty.server.handler.ContextHandler |
> qtp3916193-24 - /api/message?destination=testq&type=queue&c
> lientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,824 | DEBUG | context=/api||/message @
> o.e.j.w.WebAppContext{/api,file:/c/bb04na2a/vol/home_tst/h6i94/sav/amq/
> 58/webapps/api/} | org.eclipse.jetty.server.handler.ContextHandler |
> qtp3916193-24 - /api/message?destination=testq&type=queue&cli
> entId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,824 | DEBUG |
> sessionManager=org.eclipse.jetty.server.session.HashSessionManager@1c64ed8|
> org.eclipse.jetty.s
> erver.session | qtp3916193-24 -
>
> /api/message?destination=testq&type=queue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeou
> t=1
> 2013-02-05 22:46:11,824 | DEBUG | session=null |
> org.eclipse.jetty.server.session | qtp3916193-24 -
> /api/message?destination=testq
> &type=queue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,824 | DEBUG | servlet /api|/message|null ->
> MessageServlet | org.eclipse.jetty.servlet.ServletHandler | qtp391
> 6193-24 -
>
> /api/message?destination=testq&type=queue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,824 | DEBUG | chain=null |
> org.eclipse.jetty.servlet.ServletHandler | qtp3916193-24 -
> /api/message?destination
>
> =testq&type=queue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> 2013-02-05 22:46:11,824 | DEBUG | Getting local client
> [BFB20400-700F-11E2-9D8E-0E72C1E2DF3C] | org.apache.activemq.web.MessageSer
> vlet | qtp3916193-24 -
>
> /api/message?destination=testq&type=queue&clientId=BFB20400-700F-11E2-9D8E-0E72C1E2DF3C&readTimeout=1
> ...
> ...snip...
>
>
>
>
> -----
> Stephen Vincent
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Does-the-destination-wildcard-require-at-least-one-character-preceding-it-tp4662468p4662842.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



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

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