Re: Messages are stuck in ActiveMQ 5.11 and delivered for after more than 24 hours

2017-06-21 Thread Tim Bain
The most effective way I know to determine what a Java process is doing when I can't step through with a debugger is to use a CPU sampler (JVisualVM ships with the Oracle JDK and can attach either locally or from a remote machine via JMX and RMI) to capture where the time is being spent. Let it cap

Re: ActiveMQ Artemis: failure cause of DLQ messages

2017-06-21 Thread vishal3007
As you are reading the message in a transaction, then rolling back the transaction will send the message to the original queue which will eventually move the message to the DLQ after configured attempts. if you don't want to move the message to DLQ, then the only way which I can see that don't conf

Message grouping and MQTT

2017-06-21 Thread Stuart Small
I'm evaluating ActiveMQ for a new application I am building. Message grouping is the feature that has brought me to ActiveMQ and it looks perfect for what I want. The only problem is that I'm constrained to only using MQTT. It's unfortunately but sadly it is a hard requirement. The state of AMQ

Messages are stuck in ActiveMQ 5.11 and delivered for after more than 24 hours

2017-06-21 Thread sravan
Our batch processing applications process abut 10 Billion messages a day. >From past two months we have been experiencing an issue with ActiveMQ where ActiveMQ delivers messages very late, sometimes messages are delivered 3 days later. Daily, in the worst case 5% (and mostly 1%) of messages are de

Re: High swap usage and network timeouts during heavy publishing

2017-06-21 Thread Abhinav2510
In ActiveMQ 5.13.2 . -- View this message in context: http://activemq.2283324.n4.nabble.com/High-swap-usage-and-network-timeouts-during-heavy-publishing-tp4661946p4727692.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: High swap usage and network timeouts during heavy publishing

2017-06-21 Thread Clebert Suconic
Is that activemq or activemq artemis? what version? On Wed, Jun 21, 2017 at 9:16 AM, Abhinav2510 wrote: > Tim Bain wrote >> How much memory is your ActiveMQ process using, compared to the amount of >> RAM on your host? Could the swap simply result from the JVM being allowed >> to grow larger than

Re: PGP signature of activeMQ distribution: bad signature

2017-06-21 Thread John D. Ament
Did you import the key? https://github.com/apache/activemq/blob/master/KEYS#L273 Looks like two of them in there. John On Wed, Jun 21, 2017 at 1:56 PM hunterbdb wrote: > I'm trying to verify if this is happening for everyone or just me. > > pgp activemq.tar.gz.sig > gpg: Signature made Tue 11 A

PGP signature of activeMQ distribution: bad signature

2017-06-21 Thread hunterbdb
I'm trying to verify if this is happening for everyone or just me. pgp activemq.tar.gz.sig gpg: Signature made Tue 11 Apr 2017 03:57:47 PM UTC using DSA key ID BACB8793 gpg: BAD signature from "Dejan Bosanac " WARNING: Bad signature, doesn't match file contents! -- View this message in context:

Re: When are messageConsumed, messagePull and messageDelivered methods of BrokerFilter executed?

2017-06-21 Thread Timothy Bish
On 06/21/2017 12:05 PM, niwa.sama wrote: Hi I have another question and i hope that you can help me. I need to interrupt the process and re-apply the interceptor to one message (or may be create and send a new message with same data) in some point of the process (for example in preProcessDispat

Re: When are messageConsumed, messagePull and messageDelivered methods of BrokerFilter executed?

2017-06-21 Thread niwa.sama
Hi I have another question and i hope that you can help me. I need to interrupt the process and re-apply the interceptor to one message (or may be create and send a new message with same data) in some point of the process (for example in preProcessDispatch method) if that message have setted some

Re: StorePercentUsage not reported when running Broker embedded

2017-06-21 Thread art.licis
Yes, that was my mistake -- now it works. Thank you! -- View this message in context: http://activemq.2283324.n4.nabble.com/StorePercentUsage-not-reported-when-running-Broker-embedded-tp4727662p4727669.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: StorePercentUsage not reported when running Broker embedded

2017-06-21 Thread Gary Tully
there are some smarts in xbean that set the persistence adapter reference for the storeUsage. I think in your case that link is lost. Start with: SystemUsage usage = org.apache.activemq.broker.BrokerService#getSystemUsage then make your mods to the members in that and there necessary associations

Re: When are messageConsumed, messagePull and messageDelivered methods of BrokerFilter executed?

2017-06-21 Thread Timothy Bish
On Tue, Jun 20, 2017 at 6:36 PM, niwa.sama wrote: > I am developing a plugin to control the number of messages that AMQ can > handle in a fix time, but, i don't know when the mentioned methods are > executed. I run many tests, but in none i can see that the methods are > executed. Can any one ple

StorePercentUsage not reported when running Broker embedded

2017-06-21 Thread art.licis
Hi All, I'm pretty new to ActiveMQ. I'm trying to make a demo with resource usage notifications, and therefore was looking into stats one can read from JMX MBeans. In my demo I'm creating a simple fast producer to write to queue and leave it running without consumers (memory and store limits are s

Re: High swap usage and network timeouts during heavy publishing

2017-06-21 Thread Abhinav2510
Tim Bain wrote > How much memory is your ActiveMQ process using, compared to the amount of > RAM on your host? Could the swap simply result from the JVM being allowed > to grow larger than the amount of physical memory available? > > Tim > > On Tue, Jun 20, 2017 at 3:11 PM, Abhinav2510 < > abhin

Re: ActiveMQ Artemis: failure cause of DLQ messages

2017-06-21 Thread adaprior
Thanks, Vishal. I am not sure how to handle this situation -> I am currently listening messages from active mq with the transaction and on bad data in the message body, rollback of DB has to be done but the message should be sent to a new queue in the same transaction. throwing an exception sends b

Re: Persistent queue storage area

2017-06-21 Thread Tim Bain
You don't program KahaDB. You run an ActiveMQ broker that knows how to write to and read from KahaDB, and then you publish messages to a queue on that broker via the ActiveMQ CMS library, and the broker will write them to KahaDB. Tim On Jun 21, 2017 2:07 AM, "giox79" wrote: > Hi Tim. > Thank yo

Re: Persistent queue storage area

2017-06-21 Thread giox79
Hi Tim. Thank you for your useful help. I think that the suggested approach is the right one. I was searching for something similar but I wasn't able to find it. However I don't understand how to configure programmatically the KahaDB (I'm programming in C++). The example in: http://activemq.apach