Re: TCP send and receive buffers filling preventing openwire communication

Sorry, forgot to add logfile stuff... These hangups are often accompanied or preceded by log entries like: 2014-01-16 17:45:02,816 | WARN | TopicSubscription: consumer=B->A-35971-1389919240382-4:3:1:1, destinations=23, dispatched=1000, delivered=0, matched=1001, discarded=0: has twice its prefet

TCP send and receive buffers filling preventing openwire communication

Problem: We're experiencing a problem whereby openwire communication completely locks up and the tcp send and receive buffers fill up preventing any further communication between brokers, whilst the stomp client connectors continue to function perfectly. Below is an example of this happening betwe

Re: Connection being made, but not registering as a Consumer of any queues

I think it's probably the following from a file called messaging.rb that ActiveMessaging loads up automatically: ActiveMessaging::Gateway.define do |s| s.destination :my_publishing_queue, '/queue/myQueue_production' end -- View this message in context: http://activemq.2283324.n4.nabble.c

Re: Connection being made, but not registering as a Consumer of any queues

I'm not ruby-knoweldgeable. With that said, is there any consumer creation in that posted code? I can't make it out. Is it somewhere else? -- View this message in context: http://activemq.2283324.n4.nabble.com/Connection-being-made-but-not-registering-as-a-Consumer-of-any-queues-tp4676052p46

Re: multiple brokers and Failover for ActiveMQ questions

Three brokers cannot safely share the same database. If using kahadb or leveldb, one broker will lock the DB and the others will wait indefinitely for the lock. Ordering of messages delivered by multiple producers is not guaranteed. Only the ordering from a single producer is guaranteed. I thin

Re: Connection being made, but not registering as a Consumer of any queues

There is very little code, just a ruby script with the following contents: #!/usr/bin/env ruby # Make sure stdout and stderr write out without delay for using with daemon like scripts STDOUT.sync = true; STDOUT.flush STDERR.sync = true; STDERR.flush # Load Rails RAILS_ROOT=File.expand_path(File.

Re: Connection being made, but not registering as a Consumer of any queues

Based on that response - the fact that the connection setup is seen in both cases - I suspect the client just isn't getting to the point of sending the creation of the consumer to the server. Is there something else going on in the code between the connection creation and the consumer creation tha

Re: ActiveMQ Web Console clashes with existing broker

On Fri, Jan 17, 2014 at 6:41 PM, Hilderich wrote: > Hello dear Supporters, > > We have already an existing ActiveMQ Broker in a OSGi container (Karaf). > Now I'd like to utilize the ActiveMQ Web Console to have an overview about > the JMS Queues we are using. > The problem is that the ActiveMQ Web

ActiveMQ Web Console clashes with existing broker

Hello dear Supporters, We have already an existing ActiveMQ Broker in a OSGi container (Karaf). Now I'd like to utilize the ActiveMQ Web Console to have an overview about the JMS Queues we are using. The problem is that the ActiveMQ Web Console always implements its own JMS Broker and this one cla

ActiveMQ Web Console clashes with existing broker

Hello dear Supporters, We have already an existing ActiveMQ Broker in a OSGi container (Karaf). Now I'd like to utilize the ActiveMQ Web Console to have an overview about the JMS Queues we are using. The problem is that the ActiveMQ Web Console always implements its own JMS Broker and this one cla

Re: Connection being made, but not registering as a Consumer of any queues

Thanks so much for your response. Unfortunately we did check all those things but no luck. Do you have any other suggestions what could be going on here? We've made sure that all the versions of ruby and the gems are the same on both servers. Here is a bit of info from the data/activemq.log Whe

Re: How to consume all messages in a netwok of brokers.

Thanks for the information. Gary, I paste my activemq.xml file config: http://www.springframework.org/schema/beans"; xmlns:amq=" http://activemq.apache.org/schema/core"; xmlns:xsi=" http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http:

multiple brokers and Failover for ActiveMQ questions

Hi there, I have a couple of questions regarding ActiveMQ. 1. On my environment, I set up 3 ActiveMQ in 3 servers and share one Database. Is it possible to run the 3 ActiveMQ in the 3 servers to share the same database? I tried to set it up. However, it looks like 3 brokers cannot share the same

Re: Push messages to subscriber

On 01/17/2014 12:45 AM, jaideep wrote: Hi all, Based on my reading and understanding so far on ActiveMQ or other Message Oriented Middlewares(MOM), I think a subscriber once registered needs to keep on polling the ActiveMQ queue/topic for any new messages. I could not find any information that t

Re: Acknowledgement question.

peek at the unit tests eg: https://github.com/apache/activemq/blob/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.java#L80 On 17 January 2014 15:13, cecchinoSMI wrote: > So how I can use the class JMSReplyto in my project? Give me an example > > > > -- >

Re: Acknowledgement question.

So how I can use the class JMSReplyto in my project? Give me an example -- View this message in context: http://activemq.2283324.n4.nabble.com/Acknowledgement-question-tp2350620p4676450.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to consume all messages in a netwok of brokers.

sounds like you have a statically configured network, where forwarding is automatic. Can you post the xml config you are using. Also note what Art says above. On 16 January 2014 23:34, Rodrigo Ramos wrote: > I have been configuring a netwok of brokers, so that all the messages are > consume. > >

Re: what is the relationship between indexbinsize & indexpagesize

Such questions generally not create any attention. But I also like to know exact same thing. If someone from ActiveMQ development can reply here... -- View this message in context: http://activemq.2283324.n4.nabble.com/what-is-the-relationship-between-indexbinsize-indexpagesize-tp2366574p4676

dedicatedTaskRunner threads reductions

Hi, Reference: If we disable "dedicatedTaskRunner", we can use ActiveMQ internal thread pool to control message dispatching. Using a thread pool can restrict the number of threads required by ActiveMQ and hence reduce memory usage. Question: I disable "dedicatedTaskRunner", Will there not be one