Re: JMS message group + selectors

Everything is a tradeoff. You may wish to come up with specific scenarios and use cases. On Mon, Aug 12, 2013 at 12:44 PM, 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 implica

JMS message group + selectors

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 JMS broker? Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/JMS-message-group-selectors-tp4670296.html S

Re: Problem reading a Queue

What's the size of your heap here? Ultimately, the issue is with the way the broker works with paging in messages and applying the selectors. Selectors are only applied once messages have been paged in from store. So if you have 1000 1MB messages ahead of the message you're interested in, you'll

ActiveMQ RAR - Logging

Hi all I have deployed activemq-rar-5.8.0.rar to a GlassFish 3.1.2.2 instance (in order to connect to a remote broker, as described here http://activemq.apache.org/integrating-apache-activemq-with-glassfish.html). Unfortunately inside the connector is a SLF4J implementation which causes all ot

Messages Stuck In Queue

We are having issues with messages getting stuck in the queue. OS: Windows 2008 Server 64-bit ApacheMQ: 5.8.0 64-bit Connection String: failover:(tcp://{0}:{1})?initialReconnectDelay=3500&wireFormat.tightEncodingEnabled=true&nms.PrefetchPolicy.QueuePrefetch=1 java.exe process memory usage gets to

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

That issue is about the AMQP camel component; the activemq camel component can connect to ActiveMQ through any ActiveMQ client supporting URL On 12 August 2013 16:26, RJPercival wrote: > Unfortunately, a quick search reveals that Camel does not yet support AMQP > 1.0 (https://issues.apache.org/ji

Re: AMQP Bridge

You should be able to use the qpid-jms libs which do support the 1.0 protocol: http://qpid.apache.org/components/qpid-jms/index.html On Mon, Aug 12, 2013 at 8:26 AM, RJPercival wrote: > Unfortunately, a quick search reveals that Camel does not yet support AMQP > 1.0 (https://issues.apache.org/j

Re: AMQP Bridge

Unfortunately, a quick search reveals that Camel does not yet support AMQP 1.0 (https://issues.apache.org/jira/browse/CAMEL-5891). Presumably this makes establishing a bridge over AMQP 1.0 extremely difficult? -- View this message in context: http://activemq.2283324.n4.nabble.com/AMQP-Bridge-tp

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: AMQP Bridge

Sorry, to be more clear, the network of brokers only works for openwire-based protocols. Any other sort of bridging should be done with Camel. Cheers On Mon, Aug 12, 2013 at 7:58 AM, RJPercival wrote: > No, the remote broker isn't guaranteed to be ActiveMQ so the bridge has to > be > over AMQP

Re: AMQP Bridge

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 using Camel instead then, thanks. -- View this message in context: http://activemq.2283324.n4.nabble.com/AMQP-Bridge-tp4670281p4670286.html Sent from the ActiveMQ - U

Re: AMQP Bridge

The remote broker in my test environment is also ActiveMQ so yes, it speaks AMQP 1.0. In production, it's not guaranteed to be ActiveMQ but is guaranteed to speak AMQP 1.0 (hence the requirement to use AMQP instead of OpenWire for the bridge). There is a single warning in the log of the remote bro

Re: Stop and resume message consuming

Take a look here: https://gist.github.com/christian-posta/6211175 Key is to use prefetch == 1 and factory.setAlwaysSessionAsync(true) on the consumer. Cheers, Christian On Mon, Aug 12, 2013 at 5:20 AM, retok wrote: > JmsTest.zip < > http://activemq.2283324.n4.nabble.com/file/n4670280/Jm

Re: AMQP Bridge

The networking bridge will expect speak to openwire (or an openwire-compatible protocol... eg, openwire over HTTP) to another ActiveMQ broker on the other side. Is this your case? If not, try using Apache Camel to bridge the two. On Mon, Aug 12, 2013 at 2:01 AM, RJPercival wrote: > I've been a

Multiple consumer did not receive the message

Hi everone: I used multiple consumer to receive message from a queue .But It did not work correctly.These is message in the queue,But the consumer did not get it.

AMQP Bridge

I've been attempting to configure a static bridge between two brokers (I want any messages received on a local broker to immediately be forwarded to a remote broker if it's available). If I use OpenWire, i.e. a "static:(tcp://1.2.3.4:61616)" URL, it works, but if I change that URL to "static:(amqp:

Re: Stop and resume message consuming

JmsTest.zip I attached an example with a simple broker service, a producer and a consumer. The producer simply sends 30 messages and the consumer does not acknowledge every 3rd message. The effect is, that the first time, message

Re: AMQP Bridge

On 08/12/2013 11:01 AM, Rob Percival wrote: I've been attempting to configure a static bridge between two brokers (I want any messages received on a local broker to immediately be forwarded to a remote broker if it's available). If I use OpenWire, i.e. a "static:(tcp://1.2.3.4:61616)" URL, it wor

AMQP Bridge

I've been attempting to configure a static bridge between two brokers (I want any messages received on a local broker to immediately be forwarded to a remote broker if it's available). If I use OpenWire, i.e. a "static:(tcp://1.2.3.4:61616)" URL, it works, but if I change that URL to "static:(amqp:

AMQP Bridge

I've been attempting to configure a static bridge between two brokers (I want any messages received on a local broker to immediately be forwarded to a remote broker if it's available). If I use OpenWire, i.e. a "static:(tcp://1.2.3.4:61616)" URL, it works, but if I change that URL to "static:(amqp:

Invitation to connect on LinkedIn

LinkedIn ceposta, I'd like to add you to my professional network on LinkedIn. - prabu prabu narayanan Senior software engineer at Opus Software Solutions Chennai Area, India Confirm that you know prabu narayanan: https://www.linkedin.com/e/z2phzj-hk9cou9v-4s/isd/15702071024/7Ve4

Invitation to connect on LinkedIn

LinkedIn ceposta, I'd like to add you to my professional network on LinkedIn. - prabu prabu narayanan Senior software engineer at Opus Software Solutions Chennai Area, India Confirm that you know prabu narayanan: https://www.linkedin.com/e/z2phzj-hk9c954v-2j/isd/15702071024/7Ve4