Re: Destination wildcards or consumer selectors – advice needed

2016-02-18 Thread sburczymucha
Thanks for clarification, I decided to use message selector and it seems that it works as should :) As for page size problem - destination is set to topic and consumer is not durable, message handling is transactional, overall this should not be a problem. Best Regards, -- View this message in

Destination wildcards or consumer selectors – advice needed

2016-02-02 Thread sburczymucha
Hello, I'm seeking advice on the preferred way to solve following problem: I have “n” consumers which needs to subscribe to a non-durable topic(?), from that topic each consumer needs to receive “global” messages (messages for all clients) and messages for that specific consumer. I was thinking

Re: Active NMS - ISession and transaction listeners - how do I get TransactionId

2015-12-22 Thread sburczymucha
Hello, I think that this is due to setting TransactionId to null just before calling Listeners: https://svn.apache.org/repos/asf/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/TransactionContext.cs Method Rollback() and Commit(): this.transactionId = null; I'm not

Active NMS - ISession and transaction listeners - how do I get TransactionId

2015-12-19 Thread sburczymucha
Hello, I'm using Active NMS and I would like to log some information (e.g. Transaction ID) about currently processed transaction. It seems that I can use transaction listeners: TransactionStartedListener, TransactionCommittedListener and TransactionRolledBackListener but I'm having a problem with

Re: NMSXGroupID problem - two different consumers received message for one group

2015-12-19 Thread sburczymucha
Yeah, it seems that https://issues.apache.org/jira/browse/AMQ-3027 is describing exactly the same problem I'm having. Thank you for clarification! Best Regards, -- View this message in context: http://activemq.2283324.n4.nabble.com/NMSXGroupID-problem-two-different-consumers-received-message

Re: NMSXGroupID problem - two different consumers received message for one group

2015-12-17 Thread sburczymucha
Tim Bain wrote > Are all messages being immediately consumed, or is there a backlog of > messages for a given message group when you close the message group? I > would expect the message group to be closed immediately when the message > with NMSXGroupSeg=-1 is sent (not when it is consumed), so if

NMSXGroupID problem - two different consumers received message for one group

2015-12-17 Thread sburczymucha
Hello, I have a strange problem with message groups and multiple consumers - I've noticed several cases when message with the same NMSXGroupID was received by two different consumers, I'm not sure if this is my fault or some other edge case. How can I debug this? My setup: 1. Each consumer has o

Re: Prefetch, message consumer async listener and message grouping, transactions & clustering - how does it work?

2015-09-23 Thread sburczymucha
Hmmm, I think I got it ;) Thanks for clarification! Best Regards, -- View this message in context: http://activemq.2283324.n4.nabble.com/Prefetch-message-consumer-async-listener-and-message-grouping-transactions-clustering-how-does-it-wo-tp4702096p4702231.html Sent from the ActiveMQ - User mai

Re: Prefetch, message consumer async listener and message grouping, transactions & clustering - how does it work?

2015-09-19 Thread sburczymucha
Hello, That depends, I can't guarantee that both consumers will be connected. In worst case scenario only one consumer will be connected, and will consume messages with JMSXGroupID = 1 then with JMSXGroupID = 2 (because client is sending JMSXGroupID=-1 every X messages). Best Regards, -- View

Prefetch, message consumer async listener and message grouping, transactions & clustering - how does it work?

2015-09-18 Thread sburczymucha
Hello, I would like to know if I understand how messages are processed in following configuration. Supposed I have a connection with message prefetch = 5, and folowing messages in queue: ID = 1, JMSXGroupID = 1 ID = 2, JMSXGroupID = 1 ID = 3, JMSXGroupID = 2 ID = 4, JMSXGroupID = 1 ID = 5, JMSXGr

Message groups pattern - "late" consumers

2015-01-30 Thread sburczymucha
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 only on