Re: Delete/Purge Topic

The topic deletion URL you found sounds like it should work, though it's not something I've ever played with. Does it work as expected for you? The command line tools have a way to purge messages from a destination (see the purge task at the bottom of http://activemq.apache.org/activemq-command-li

Re: Duplicate messages received with ActiveMQ 5.13.2

Wait, there are multiple transport connections between A and B? Why? That right there seems like a problem, and might be the root cause of the behavior you're seeing. The code I see in that processBrokerInfo() method creates the inverse side of the duplex network connection (under the hood it's no

Re: Programatically setting up a proxying broker

OK, no subscriber on the proxy broker certainly explains why no messages are making it to the main broker, so let's dig into that. Do you see (via JMX) a networkConnector between the two brokers? And do you see advisory messages passing from the main broker to the proxy when a subscriber connects?

[ANNOUNCE] ActiveMQ Artemis 2.2.0 Released

I'm pleased to announce the release of ActiveMQ Artemis 2.2.0. For a complete list of updates: http://activemq.apache.org/artemis/release-notes-2.2.0.html Thanks a lot for all who contributed on this extensive release: I checked on status.apache.org along the road of this cut and there was day

Re: Add mqtt protocol to artemis Wildfly

I would recommend you using artemis with mqtt on 2.2.0.. or AMQ. so that is use artemis remotely from wildfly, which would still work. 2.2.0 currently can't be embedded on wildfly (there are some changes to be done on artemis messaging layer). Like the recent bug fix on mqtt.. I don't think it'

Re: Random port listening on 0.0.0.0 for tcp transport

There is a guide on how to define local host and port for Socket. http://activemq.apache.org/how-do-i-define-a-local-address-and-local-port-for-tcp-or-ssl.html This looks little strange together with TcpTransportFactory.createTransport(location,wireformat) method that is parsing the connection str

Re: Exception when connecting simple client to artemis wildfly broker

I posted a question in wildfly forum https://developer.jboss.org/message/974758#974758 . -- View this message in context: http://activemq.2283324.n4.nabble.com/Exception-when-connecting-simple-client-to-artemis-wildfly-broker-tp4729069p47290

Re: Exception when connecting simple client to artemis wildfly broker

This looks like a classloading issue related to your JBoss Modules configuration. I recommend you post your question on the JBoss Wildfly forum. Justin On Mon, Jul 31, 2017 at 9:20 AM, aragoubi wrote: > I am using apache paho to connect a client to artemis wildfly embeded > broker. > I added

Re: Programatically setting up a proxying broker

Still no luck, unfortunately. This is the test program I'm using now: http://ataxia.io7m.com/2017/07/31/ForwardingServers.java I use setDynamicallyIncludedDestinations() with a wildcard topic ">". I still see no subscriptions on the proxy broker from the receiver broker. -- Mark Raynsford | h

Exception when connecting simple client to artemis wildfly broker

I am using apache paho to connect a client to artemis wildfly embeded broker. I added mqtt protocol module. The client connect to the broker via ""tcp://localhost:61616" port. This is the full stacktrace of the exception stacktrace.txt

Re: Duplicate messages received with ActiveMQ 5.13.2

I got a little further today: The reason that conduit does not happen is that even though ConsumerInfos come twice for the same topic, they come over different transport connections and thus come to different bridges. For conduit to happen it must happen within one bridge. Also, I noticed that when

Re: Add mqtt protocol to artemis Wildfly

For clarity's sake I recommend you start a new thread with your interceptor question. Justin On Mon, Jul 31, 2017 at 8:06 AM, aragoubi wrote: > Thank you for your response, yes now it works fine, it was a jars problem. > I begin with artemis, and I would like to know how could I configure my >

Re: Schedule Message Delivery Producer Performance

On 07/31/2017 05:42 AM, MattFaulkner wrote: Hi, I'm looking at using the scheduler for delaying a large number of messages. However, when testing I notice there is a big performance difference between having the AMQ_SCHEDULED_DELAY value and not. I created a simple producer and sent 1 million m

Re: Random port listening on 0.0.0.0 for tcp transport

Thanks pheitman. You already helped me figuring out what the hell is opening this random port on 0.0.0.0. After I stopped the application port gets closed. Have you been able to figure out how to solve this? -- View this message in context: http://activemq.2283324.n4.nabble.com/Random-port-list

Re: Programatically setting up a proxying broker

On 2017-07-31T06:55:07 -0600 Tim Bain wrote: > People do what you're trying to do, so this is a use case that works (or at > least, did work at some point in the past). Right. > My advice when message forwarding isn't working in a network of brokers is > to use JMX to figure out what's going on

Re: Add mqtt protocol to artemis Wildfly

Thank you for your response, yes now it works fine, it was a jars problem. I begin with artemis, and I would like to know how could I configure my broker, for example if I want to add an interceptor in order to intercept connections to broker. Do you have any idea on how to achieve that ? -- Vie

Re: [ActiveMQ-CPP] "backup=true" does not work with failover transport

Tim, Is the following a correct restatement of your response? "The backup feature of the failover transport is known to not work in ActiveMQ-CPP. If you'd like, you can submit a bug in JIRA to request that it be fixed." Tim On Jul 31, 2017 6:53 AM, "Timothy Bish" wrote: > On 07/31/2017 06:41

Re: Programatically setting up a proxying broker

People do what you're trying to do, so this is a use case that works (or at least, did work at some point in the past). My advice when message forwarding isn't working in a network of brokers is to use JMX to figure out what's going on in each broker. I'd start with the proxy broker and confirm th

Re: [ActiveMQ-CPP] "backup=true" does not work with failover transport

On 07/31/2017 06:41 AM, Tamas1 wrote: Thank you for your reply. The library in the application has been replaced to the latest 3.9.4 Release. The behaviour is different but it didn't resolve the problem. I used the following connection URL: failover:(tcp://amq01:61616?soKeepAlive=true,tcp://amq0

Re: Add mqtt protocol to artemis Wildfly

There are 2 files you need to change: wildfly-10.1.0.Final/modules/system/layers/base/org/apache/activemq/artemis/main/module.xml wildfly-10.1.0.Final/modules/system/layers/base/org/apache/activemq/artemis/protocol/mqtt/main/module.xml You also need to drop the following jars into the mqtt/main d

Add mqtt protocol to artemis Wildfly

I want to use mqtt with Artemis activemq. I tried adding a module for mqtt exactely like in this post https://stackoverflow.com/questions/39427558/how-to-work-with-mqtt-in-wildfly. My problem is the same, I can't see the *Adding protocol support for: MQTT* when I start wildfly. I am starting wildfl

Re: [ActiveMQ-CPP] "backup=true" does not work with failover transport

Thank you for your reply. The library in the application has been replaced to the latest 3.9.4 Release. The behaviour is different but it didn't resolve the problem. I used the following connection URL: failover:(tcp://amq01:61616?soKeepAlive=true,tcp://amq02:61616?soKeepAlive=true)?randomize=true

Schedule Message Delivery Producer Performance

Hi, I'm looking at using the scheduler for delaying a large number of messages. However, when testing I notice there is a big performance difference between having the AMQ_SCHEDULED_DELAY value and not. I created a simple producer and sent 1 million messages. WITH delay time taken - 2429 second

Re: Programatically setting up a proxying broker

Hm, is anyone out there actually using ActiveMQ in this manner? The reason I'm doing this is that I'm considering deploying message brokers in a manner analogous to the way in which one would typically deploy mail servers: Programs on a server communicate with an MTA (such as Postfix or qmail) on

Re: Memory leak with apache artemis 2.1.0

the issue is solved in 2.2.0 thanks a lot : -- View this message in context: http://activemq.2283324.n4.nabble.com/Memory-leak-with-apache-artemis-2-1-0-tp4728863p4729051.html Sent from the ActiveMQ - User mailing list