Re: Message groups (was: route message to a specific consumer)

est/org/apache/activemq/artemis/api/core/management/QueueControl.html#resetGroup(java.lang.String) On Mon, Dec 11, 2023 at 8:08 AM John Lilley wrote: > Justin, > > > > Thanks again for your attention to this. I have verified many times now > that message groups work in our

Message groups (was: route message to a specific consumer)

Justin, Thanks again for your attention to this. I have verified many times now that message groups work in our test harness -- When I enable message groups the test succeeds, and when I disable message groups the test fails. Your concern about message groups was: “Even in the case of message

Classic Message Groups and Horizontal Scaling of Consumers

Hi, We're considering using Message Groups to solve update contention within the consumers. Consumers do handle contention by rolling back and retrying, which significantly reduces effective throughput, so the objective is to eliminate as much contention as possible. Msg ordering is als

Re: [ActiveMQ Artemis]: Message Groups; STOMP; idle consumers

] immediately > 2. `Consumer 2` starts handling [group: user-2] immediately > > Actual behavior: > 1. `Consumer 1` starts handling [group: user-1] immediately > 2. `Consumer 2` waits until `Consumer 1` handled about 60 - 65 messages and > only after that starts handling [group: user-2] &

[ActiveMQ Artemis]: Message Groups; STOMP; idle consumers

sages and only after that starts handling [group: user-2] (The only way to achieve expected behavior was to increase the priority of the message in [group: user-2]) Can be reproduced even with 3 consumers, 3 message groups with 100 messages in it (in this case `consumer 3` waits until `consumer 2` handled about 60 - 65 messages. Please advise. Regards, Egor

Use of Message Groups

Wanted to ask some specifics about the "Message Groups" feature. * is the feature incurring an overhead to the broker processing? * would a large queue depth cause any issues? * there is a note about 'grouping in memory', does this mean messsages are somehow re-order

Re: Selective consuming of priority messages with message groups

ankie -- View this message in context: http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813p4704975.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Selective consuming of priority messages with message groups

e form of simple >> heuristic to choose when to process the same (e.g. after processing 10 >> high-priority messages, process 1 low-priority message) >> >> The use of a heuristic will be important to allow the balance between >> starving low-priority messages and d

Re: Selective consuming of priority messages with message groups

s, such as priority queueing, are limited and not likely > to > give you the desired results. > > BTW, I may have missed it - why use message groups? Is messaging order > important? > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Select

Re: Selective consuming of priority messages with message groups

Messaging features, such as priority queueing, are limited and not likely to give you the desired results. BTW, I may have missed it - why use message groups? Is messaging order important? -- View this message in context: http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-m

Re: Selective consuming of priority messages with message groups

There are two things that happen with message groups that makes them a poor match for use with selectors. First, the default implementation of message groups uses "buckets" of assignments for groups-to-consumers. This means that multiple groups actually get assigned to the same consum

Re: Selective consuming of priority messages with message groups

.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813p4704927.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Selective consuming of priority messages with message groups

>> >> Jose María Zaragoza wrote >> > A question about your code: >> > >> > why do you configure prioritizedMessages= true on your broker and also >> > use consumers with a selector parameter ? >> > I guess that to use consumers with a selector parameter is for >> > avoiding to set prioritizedMessages= true >> > >> > With prioritizedMessages= true , the broker try to deliver the >> > messages in order by priority >> > >> > It's only curiosity >> > >> > Regards >> >> >> >> >> >> -- >> View this message in context: >> http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813p4704881.html >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> >

Re: Selective consuming of priority messages with message groups

n your broker and also > > use consumers with a selector parameter ? > > I guess that to use consumers with a selector parameter is for > > avoiding to set prioritizedMessages= true > > > > With prioritizedMessages= true , the broker try to deliver the > > messages in

Re: Selective consuming of priority messages with message groups

; messages in order by priority > > It's only curiosity > > Regards -- View this message in context: http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813p4704881.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Selective consuming of priority messages with message groups

processed, > regardless of the order they're pushed in, while the messages with priority > falling into the other side of the selector will not be consumed at all and > will stay sitting on the queue. > > The version of AMQ broker I'm using is 5.10. > > So, does this seems to you like a bug or a feature I'm not able to > understand? All input on the topic is highly welcome and appreciated! > > Regards, > Frankie > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Selective consuming of priority messages with message groups

ith the jConsole to the local AMQ broker and indeed > there are two Consumers for the queue: one with the selector > "JMSPriority>=4" and one with "JMSPriority<4". After the messages were > pushed to the queue, the second Consumer shows dispatch, as well as

Re: Selective consuming of priority messages with message groups

he second Consumer shows dispatch, as well as dequeue count of 2, while the first one shows a 0 for both of the values. My suspicion is that message groups have something to do with it. It seems as if a Thread #n was dedicated to process the message 1, and then (because of the same message grou

Re: Selective consuming of priority messages with message groups

ing, > even though not sure why it wouldn't work because it's explicitly set in a > same way as it is for low priority messages. > > Tim -- View this message in context: http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813p4704818.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Selective consuming of priority messages with message groups

ge pushed to the queue will be processed, > regardless of the order they're pushed in, while the messages with priority > falling into the other side of the selector will not be consumed at all and > will stay sitting on the queue. > > The version of AMQ broker I'm using is 5.10. > > So, does this seems to you like a bug or a feature I'm not able to > understand? All input on the topic is highly welcome and appreciated! > > Regards, > Frankie > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Selective-consuming-of-priority-messages-with-message-groups-tp4704813.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >

Selective consuming of priority messages with message groups

ll stay sitting on the queue. The version of AMQ broker I'm using is 5.10. So, does this seems to you like a bug or a feature I'm not able to understand? All input on the topic is highly welcome and appreciated! Regards, Frankie -- View this message in context: http://activem

Re: Artemis: JMSXGroupID / Message groups: Large number of groups

Hi Marco, Please see comments inline. Regards Martyn On 08/06/15 20:48, Marco wrote: Hi all, first, thanks for the release of v1.0.0 of Artemis! I'm currently experimenting with the use of message groups to quickly distribute messages to workers while keeping order on items belo

Re: Artemis: JMSXGroupID / Message groups: Large number of groups

actory and hashing UUID to a smaller number of keys. Faisal -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-JMSXGroupID-Message-groups-Large-number-of-groups-tp4697436p4697943.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis: JMSXGroupID / Message groups: Large number of groups

Hi all, first, thanks for the release of v1.0.0 of Artemis! I'm currently experimenting with the use of message groups to quickly distribute messages to workers while keeping order on items belonging together. In order to avoid artificial grouping/sharding it would be perfect for my use ca

Re: Message groups pattern - "late" consumers

never used message groups, you'll want to check that theory. You'd also need to confirm that your consumers' business logic will properly handle the case where a new consumer picks up processing a message group after one of these closes. On Jan 30, 2015 4:44 PM, "sburczymu

Message groups pattern - "late" consumers

Hello, I'm looking for a message pattern - something like message groups. I would like to have one or more consumers/workers that process messages from a queue, each message is tied with specific device and needs to be processed in the order received on a per-device context, so at one time

Re: Dispatch policy for ActiveMQ with new message groups? [

iveMQ-with-new-message-groups-tp4687812p4687863.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Dispatch policy for ActiveMQ with new message groups? [

modify. By the way, is a network of brokers in use? Things get more complicated in that case. -- View this message in context: http://activemq.2283324.n4.nabble.com/Dispatch-policy-for-ActiveMQ-with-new-message-groups-tp4687812p4687861.html Sent from the ActiveMQ - User mailing list archive

Re: Dispatch policy for ActiveMQ with new message groups? [

Q-with-new-message-groups-tp4687812p4687829.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Dispatch policy for ActiveMQ with new message groups? [

icy-for-ActiveMQ-with-new-message-groups-tp4687812p4687828.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Broker redelivery with message groups

10:49, "tbenkooe" wrote: > Hi, > > Is the ordering of the messages in a message groups guaranteed when broker > redelivery is configured? And vice versa, does broker delivery works if > messages are grouped? > > I couldn't find anything in the documentation ab

Broker redelivery with message groups

Hi, Is the ordering of the messages in a message groups guaranteed when broker redelivery is configured? And vice versa, does broker delivery works if messages are grouped? I couldn't find anything in the documentation about the interaction of these features. Cheers, Tamas -- View

Re: Activating consumer for each message groups

If you have existing messages in the broker and add consumers at a later stage, it is a good idea to delay message dispatch start until all consumers are present (or at least to give enough time for them to subscribe). If you don't do that the first consumer will probably acquire all me

Re: Activating consumer for each message groups

Hi, I've checked it once again and broker's web console shows 3 active consumers. TIA. Sergey -- View this message in context: http://activemq.2283324.n4.nabble.com/Activating-consumer-for-each-message-groups-tp4683066p4683266.html Sent from the ActiveMQ - User mailing list

Re: Activating consumer for each message groups

sed for all producers in order for message groups to work? TIA Sergey -- View this message in context: http://activemq.2283324.n4.nabble.com/Activating-consumer-for-each-message-groups-tp4683066p4683176.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Activating consumer for each message groups

Can you verify (JMX) that your consumer (are you using Camel? or straight DMLC from spring?) is actually creating the requisite number of consumers you're expecting? On Thu, Jul 10, 2014 at 4:00 AM, UcayaliFish wrote: > Hi, > I need some advice with message groups and I've

Activating consumer for each message groups

Hi, I need some advice with message groups and I've failed to find a solution in the net. What I'm doing is accepting RTP audio from several sources and converting each RTP frame to JMS BytesMessage and sending it to ActiveMQ queue setting JMSXGroupID property according to audio ori

Re: Message Groups and Network of Brokers (Still not supported?)

gt; Am I missing anything? or is this the expected behavior? > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-Groups-and-Network-of-Brokers-Still-not-supported-tp4678567p4682268.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- http://redhat.com http://blog.garytully.com

Re: Message Groups and Network of Brokers (Still not supported?)

m I missing anything? or is this the expected behavior? -- View this message in context: http://activemq.2283324.n4.nabble.com/Message-Groups-and-Network-of-Brokers-Still-not-supported-tp4678567p4682268.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Message Groups and Network of Brokers (Still not supported?)

message in context: http://activemq.2283324.n4.nabble.com/Message-Groups-and-Network-of-Brokers-Still-not-supported-tp4678567p4678596.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Message Groups and Network of Brokers (Still not supported?)

uration? > > If this is no longer true, then please provide any network of brokers > configurations that can be used reliably with message groups. > > TIA > > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-Groups-and

Message Groups and Network of Brokers (Still not supported?)

groups. TIA -- View this message in context: http://activemq.2283324.n4.nabble.com/Message-Groups-and-Network-of-Brokers-Still-not-supported-tp4678567.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Message Groups and performance

Hi All, I was wondering if there is a publication about the Queue performance when using Message Groups. Our requirement is to handle 45k messages per second. How many messages can a queue handle? how could handle such a load? Thanks, Ali -- View this message in context: http://activemq

Re: Enabling Message Groups

the persistent store , am I right? -- View this message in context: http://activemq.2283324.n4.nabble.com/Enabling-Message-Groups-tp4660972p4672434.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Enabling Message Groups

that is correct. selectors and message groups are dispatched from memory and the number of messages in memory is bound by maxPageSize and prefetch size. note: if you increase the prefetch size for a consumer it will also result in more messages getting paged in. On 7 October 2013 07:06, Girish

Re: Enabling Message Groups

.n4.nabble.com/Enabling-Message-Groups-tp4660972p4672313.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Enabling Message Groups

solution for this problem, would be great if you could share. -- View this message in context: http://activemq.2283324.n4.nabble.com/Enabling-Message-Groups-tp4660972p4672279.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: JMS message Groups - Short living groups

there is no way to automatically clean them up? If not, ts there a way to look up the existing message group and run some type of a clean up code? -- View this message in context: http://activemq.2283324.n4.nabble.com/JMS-message-Groups-Short-living-groups-tp4670060p4670138.html Sent from the

Re: JMS message Groups - Short living groups

I am in process to introduce Message Groups to support parallel processing > of message with an order and multiple consumers. > > We have been thinking a lot about an approach to to create our groups and > it > seems like the groups that we can come up with are short lived and we will

JMS message Groups - Short living groups

Hi All, I am in process to introduce Message Groups to support parallel processing of message with an order and multiple consumers. We have been thinking a lot about an approach to to create our groups and it seems like the groups that we can come up with are short lived and we will very many of

Re: Active MQ - Message Groups

strict message ordering is always going to be at odds with performance. what you're trying to do might be better accomplished with: http://activemq.apache.org/exclusive-consumer.html On Wed, Jul 24, 2013 at 4:05 PM, MB wrote: > After reading ActiveMQ Message Groups feature

Active MQ - Message Groups

After reading ActiveMQ Message Groups feature (http://activemq.apache.org/message-groups.html), I'm a little confused about how it works in a clustered environment. The basic premise as far as I can see is that messages of a particular type (defined by the JMSXGroupID, set in a message) ar

Re: can we combine message groups and jms selectors

; > > Why not using two queues to send the different messages? > > > It's more easy for problem diagnosis if some trouble is present. > > > Besides, Do not use sparse selector or your consumers may get stuck. > > > > > > > > > > > > >

Re: can we combine message groups and jms selectors

t; > seems work in theory. > > Why not using two queues to send the different messages? > > It's more easy for problem diagnosis if some trouble is present. > > Besides, Do not use sparse selector or your consumers may get stuck. > > > > > > > > > > A

Re:Re: can we combine message groups and jms selectors

ote: > >> seems work in theory. >> Why not using two queues to send the different messages? >> It's more easy for problem diagnosis if some trouble is present. >> Besides, Do not use sparse selector or your consumers may get stuck. >> >> >> >&g

Re: can we combine message groups and jms selectors

> It's more easy for problem diagnosis if some trouble is present. > Besides, Do not use sparse selector or your consumers may get stuck. > > > > > At 2013-03-26 22:58:29,"Daniel Guggi" wrote: > >hi, > > > >im curious if it is possible to use

Re:can we combine message groups and jms selectors

>im curious if it is possible to use message-groups and jms selectors >together. > >example: > >i have consumer 'normalPriorityConsumer' for queue "X" with selector >'JMSProperty >= 4' >i have consumer 'lowPrioritiyConsumer' for qu

can we combine message groups and jms selectors

hi, im curious if it is possible to use message-groups and jms selectors together. example: i have consumer 'normalPriorityConsumer' for queue "X" with selector 'JMSProperty >= 4' i have consumer 'lowPrioritiyConsumer' for queue "X" with sele

Some messages are undelivered in a queue using Message Groups

ot sure how to debug why these messages aren't getting consumed. I'm using the following setup: - Apache ActiveMQ 5.5.1 - Camel / Spring / Java is used for message consuming - Using "Message Groups" to ensure message ordering based on username **The

Re: Enabling Message Groups

ext: http://activemq.2283324.n4.nabble.com/Enabling-Message-Groups-tp4660972p4661035.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Enabling Message Groups

> assume I have something configured incorrectly but I'm not sure where to > start? As I understand it when another message comes in with JMSXGroupID of > B it should be processed by an idle consumer. This does not appear to be > happening for me. > > Thanks, > Chad > &

Enabling Message Groups

nother message comes in with JMSXGroupID of B it should be processed by an idle consumer. This does not appear to be happening for me. Thanks, Chad -- View this message in context: http://activemq.2283324.n4.nabble.com/Enabling-Message-Groups-tp4660972.html Sent from the ActiveMQ - User mai

Re: ActiveMQ message groups ConcurrentModificationException

producers that use vmtransport maybe post your xml config and camel context. On 28 September 2012 20:35, boday wrote: > I'm using AMQ message groups with AMQ 5.5.0-fuse-00-27 with Kahadb persistent > messaging and periodically see this WARN in the logs. I don't see any > s

ActiveMQ message groups ConcurrentModificationException

I'm using AMQ message groups with AMQ 5.5.0-fuse-00-27 with Kahadb persistent messaging and periodically see this WARN in the logs. I don't see any specific errors that result from this, but am wondering what the side effects of this are, etc. My consumer is a Camel (2.7.1-fuse-00-27)

Re: Delete all items from queue with same Message Groups id

On Tue, 2012-08-07 at 11:32 +0300, Umut Kocasaraç wrote: > Hi everyone, I am adding some item on active mq queue with message group id > (JMSXGroupID). When someting goes wrong on queue consumer i would like to > delete all items with same message group id. > > For example i have one queue and i

Delete all items from queue with same Message Groups id

Hi everyone, I am adding some item on active mq queue with message group id (JMSXGroupID). When someting goes wrong on queue consumer i would like to delete all items with same message group id. For example i have one queue and i have added 5 items to it. Message id =1 *Message Group id = 1 Messa

Delete all items with same Message Groups id

this message in context: http://activemq.2283324.n4.nabble.com/Delete-all-items-with-same-Message-Groups-id-tp4654808.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Message groups interleaving

Thank you. -- View this message in context: http://activemq.2283324.n4.nabble.com/Message-groups-interleaving-tp4084534p4111815.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Message groups interleaving

Hi, Having multiple message groups producers and multiple async consumers, would it be correct to anticipate that a single consumer may get the messages received being interleaved from different groups of messages? Example: - msg producer P1 sends a group of 2 msgs: P1.1 and P1.2, while at the

Re: Fwd: Message groups enhancement feature request

BTW. we have open feature request for the broker rebalance message groups when consumers are added/removed ( https://issues.apache.org/jira/browse/AMQ-2106). I think that's the best way to handle this use case. In any case, any contribution in this area is welcomed. Regards -- Dejan Bo

Re: Fwd: Message groups enhancement feature request

Hi, > So it sounds like the current Message Groups behaviour is fine; its > just you want to ensure fair load balancing of the message groups > across consumers right? So if lots of other clients are restarted; the > long running clients could end up claiming too many of the mess

Re: Fwd: Message groups enhancement feature request

Hi, On Fri, Jul 1, 2011 at 4:00 PM, boday wrote: > Martin, message groups (by design) guarantee that only a single consumer will > process messages for a group at a time. Yes, I am aware of that. My problem at the moment is only, that it will always be the SAME consumer processing the m

Re: Fwd: Message groups enhancement feature request

So it sounds like the current Message Groups behaviour is fine; its just you want to ensure fair load balancing of the message groups across consumers right? So if lots of other clients are restarted; the long running clients could end up claiming too many of the message groups? I wonder if just

Re: Fwd: Message groups enhancement feature request

Martin, message groups (by design) guarantee that only a single consumer will process messages for a group at a time. It preserves ordering of related/group messages by single threading their processing while still allowing concurrent processing of the queue as a whole (each group has it'

Re: Fwd: Message groups enhancement feature request

Hi, My issue is that in a dynamically load-balancing scenario with scaling the number of consumers up/down, long-living consumers will tend to gather all available message groups and newly created won't have anything available. Even if a newly created consumer gets a new message group, it

Re: Fwd: Message groups enhancement feature request

/2010/09/activemq-message-groups.html Either way, I'd think this could be a feature of the message groups. Basically let you specify a frequency (either elapsed time or message count) to force a new consumer for a group. Would serve to better randomize the load across consumers to protect ag

Fwd: Message groups enhancement feature request

Hi, we currently use message groups to ensure ordered delivery of messages within a given group. As noted on the documentation for message groups, this often does not scale very well with variable consumer counts, as in this case the oldest consumers will hog all message groups. In our use-case

Re: Load balancing message groups

Same issue, except I'm using ActiveMQ 5.5. And even with consumer.prefetchSize=1, I still have messages for all group IDs being sent to consumers on only one of the JVMs. Even more intriguing, if I let the whole thing run for a longish period, I *do* see some or all of the message g

Re: Message Groups and Group Sequence -1

nd if the messages with -1 gets processed last. > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-Groups-and-Group-Sequence-1-tp3035034p3035034.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >

Message Groups and Group Sequence -1

I am using message groups with ActiveMQ 5.4.1 and when ending the group I'm seeing some odd behavior. I run two consumers on Queue A. There is a 200ms delay when processing a message. I have a producer send 100 messages with group A to the broker with the last having a group sequence

Re: get message groups owned by a consumer

anning.com/snyder/ Blog - http://www.nighttale.net On Tue, Oct 5, 2010 at 3:46 PM, marco crivellaro wrote: > > Is there a way to get the message group (s) currently owned by a consumer? > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/get-message-g

Message Groups and ActiveMQ network of brokers

Hi, I found an old message on this mailing list stating: >>I don't want to load balance across brokers; I want sticky load balancing >>across consumers, with failover. I have a network-of-brokers. The message >>groups documentation (http://activemq.apache.org/message-gr

Message Groups under failover

I have questions surrounding message groups and their behaviour under failover: My configuration: * 2 brokers (A & B) connected to each other using a network connector. Both brokers define a queue called TEST_Q. * BrokerA and BrokerB have their own slave broker (SlaveBrokerA and SlaveBro

Re: Activemq-cpp and Message Groups malfunction

before, this doesn't happen always, it is random. I don't understand why nobody else sees this problem. Maybe it has to do with opening and closing a lot of Message Groups? Atte., Luis Rojas -- View this message in context: http://old.nabble.com/Activemq-cpp-and-Message-Groups-malfunct

Re: Activemq-cpp and Message Groups malfunction

b administration tool for ActiveMQ and also with a sniffer, between messages sent from a Java client and from a C++ client, to be sure that they are the same, and this problem happens only with the C++ client. We thought that this could be related to the hash algorithm used in AMQ for Message groups (th

Re: Activemq-cpp and Message Groups malfunction

On Tue, 2009-12-01 at 05:57 -0800, kalki70 wrote: > > > kalki70 wrote: > > > > Hello, > > > > We are having a problem when using Activemq-cpp (version 2.2.6). This > > problem happens with Stomp and Openwire. > > We create thousands of message gr

Re: Activemq-cpp and Message Groups malfunction

kalki70 wrote: > > Hello, > > We are having a problem when using Activemq-cpp (version 2.2.6). This > problem happens with Stomp and Openwire. > We create thousands of message groups dynamically : Create a message > group, send several messages, close message group

Activemq-cpp and Message Groups malfunction

Hello, We are having a problem when using Activemq-cpp (version 2.2.6). This problem happens with Stomp and Openwire. We create thousands of message groups dynamically : Create a message group, send several messages, close message group. The producer is a C++ application, the consumer is two

message groups with exception handling

I'm using AMQ message groups with ServiceMix 3.3.1 and Camel 2.0.0... thanks - Ben - Senior Consultant -- View this message in context: http://www.nabble.com/message-groups-with-exception-handling-tp25350435p25350435.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

message groups with concurrent consumers

how do I set the concurrnetConsumer/maxConcurrentConsumer properties when using message groups? For example, if I set the maxConcurrentConsumers to 10 and I send messages with 100 different JMSXGroupIDs...will the consumers be created/destroyed as necessary or does a single consumer get reused

ActiveMQ 5.3/JBoss 4.2.2 and Message Groups

I am testing ActiveMQ 5.3 SNAPSHOT build from July 25th to get the message group fix (AMQ-2016). When I test message groups with a simple read/write test programs, it seems to work as advertised. However when I try to use the same version of 5.3 using an MDB in jboss 4.2.2, it doesn't se

Re: Automatic recovery when using Message Groups

ceive any more messages. So what I proposed was something like the > consumer saying : > "Hey, I crashed, but I came back. Give me back the message groups I had > before. By the way, last time I subscribed my consumer id was x". > > The feature you mention, that when a new c

Re: Automatic recovery when using Message Groups

like the consumer saying : "Hey, I crashed, but I came back. Give me back the message groups I had before. By the way, last time I subscribed my consumer id was x". The feature you mention, that when a new consumer subscribes, the broker tries to distribute evenly the messages group

Re: Automatic recovery when using Message Groups

i70 wrote: > > Hi, Dejan, > > My opinion is that the functionality of Message Groups is partially broken > if there is no automatic recovery. What should the user do? Restart > ActiveMQ > ? :-( > I don't think it is so hard to implement. Upon subscription the consumer > co

Re: Automatic recovery when using Message Groups

Hi, Dejan, My opinion is that the functionality of Message Groups is partially broken if there is no automatic recovery. What should the user do? Restart ActiveMQ ? :-( I don't think it is so hard to implement. Upon subscription the consumer could be informed its consumer id, which can

Re: Automatic recovery when using Message Groups

Hi Luis, unfortunately there is no way for the consumer to recover its previous message groups. I'm not sure how this could be implemented, since the consumer will have a new consumer id upon recovery, so it would be impossible to relate it to the previous subscription. Cheers -- Dejan Bo

Automatic recovery when using Message Groups

Hi, I have been looking at this feature, that so far looks great for our applications. If I have several consumers, messages with specific JMSXGroupId are routed to the same consumer. If a consumer fails, its message groups are now reassigned to a different consumer, so the service keeps working

Re: NMS and message groups

Hopefully, it is working now. It definitely wasn't before, though. I'm OK with leaving the NMSXGroupID as-is for now. It can be set on the IMessage interface now, so the functionality is there. On Wed, Aug 27, 2008 at 7:52 AM, James Strachan <[EMAIL PROTECTED]>wrote: > 2008/8/27 Jim Gomes <[EM

Re: NMS and message groups

iew=markup > > We should raise a JIRA for this > > 2008/8/25 Marko111 <[EMAIL PROTECTED]>: > > > > Hi everyone, > > > > I am having a problem with message groups. Can someone please send me an > > example of how to use message grouping feature with NMS. I

Re: NMS and message groups

2008/8/27 Jim Gomes <[EMAIL PROTECTED]>: > Hi James, > > There was an implementation gap on this area. I refactored this area of the > code. Feel free to look over it to make sure I did things right. I wanted > to make the IMessage.Properties transparent to use and interchangeable with > the Set

  1   2   >