activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Roger Hoover" <roger.hoo...@gmail.com>
Subject Re: Priority queue/semantics of consumer priority
Date Wed, 13 Feb 2008 02:37:46 GMT
That would get the messages into their respective queues.  I still need a
solution for the STOMP consumers to subscribe to multiple queues and process
messages from them in priority order.  I think the select()  based approach
I mentioned previously will work.  I wanted to see if there were other
options before heading down that path because most STOMP clients do not make
it really easy to do this.
Thanks,

Roger

On Feb 12, 2008 6:05 PM, ttmdev <joe.fernandez@ttmsolutions.com> wrote:

>
> Oops, sorry. When I saw this statement, I thought you wanted a message
> routed
> to a particular queue based on its priority.
>
> "Put the messages with different priorities into different queues"
>
> If that is the case, then I think you can have the broker - using
> composite
> destinations and selectors - automatically route the messages to their
> respective queues based on their priority. Something similar to this
> pattern.
>
> http://www.enterpriseintegrationpatterns.com/ContentBasedRouter.html
>
> Joe
>
>
>
> Roger Hoover wrote:
> >
> > Thanks, Joe.
> > I'm not sure content-based routing would do what I'm looking for (maybe
> > you
> > can explain further).
> >
> > I'd like the same group of consumers to process messages with different
> > priorities but to give preference in the order of processing to higher
> > priority messages.
> >
> > On Feb 12, 2008 11:01 AM, ttmdev <joe.fernandez@ttmsolutions.com> wrote:
> >
> >>
> >> I would say the answer to your first question is 'yes'.
> >>
> >> Sounds like you're implementing a content-based routing pattern.
> >>
> >> If you can't use Camel to implement the pattern, then consider
> >> configuring
> >> the broker with composite destinations in combination with a selector
> to
> >> let
> >> the broker do the routing for you.
> >>
> >> Joe
> >> www.ttmsolutions.com
> >>
> >>
> >>
> >> Roger Hoover wrote:
> >> >
> >> > Thanks for the link, Joe.
> >> > So it looks like consumer priority is used by the broker to determine
> >> > which
> >> > subscriber to choose as the exclusive consumer?
> >> >
> >> > Does AMQ support message priorities?  This ticket would suggest the
> >> answer
> >> > is no (http://issues.apache.org/activemq/browse/AMQ-122)
> >> >
> >> > Does anyone have any recommendations for achieving the semantics of a
> >> > priority queue?
> >> >
> >> > Here's what I was thinking of doing:
> >> > - Put the messages with different priorities into different queues
> >> > - Have the clients (STOMP is this case) subscribe to the various
> >> priority
> >> > queues
> >> > - The clients select() on all the sockets and when data is ready to
> be
> >> > read,
> >> > the client reads from socket of the highest priority queue.
> >> >
> >> > Suggests welcome.  Thanks,
> >> >
> >> > Roger
> >> >
> >> > On Feb 12, 2008 5:36 AM, ttmdev <joe.fernandez@ttmsolutions.com>
> wrote:
> >> >
> >> >>
> >> >> Hi Roger,
> >> >>
> >> >> I'd disregard the consumer priority feature; it does not function as
> >> >> described in the consumer priority page.
> >> >>
> >> >> Here's the exclusive consumer web page.
> >> >>
> >> >> http://activemq.apache.org/exclusive-consumer.html
> >> >>
> >> >> Joe
> >> >> www.ttmsolutions.com
> >> >>
> >> >>
> >> >>
> >> >>
> >> >>
> >> >>
> >> >> Roger Hoover wrote:
> >> >> >
> >> >> > I want to implement a priority queue (message delivery ordered
by
> >> >> > priority)
> >> >> > and am trying to figure out what consumer priority means.
> >> >> >
> >> >> > After looking over the documentation (
> >> >> > http://activemq.apache.org/consumer-priority.html) and these email
> >> >> > threads,
> >> >> > the semantics of consumer priority are still not entirely clear
to
> >> me.
> >> >> >
> >> >>
> >>
> http://www.nabble.com/Consumer-Priority-on-AMQ-5.0-to14369093s2354.html#a14369093
> >> >> >
> >> >>
> >>
> http://www.nabble.com/Using-different-consumer-priorities-in-the-same-connection-td14722765s2354.html#a14722765
> >> >> >
> >> >> > - Does consumer priority control the order of message delivery
or
> >> does
> >> >> it
> >> >> > influence which consumer messages get sent to?
> >> >> >
> >> >> > - If it controls delivery order, what effect does setting a
> priority
> >> on
> >> >> a
> >> >> > consumer have?  It would seem like the priority should be set
per
> >> >> message.
> >> >> >
> >> >> > - What does Hiram mean by "exclusive consumers"?  Is this
> different
> >> >> from
> >> >> > each message being delivered to one and one only consumer?
> >> >> >
> >> >> > - What is the weighting algorithm for priorities?
> >> >> >
> >> >> > - What is the ballpark performance penalty for priority evaluation
> >> on
> >> >> the
> >> >> > broker?
> >> >> >
> >> >> > - Does the priority value have any particular significance other
> >> than
> >> >> > being
> >> >> > greater or less than other priority levels?
> >> >> >   - Is there a maximum priority value?
> >> >> >   - Does priority 0 have any special meaning?
> >> >> >
> >> >> > - Does the feature exist in AMQ 4.1.1?
> >> >> >
> >> >> > - Are there any gotchas when using it with STOMP?
> >> >> >
> >> >> > I appreciate any info anyone can provide.
> >> >> >
> >> >> > Cheers,
> >> >> >
> >> >> > Roger
> >> >> >
> >> >> >
> >> >>
> >> >> --
> >> >> View this message in context:
> >> >>
> >>
> http://www.nabble.com/Priority-queue-semantics-of-consumer-priority-tp15427022s2354p15433256.html
> >> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> >> >>
> >> >>
> >> >
> >> >
> >>
> >> --
> >> View this message in context:
> >>
> http://www.nabble.com/Priority-queue-semantics-of-consumer-priority-tp15427022s2354p15440134.html
> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> >>
> >>
> >
> >
>
> --
> View this message in context:
> http://www.nabble.com/Priority-queue-semantics-of-consumer-priority-tp15427022s2354p15447735.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>

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