Calling end on TransactionContext hangs during failover when using master slave

2017-01-05 Thread JordanC
I have a clustered J2EE application that starts up a broker on each node using failover protocol and a shared data directory. Node 1: Starts up a broker and creates a transport connector at tcp://:61616. Consumer and producer connect via a broker url of failover:(tcp://:61616,tcp://:61617) Node 2

How does when set the duplex parameter when configuring the broker with a URL?

2017-01-05 Thread exabrial
Hey guys, if I want my network connections to be duplex, is it possible to set that parameter using the broker URL? I tried this, which does not work:broker:(vm://localhost,network:static:tcp://localhost:61616?duplex=true)?persistent=false which tells me: WARNING: Could not connect to remote URI:

Re: Artemis 1.5.1 clustered consumer not receiving messages in specific circumstances

2017-01-05 Thread Justin Bertram
Here's what was happening when redistribution was disabled: 1) Message is sent to artemis.node.1 2) Message stays on artemis.node.1 because there are no consumers on any node in the cluster and because 1 message isn't enough to trigger round-robin message load-balancing (assuming it's enable

ActiveMQ Trigger Monitor for As/400

2017-01-05 Thread Amit
We are looking at the options to use Apache's ActiveMQ on our AS/400 systems. However we are not sure if it's possible to trigger a rpg app\program on AS/400 based on a message arrival in a queue. The forums\articles I have found so far seems to indicate that messages need to be pulled from queues

Re: can not delete specific message from activemq queue

2017-01-05 Thread Timothy Bish
Believe you need to add the 'ID:' to the message ID and also use quotes around the ID string. On 01/04/2017 05:44 PM, tk0485 wrote: I'm trying to get list of all messages I have in activeMQ queue using java and delete one of the messages based on their ID. My code looks like the following:

Re: Unable to launch ActiveMQ v5.14.3 with Jetty

2017-01-05 Thread xabhi
Looks like it is due to Jetty upgrade in ActiveMQ version and SelectChannelConnector seems to have been removed in new jetty version ( http://stackoverflow.com/questions/36788049/selectchannelconnector-alternative-class-in-jetty-9-and-above

Re: Artemis 1.5.1 clustered consumer not receiving messages in specific circumstances

2017-01-05 Thread Maciej Gałkowski
Damn, you are right. I did confuse and I had explicitly set 0, and while this is correct setting for my use case, i ovelooked that is by default set to -1. Thank you very much for the quick reply. I just verified that enabling redistribution fixes the problem. 2017-01-05 15:41 GMT+00:00 Ju

Re: Artemis 1.5.1 clustered consumer not receiving messages in specific circumstances

2017-01-05 Thread Justin Bertram
Can you provide your broker configuration? It sounds to me like you don't have message redistribution enabled. What happens if you start the STOMP consumer on artemis.node.2 and then send a message to artemis.node.1? Justin - Original Message - From: "Maciej Gałkowski" To: users@act

Re: Unable to launch ActiveMQ v5.14.3 with Jetty

2017-01-05 Thread xabhi
Below is the minimum configuration required to reproduce this problem. I am using these files will freshly extracted ActiveMQ v5.14.3 with no changes. I am not sure what is missing as this works fine with v5.11.1 with below command: ~/apache-activemq-5.11.1/bin/activemq console xbean:/u/choudhab/a

Artemis 1.5.1 clustered consumer not receiving messages in specific circumstances

2017-01-05 Thread Maciej Gałkowski
I have set up a two node Artemis 1.5.1 cluster, precreated a persistent queue (jms.queue.testqueue) on both nodes. Starting both instances, they form a cluster. 1.Using STOMP protocol I send a message to the aretmis.node.1 2. I start STOMP consumer on artemis.node.2, not receiving anything 3. I st

Unable to launch ActiveMQ v5.14.3 with Jetty

2017-01-05 Thread xabhi
Hi, I am trying to use new version of ActiveMQ v5.14.3 but i am not able to launch it with embedded jetty server of AJAX. The same setup is working for ActiveMQ v5.11.1 without any issues: The jetty version in 5.11.1 is v8.1.16.v20140903. *Java command for v5.14.3:* Java Runtime: Oracle Corporati