Re: How to use destination wildcards to match a common suffix

ooh - that's nice. On 11 April 2015 at 11:32, Martin Lichtin wrote: > Hi James, yes that'd be a great extension, and I could easily adjust my > naming convention to make use of it. > > > On 11.04.2015 12:01, James Carman wrote: > >> Martin, >> >> Does this satisfy what you're looking to do: >> >

Re: DOS attack on activemq setup

Can't find it in the docs - will fix when I get a chance; Basically the properties on the TransportConnector are: maximumConsumersAllowedPerConnection and maximumProducersAllowedPerConnection You can set them on the TransportConnector (used by the Broker) e.g. url = "tcp://localhost:61616?maximu

Re: ActiveMQ 5.9.1 +MQTT

Yikes - WS got missed want to raise a jira? On 7 May 2014, at 03:43, surfnerd wrote: > Hi, > Actually link stealing doesn't work for MQTT + Webscokets. > Simple testing: > Connect with MQTT WS client library ( Eclipse Paho) and connect-disconnect > multiple times. > It will give error of client

Re: Non persistent Messages Not getting expired even after expiration time exceeded

It depends on when the durable subscription went offline - but its difficult to know what the real problem is - without a test case :) On 23 Apr 2014, at 20:00, artnaseef wrote: > Should non-persistent messages even be stored in an offline durable > subscription? > > > > -- > View this mess

Re: Non persistent Messages Not getting expired even after expiration time exceeded

non-persistent messages, if off lined to tmp storage, won’t be expired until they are scheduled for dispatch. If you could, raise an enhancement issue [1], giving as much detail as possible? [1] - https://issues.apache.org/jira/browse/AMQ On 23 Apr 2014, at 11:53, khandelwalanuj wrote: > It's

Re: Non persistent Messages Not getting expired even after expiration time exceeded

Is the message non-persistent or are you sending a persistent message to a broker with a non-persistent (in memory) message store? On 23 Apr 2014, at 07:55, khandelwalanuj wrote: > Did anyone get a chance to look at this. > > > > -- > View this message in context: > http://activemq.22833

Re: activemq anywhere example

sorry - I don’t quiet follow ? - are you looking for example code ? On 7 Mar 2014, at 16:37, gadido30 wrote: > Hi All, > > Is there possible to send or receive messages between mqtt server to > activemq with: > > https://github.com/rajdavies/activemq-anywhere-example > > Thank You > Gadi > >

Re: what's the status of activemq real time?

On 25 Feb 2014, at 09:31, Li Li wrote: > what's the status of this sub project? is there any real world use > case? what's the desgin difference compared to non-realtime version? The purpose was to to do peer-to-peer messaging, and to try out different reliable multicast implementations. The p

Re: Message Dequeue count in jconsole 0 even after messages are recieved and consumed by subscribers

thanks! On 10 Jan 2014, at 07:45, xabhi wrote: > https://issues.apache.org/jira/browse/AMQ-4965 > > > Thanks, > Abhi > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-Dequeue-count-in-jconsole-0-even

Re: Statistics Question

On 8 Jan 2014, at 19:42, uromahn wrote: > jconsole reports the exact same number, so no issue there. > > I re-ran my tests and checking the statistics immediately after the run was > completed.The statistics make more sense now with the definition you > provided. The average enqueue time is con

Re: [ActiveMQ]How to setup fault-tolerant consumer node?

Probably the easiest thing to do would be to use exclusive consumers - see http://activemq.apache.org/exclusive-consumer.html On 13 Dec 2013, at 09:18, cngamer wrote: > I have a consumer node that consumes messages from a ActiveMQ topic server, > and I want to add a backup consumer node in case

Re: Activemq health

If you can use JMX there’s a HealthView MBean associated with the broker - which summarises things like memory usage, disk space usage, Queues with no consumers etc. On 13 Dec 2013, at 05:57, Rodrigo Ramos wrote: > Hello everybody > > > Im starting with activemq. I have been reading about ho

Re: It seems that leveldb encounter some error and broker could not work normally

Could you please raise a jira so we can track this ? https://issues.apache.org/jira/browse/AMQ On 28 Nov 2013, at 06:43, HellKnight wrote: > I installed activemq 5.9.0 as windows service under windows server 2008 r2 > and use leveldb persistence. My coworker stopped the service and restarted >

Re: Query regarding OpenWire/STOMP/AMQP

There’s no reason that there aren’t other clients for OpenWire other than we hadn’t got round to it (there’s been little demand for it as we’ve has STOMP - so its not as if there hasn’t been at least some connectivity). As ActiveMQ now supports AMQP 1.0 - it would make sense to utilise clients t

Re: what does "Replaying recovery log" mean? Embedded broker

Your using Apollo ? This is part of the recovery process for the message store of the broker - though not sure why its getting replayed - unless you are using a hard shutdown on the broker - in which case this is normal, and is done to ensure the message store is in a consistent state on start u

Re: Does AMQ have built-in routing?

Have a look at ActiveMQ 5.9 and the Broker Camel Component - see http://activemq.apache.org/broker-camel-component.html On 12 Nov 2013, at 16:24, salemi wrote: > Hi All, > > > We have 160 queues and each of them is connected to a consumer. We would > like to distribute the incoming messages a

Re: Message Expiration thorugh broker

The broker camel component should make it easier to do - see http://activemq.apache.org/broker-camel-component.html On 7 Nov 2013, at 14:59, Sophia Wright wrote: > Thank you Gary :) > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-Expiration-tho

Re: Message Expiration thorugh broker

Inactive destinations will only be deleted if there aren't any messages awaiting delivery - so could only be used in conjunction with messages getting expired. What problems are you seeing with the TimeStamp plugin ? On 21 Oct 2013, at 15:57, Sophia Wright wrote: > Thanks for the reply, > >

Re: Rebalance not working in 5.8.0

OK - so can you raise an issue for this thanks! Rob On 17 Oct 2013, at 02:31, waydena wrote: > See Broker 1 config file attached. > > activemq.xml > > > > > -- > View this message in context: > http://activemq.2283324.n4

Re: Rebalance not working in 5.8.0

sorry I can't see the config - can you add as an attachment ? On 17 Oct 2013, at 02:17, waydena wrote: > Yes (as per xml in original post (is there a better way to post this?)): > > > > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Rebalance-not-worki

Re: Rebalance not working in 5.8.0

So you've enabled updateClusterClients rebalanceClusterClients and updateClusterClientsOnRemove on the transport connector on both brokers in the broker config ? On 17 Oct 2013, at 02:03, waydena wrote: > Yes the brokers are networked. The failover works - just not the rebalance... > > Broker

Re: Rebalance not working in 5.8.0

so are the brokers connected (have a network connector between them?) On 16 Oct 2013, at 22:25, waydena wrote: > On reflection we may not have had this working in 5.4 - the clients connected > split across the two brokers on initial start-up because we still had both > brokers configured in the

Re: Use case of http transport connector

On 7 Oct 2013, at 16:31, Steven Turner wrote: > In addition to below post I also want to add some queries while using http > transport. > > 1. The HTTP transport is used to tunnel over HTTP(hypertext transfer > protocol) using XML payloads. http transport uses openwire, which operates > in bina

Re: Use case of http transport connector

the HTTP protocol is used for HTTP Tunnelling - to allow messaging through NATs, Proxies, firewalls etc which restrict communication to HTTP only - see http://en.wikipedia.org/wiki/HTTP_tunnel On 7 Oct 2013, at 13:38, Steven Turner wrote: > Hi, > > I am currently running my broker with TCP t

Re: How to generate slow consumers.

Its going to be difficult to setup a slow consumer with request/reply because you are limiting the rate at which messages are produced. A consumer is slow if can't keep pace with producer(s). What I would suggest you do is change your test a little, have your producer send messages asynchronousl

Re: Too many advisories topics created in ActiveMQ

n CPU up* >> You could use a temp queue per processing unit and handle a lot of messages >> (This is nice for pub/sub) >> You could use one queue and a bit of instanceof code (It looks a bit crufty >> but it is very functional) >> >> >> On Oct 9, 2013, at

Re: Too many advisories topics created in ActiveMQ

oks a bit crufty > but it is very functional) > > > On Oct 9, 2013, at 11:05 PM, Robert Davies wrote: > >> What you have described is a bit of an anti-pattern - there's some >> guidelines here in the faq: >> http://activemq.apache.org/how-should-i-implement-

Re: Too many advisories topics created in ActiveMQ

What you have described is a bit of an anti-pattern - there's some guidelines here in the faq: http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html Its an anti-pattern because there is a lot of broker side over head with creating temporary destinations and consumers (

Re: JMS message group + selectors

I presume you mean message groups ? That's going to be a good thing to do if it is. On 12 Aug 2013, at 20:44, salemi wrote: > Hi, > > I am planing to use JMS message group in conjunction for selector. Has > anybody done it before? > > If I use both does it have performance implications of the

Re: AMQP Bridge

As I said - have a look at https://github.com/rajdavies/activemq-anywhere-example - it uses JMS over AMQP 1.0 with Camel On 12 Aug 2013, at 16:26, RJPercival wrote: > Unfortunately, a quick search reveals that Camel does not yet support AMQP > 1.0 (https://issues.apache.org/jira/browse/CAMEL-

Re: AMQP Bridge

You can look at https://github.com/rajdavies/activemq-anywhere-example for examples of setting up the Camel routes On 12 Aug 2013, at 15:58, RJPercival wrote: > No, the remote broker isn't guaranteed to be ActiveMQ so the bridge has to be > over AMQP 1.0 rather than OpenWire. I'll look into usi

Re: ActiveMQ crashes frequently

Ultimately I'm pretty confident this problem is an NFS problem - and as Johan has already let the cat out of the bag ;) - let me ask the following: Which version of NFS 4 are you using and which environment? Have you checked the system logs for NFS errors on all the machines running ActiveMQ

Re: ActiveMQ crashes frequently

Hi Mark, could you produce a test case for your problem - it would help us identify the problem a lot quicker thanks, Rob On 30 Apr 2013, at 16:40, fenbers wrote: > Zagan wrote >> Can you please check if your .log files in the /data directory are cleaned >> up? On basis of the information I s

Re: Memory leak??

I think we will need to see the client code to see if there's anything obviously wrong with the use of Temp Destinations On 29 Apr 2013, at 21:21, SledgeHammer wrote: > Hmm... I switched the response queue to be a "permanent" queue and it looks > like it doesn't have the same memory leak issue.

Re: Cleaning up queues...

1. set a timeToLive on your messages http://activemq.apache.org/how-do-i-set-the-message-expiration.html - this means that if the producer crashes, the messages will get cleaned up at some point 2. Enable gc on destinations - http://activemq.apache.org/delete-inactive-destinations.html - which

Re: Batching messages for better compression?

There's been some discussion on batches for JMS2 - see http://java.net/jira/browse/JMS_SPEC-36 On 14 November 2012 21:13, Gary Tully wrote: > Auto batching does not exist at the moment but it would be a nice > enhancement. > ie: configure some sort of client side pause time or size limit so > th