Re: Question about rollbackOnlyOnAsyncException (AMQ-3166)

I'd echo Gary's suggestion that you capture thread dumps or perform sampling during the slow events. That would make it clear where the time is being spent. Tim On Wed, Feb 14, 2018 at 11:16 PM, alprausch77 wrote: > Yes, we use XA transactions. > > I don´t think

Re: Question about rollbackOnlyOnAsyncException (AMQ-3166)

Yes, we use XA transactions. I don´t think that the NIO mixes this up somehow. We can run our system with a standalone ActiveMQ using tcp or nio but also in an embedded mode inside Wildfly using the VM protocol. I just run our tests again with the enableAckCompaction set to false for the kahaDB

Re: [DISCUSS] Using Travis CI for Artemis PR builds

I'm in no way trying to discourage you guys from evaluating Travis CI. However... There are currently 4 builds that are in a failed state on the history of that job: - https://builds.apache.org/view/A/view/ActiveMQ/job/ActiveMQ-Artemis-PR-Build/5111/consoleFull - Failed due to "Could

Re: ActiveMQ and Java 9

I submitted https://issues.apache.org/jira/browse/AMQ-6864 in November to propose that we add default compiler flags to enable ActiveMQ 5.x to work out of the box with Java 9. To date there's been no activity on it. However, my understanding is that enabling access to those internal APIs is simply

Re: Warning "An exception occurred processing JSP page" - keeps filling up log's

This looks similar to https://issues.apache.org/jira/browse/AMQ-6224 and https://issues.apache.org/jira/browse/AMQ-6473 (though neither is on exactly the same since both relate to topics and you're looking at a queue-related page), which are both currently unresolved. So I doubt it's the same

Re: ActiveMQ Artemis Clustering

When 2 nodes are configured for HA (i.e. one is an active "live" and the other is a passive "backup") the clustering configuration only facilities HA. There is no load balancing or message redistribution between a live and a backup. Those features only work between live brokers. Justin On

ActiveMQ Artemis Clustering

Is there a way to set up Artemis clustering just for HA purposes. I don't need server side message load balancing or client side load balancing or message redistribution. Will setting message-load-balancing to off suffice ? Thanks. -- Sent from:

Re: ActiveMQ and Java 9

There are some companies as my one who don't want to run software which is EOL. Therefore we must run Artemis within the next months with Java 10. Am 14.02.18 um 21:05 schrieb Justin Bertram: Out of curiosity, is there a particular reason you want to use Java 9? Justin On Wed, Feb 14, 2018

Re: Scheduling(delayed delivery) a message AMQP.NETLIBRARY broker: ActiveMQ Windows platform C#

On 02/14/2018 07:06 AM, bittusrivastava wrote: Thanks for reply. how to use MessageAnnotation. i tried reading documentation but couldn't find any useful resource. for example if i have to set attribute "x-opt-delivery-delay" how can we do it. Thanks -- Sent from:

Re: ActiveMQ and Java 9

Out of curiosity, is there a particular reason you want to use Java 9? Justin On Wed, Feb 14, 2018 at 1:10 PM, nbhc wrote: > Does ActiveMQ work with Java 9? I tried v5.15.2 and JDK9.0.4, activemq > fails > to start with exception like below: > > java.io.IOException:

Re: Artemis and Python

> Does Artemis support Python client APIs ? The user manual does not say it explicitly, but I want to be really sure Artemis supports the AMQP, MQTT, and STOMP protocols all of which have client implementations in Python. > I understand that no external services are needed - Can someone please

Re: ActiveMQ and Java 9

On 02/14/2018 02:10 PM, nbhc wrote: Does ActiveMQ work with Java 9? I tried v5.15.2 and JDK9.0.4, activemq fails to start with exception like below: java.io.IOException: java.lang.IllegalAccessException: class org.iq80.leveldb.util.ByteBufferSupport cannot access class jdk.internal.ref.Cleaner

Artemis and Python

I am contemplating using Artemis as a message broker. My use case is the following: - Messages are not published at a very high scale. Probably a few thousand messages every minute or so - Need persistent messages with guaranteed delivery - Need a HA solution (There is no shared storage, so will

ActiveMQ and Java 9

Does ActiveMQ work with Java 9? I tried v5.15.2 and JDK9.0.4, activemq fails to start with exception like below: java.io.IOException: java.lang.IllegalAccessException: class org.iq80.leveldb.util.ByteBufferSupport cannot access class jdk.internal.ref.Cleaner (in module java.base) because module

RE: Artemis 2.4.0 message loss in durability tests upon system power-off

We powered off the VM while the producers were kicking and alive, and no one was consuming. Then we tallied for the number of committed messages by the producers. After that we restart the VM, and then restart the broker, and take the queue stats. Then we use the JMS QueueBrowser API to count

RE: Artemis 2.4.0 message loss in durability tests upon system power-off

Hi Martyn, Thanks for your reply. 1) On the disk sync guarantee for the VirtualBox VM I don't know the precise answer, and did not find a good answer when I looked around. So we ran alternate experiments where we mounted a Windows host folder (instead of a virtual disk image) into the VM, and

Re: Question about rollbackOnlyOnAsyncException (AMQ-3166)

XA transactions? normally the transaction is on the session and connection... so any async call will complete before the commit.. unless maybe nio is mixing this up some. do you have some code that will show the rollbackOnlyOnAsyncException case where the tx is null. There is a test case that can

Warning "An exception occurred processing JSP page" - keeps filling up log's

I'm running 2 clusters of 3 ActiveMQ servers version 5.15.1 on Windows Servers in AWS and I keep getting this same Warning over and over it over flows my log's so when we do get an Error it's rolled off the log's before we can look at it. Is there anyone that know how to fix this issue? Note:

Couldn't enable Audit logging in apache-activemq-5.14.0[Windows]

We have updated conf\log4j.properties as ### # Audit log ### log4j.additivity.org.apache.activemq.audit=true log4j.logger.org.apache.activemq.audit=INFO, audit log4j.appender.audit=org.apache.log4j.RollingFileAppender log4j.appender.audit.file=${activemq.base}/data/audit.log

Couldn't enable Audit logging in apache-activemq-5.14.0[Windows]

We have updated conf\log4j.properties as ### # Audit log ### log4j.additivity.org.apache.activemq.audit=true log4j.logger.org.apache.activemq.audit=INFO, audit log4j.appender.audit=org.apache.log4j.RollingFileAppender log4j.appender.audit.file=${activemq.base}/data/audit.log

Re: Artemis 2.4.0 message loss in durability tests upon system power-off

The "messages added" metric for a queue is volatile so when the broker is stopped it will be reset. When the broker is started again the "messages added" will be 0. In your test you say the broker is "powered off" and then you "resume" the broker. What exactly does this mean? It seems clear

Re: Question about rollbackOnlyOnAsyncException (AMQ-3166)

Hello Gary. Thanks for your reply. I already tried the rollbackOnlyOnAsyncException. But this one only works if the transaction still exists when the error in the async send happens. But if the TX is already finished, than there is no such action because the code which looks up the transaction

Re: Question about rollbackOnlyOnAsyncException (AMQ-3166)

in addition, try the latest Artemis release, there has been a bunch of work on latency w.r.t gc on exactly that flat send latency (reliable enqueue) use case. On Wed, 14 Feb 2018 at 14:29 Gary Tully wrote: > transaction commit is a sync operation... if an async send in a >

Re: Question about rollbackOnlyOnAsyncException (AMQ-3166)

transaction commit is a sync operation... if an async send in a transaction fails, then the commit will rollback via: rollbackOnlyOnAsyncException w.r.t spikes in send, have you enabled the preallocation strategy on kahadb, it may be worth toggling to see the effect in your env. Also,

Re: what value of networkTTL need to use for synchronous request and reply in network connectors

In the event of connection failures there is a good chance of loosing messages. If you are about messages and replies then use real queues, maybe have a reply queue per process or per application and use selectors based on the correlation id if you need to multiplex. The lifetime of a temp queue

Re: Trying to send and receive text messages using ActiveMQ with JavaScript (AMQP) and Java (OpenWire/JMS) clients

See the Mapping To JMS section of http://activemq.apache.org/amqp.html for details. (The other) Tim On Feb 13, 2018 6:54 PM, "Timothy Bish" wrote: > On 02/13/2018 07:29 PM, Jeroen van Ooststroom wrote: > >> >> I added the wireFormat.allowNonSaslConnections=true to the AMQP

Re: Scheduling(delayed delivery) a message AMQP.NETLIBRARY broker: ActiveMQ Windows platform C#

Thanks for reply. how to use MessageAnnotation. i tried reading documentation but couldn't find any useful resource. for example if i have to set attribute "x-opt-delivery-delay" how can we do it. Thanks -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis 2.4.0 message loss in durability tests upon system power-off

Hi Anindya, I would be very surprised if messages were lost due to an ActiveMQ Artemis broker issue. We have a lot of very extensive testing around these exact use cases. Could you please check a couple of things: 1. Can you confirm that the same guarantees for disk sync apply to a host VM as

Re: ARTEMIS - Selector modification

Hi Justin, thanks for the response! My current solution is to mark the messages at the publisher side as "for app 1", "for app 2" etc, which kinda defeats the purpose of the publisher being agnostic to subscribers. Perhaps there's another way? Thanks again, Adi -- Sent from: