Help needed. About message loss in distributed queue in network of brokers environment

We have a distributed architecture with two brokers connnected to each other through WAN. We configured it using network of brokers. One producer sends messages to a distributed queue named aqueue on broker A. One consumer consume messages from the queue aqueue on broker B. I thought activemq

is there any way to consume messaes from weblogic JMS using ActiveMQ

I would like to use the ActiveMQ feature Exclusive Consumer in a cluster of weblogic JMS. Is this possible? if yes how to achive it. Thanks. -- View this message in context: http://www.nabble.com/is-there-any-way-to-consume-messaes-from-weblogic-JMS-using-ActiveMQ-tp18378727p18378727.html Sent

Re: Help needed. About message loss in distributed queue in network of brokers environment

I discovered that the message transfer between network of brokers is handled by DemandForwardingBridgeSupport class and there is some comment on async send mode will be assumed between brokers if the producer send the message to the queue using async send mode which will cause small probability

Re: Help needed. About message loss in distributed queue in network of brokers environment

It is sad that the activemq message sending is default to sync send. So this issue is still open. Please provide help! Bryan.Shaw wrote: I discovered that the message transfer between network of brokers is handled by DemandForwardingBridgeSupport class and there is some comment on async

RE: Openwire C client protocol error

Thanks, Nate Yes, we're using a C++ compiler. Openwire C client was one of the alternatives. The other one is CPP but we were a bit afraid about the integration of CPP API code (threading and so) with our event loop. So, we have tried the other one as first choice. Now, we'll have a look to

Re: ActiveMQ Disk usage

andrewh wrote: andrewh wrote: [snip...] https://issues.apache.org/activemq/browse/AMQ-1786 I think I could be experiencing this issue. It is the $ACTIVEMQ_HOME/data/brokername/journal folder that is filling up. Still, any comments on my config are appreciated. Rgds,

Re: is there any way to consume messaes from weblogic JMS using ActiveMQ

On 10 Jul 2008, at 10:04, mallikarjun wrote: I would like to use the ActiveMQ feature Exclusive Consumer in a cluster of weblogic JMS. Is this possible? if yes how to achive it. Thanks. -- View this message in context:

Re: Help needed. About message loss in distributed queue in network of brokers environment

This is currently only the case if you are using duplex connections - or the message was originally sent using async send from the client (e.g. non-persistent) - as the network tries to maintain the same QOS as used by the original producer cheers, Rob On 10 Jul 2008, at 10:34,

Re: ActiveMQ Disk usage

Hi Andrew - will have a look btw - who did you have training with ? cheers, Rob On 10 Jul 2008, at 11:13, andrewh wrote: andrewh wrote: andrewh wrote: [snip...] https://issues.apache.org/activemq/browse/AMQ-1786 I think I could be experiencing this issue. It is the

Re: ActiveMQ Disk usage

Hi Rob, that's much appreciated. The training was with your good selves at IONA :) Best, Andrew rajdavies wrote: Hi Andrew - will have a look btw - who did you have training with ? cheers, Rob -- View this message in context:

bump

bump -- View this message in context: http://www.nabble.com/How-to%3A-Slow-consumers-and-CLIENT_ACKNOWLEDGE--tp18356204p18380884.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

RE: Can any one help me in dealing with duplicating messages for clustered web application

I believe that's the pub-sub behavior. A message on a topic should be sent to all registered subscribers. If you need the message to be processed only once, your should use queues instead. Regards Sachin -Original Message- From: Manish1985 [mailto:[EMAIL PROTECTED] Sent: Wednesday, July

How is the number of Consumers counted ?

Hello, I am using activeMQ for one of our projects where a Java applet is used to consume messages from JMS queues. During our tests, we discovered that the number of consumers for each queue was not corresponding to the number of connected clients but was way higher (not everytime indeed, but

Re: Openwire C client protocol error

FYI, You don't have to use the asynchronous consumers. You can always poll for new messages with a call to receive(). That way the threading shouldn't be an issue for you. Nate On Jul 10, 2008, at 3:10 AM, Joselu wrote: Thanks, Nate Yes, we're using a C++ compiler. Openwire C client

Re: bump

On 10 Jul 2008, at 12:30, bonnyr wrote: bump -- View this message in context: http://www.nabble.com/How-to%3A-Slow-consumers-and-CLIENT_ACKNOWLEDGE--tp18356204p18380884.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. I hate answering questions - with use the

Re: How is the number of Consumers counted ?

On 10 Jul 2008, at 13:01, Borer Reynald wrote: Hello, I am using activeMQ for one of our projects where a Java applet is used to consume messages from JMS queues. During our tests, we discovered that the number of consumers for each queue was not corresponding to the number of connected

Re: Filtering messages in a Network of Brokers

On 10 Jul 2008, at 14:13, Yohan Liyanage wrote: Hi, Is there anyway to filter messages in a network of brokers (Store and Forward) ? For example, is there anyway to avoid forwarding messages which contains a specific property, etc to other brokers? Thanks in advance. -- View this

Re: Filtering messages in a Network of Brokers

You could implement a MessageAuthorizationPolicy. The policy wold allow/disallow messages based on a property. See bottom of this page http://activemq.apache.org/security.html Or a filter message pattern via Camel http://activemq.apache.org/camel/message-filter.html Joe www.ttmsolutions.com

Re: No clientID specified for connection disconnect request

Thanks for the bump and for the work-around! But - turning off async dispatch reduces performance with slow consumers if I understand correctly, so I would prefer having it on. Is there a better solution to this? Is it a bug or do I have bad config somewhere? rajdavies wrote: Great! thx

Need help on the configuration below

Hi I am currently using Active MQ 5.1. I ran the query command I have pasted 2 subscriptions out of it. DispatchedQueueSize = 0 ConnectionId = ID:qa01-44509-1214325055754-0:6 PrefetchSize = 32766 DispachedCounter = 0 DiscardedCount = 0 active = true DequeueCounter = 1 PendingQueueSize = 0

Re: Help needed. About message loss in distributed queue in network of brokers environment

I am not using async send from the client. But, I am using duplex connection because one of the two brokers do not have fixed IP Address. How can I avoid using duplex connnection if only one IP is fixed? rajdavies wrote: This is currently only the case if you are using duplex connections -

Re: No clientID specified for connection disconnect request

Actually async is faster normally - this is a work around until 5.2 - the issue is fixed in trunk On 10 Jul 2008, at 16:47, Demian Mrakovich wrote: Thanks for the bump and for the work-around! But - turning off async dispatch reduces performance with slow consumers if I understand

Re: Help needed. About message loss in distributed queue in network of brokers environment

You can't avoid duplex in this case unfortunately - will see if can get this fixed for 5.2. Would you like to raise an issue for it - so I don't forget ? On 10 Jul 2008, at 17:01, Bryan.Shaw wrote: I am not using async send from the client. But, I am using duplex connection because one of

MaximumPendingQueueSize

I am using 4.1.1. How can I set the MaximumPendingQueueSize (without using JConsole)? -- View this message in context: http://www.nabble.com/MaximumPendingQueueSize-tp18390026p18390026.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: runlevel script for debian/ubuntu

bsnyder wrote: On Tue, Jul 8, 2008 at 2:04 AM, lkwg82 [EMAIL PROTECTED] wrote: starting as root and giving processes to non-root users is common on unixes, it is a need for security Yes, I'm quite familiar with it :-). and EOL means EndOfLine, on win32 it is \r\n and on linux only

Virtual Topic Size

Hi, Is there a way to set the maximum size of a Virtual Topic. I have my queues topic set to a maximum of 50mb, but it doesn't appear to work with VirtualTopic. Currently, I am seeing the system slow down to a crawl when the VT takes up most of the activemq jvm memory. Any suggestions?

camel and set ttl of messages

1) how do I extend the following code snippet to set different TTLs on the messages?? 2) how do I print these header properties as system.println() ?? thx in advance public final class CamelFileToJMS { public static void main(String args[]) throws Exception {

Re: NMS doesn't work with latest ActiveMQ

Jim, Thanks a lot for the clariification. I got my integration code to work using the latest code from SVN trunk, i can speak with the 5.1 ActiveMQ. Most of my problems ended up being user errors, but i was a little hesitant to rely on something with failing unit tests. I've tested my

Re: Filtering messages in a Network of Brokers

Thanks Joe ! I think 'MessageAuthorizationPolicy' will work for me. :) Joe Fernandez wrote: You could implement a MessageAuthorizationPolicy. The policy wold allow/disallow messages based on a property. See bottom of this page http://activemq.apache.org/security.html Or a filter

Re: Filtering messages in a Network of Brokers

Thanks Rob! But I wanted to filter several messages, not destinations :S. With wildcards, I can only filter based on destination name is it? rajdavies wrote: On 10 Jul 2008, at 14:13, Yohan Liyanage wrote: Hi, Is there anyway to filter messages in a network of brokers (Store and

Re: Help needed. About message loss in distributed queue in network of brokers environment

I have already reported this issue in JIRA. The issue key is AMQ-1845. rajdavies wrote: You can't avoid duplex in this case unfortunately - will see if can get this fixed for 5.2. Would you like to raise an issue for it - so I don't forget ? On 10 Jul 2008, at 17:01, Bryan.Shaw

Re: why my consumer client always lost connection

i am not sure if the firewall cause this, but why there is no exception? i have set exception listener to this connection, under normal circumstances it would throw exception sparky2708 wrote: Check your firewall. We had a similar problem - our firewall would disconnect the connection if it

JMS + producer a .NET application and Consumer Java Application

Hey, I want to implement JMS in my application but want to make sure weather it is possible to implement my producer code in .NET and consumer in Java ? I am using activeMQ as my message broker. Looking forward to hear from you soon, Thanks Regards, Jigar Naik. -- View this message in