Re: Transactions and memory consumption

FYI, I have posted a similar question to StackOverflow: http://stackoverflow.com/questions/22977299/in-activemq-is-it-possible-to-limit-the-memory-required-for-an-open-consumer-tra -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-and-memory-consumption-tp42248

Re: master/slave within a network of brokers

see https://issues.apache.org/jira/browse/AMQ-4164 -- View this message in context: http://activemq.2283324.n4.nabble.com/master-slave-within-a-network-of-brokers-tp4410862p4658965.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Exception in thread "ActiveMQ BrokerService[localhost] Task-4" java.lang.OutOfMemoryError: unable to create new native thread

This means that you have created more threads on your system than you are allowed to create or have memory to create. We cannot really tell without more information about you environment. You may find this page u

Re: in master slave broker network, networked slave incorrectly bound to other slave

Note, when I patch DemandForwardingBridge to setNetworkConnection(true) on all BrokerInfo commands received by serviceRemoteCommand and patch TransportConnection to not create MasterBroker filters for networked slaves, this problem does not occur and things proceed as expected. I think this should

Re: Message sometimes lost when transaction open and broker restarted

After deeper investigation, I have discovered that when this fails, it is because the first message (the one that ends up missing) is never written to the KahaDB store. I added a trace message to /void upadateIndex(Transaction tx, KahaAddMessageCommand command, Location location) / in order to see

Re: Message sometimes lost when transaction open and broker restarted

Thanks. I will try to. In part of my test I am using a QueueBrowser to inspect what is on the queue. I do this to check the state at various points to make sure it meets expectations. When I removed these checks (which weren't completely necessary), the problem when away. So my concern here is

Message sometimes lost when transaction open and broker restarted

I am using 5.7.0 with Java 1.7.0_07 on a linux 64 system. Messages are persisted using KahaDB as the store. * I have a test which puts 10 messages on a queue. This queue is being read via a transacted consumer. * I then shutdown the broker without committing or rolling back the session. I am d

Re: out of memory using producer flow control and fileQueueCursor

I will look at IndirectMessageReference more closely. The pendingMessages map does have an IndirectMessageReference for each dispatched message. And each IndirectMessageReference contains an ActiveMQTextMessage (in my case) which is the fully realized message. So the trick is to know when the

Re: out of memory using producer flow control and fileQueueCursor

When I use the default store cursor, then the system will end up blocking. This is because the cursor reaches the 70% watermark and stops dispatching messages to the consumer. This is also not viable for us because then there is no way to get all the messages to the consumer it need to complete t

Re: Failover with networkConnectors

I'm using: Note, no // after the static. But it looks like something else is misconfigured for you. Notice the /start/ after no scheme specified. hodgesz wrote > > ERROR: java.lang.RuntimeException: Failed to execute start task. Reason: > java.l > ng.IllegalArgumentException: Invalid broke

out of memory using producer flow control and fileQueueCursor

version 5.5.1 broker cfg: memory: 256M, Store:10g, Swap/tmp:10g, persistence=true, producerFlowControl=true I'm using the http://activemq.apache.org/message-cursors.html fileQueueCursor destination policy for a queue. It appears to properly page in messages in the cursor without blocking when

Re: how can jmx queueSize be greater than enqueue size?

Ok, after poking around a bit, I realized that there must be persisted messages being restored from a previous execution. Does that make sense? -- View this message in context: http://activemq.2283324.n4.nabble.com/how-can-jmx-queueSize-be-greater-than-enqueue-size-tp4414406p4414654.html Sent fr

Re: master/slave within a network of brokers

john, I have been using connections like between two sets of master/slave brokers that are networked together. This generally works but I am working on tracking down some occasional failures of my tests that seem related to the network never getting set up (not sure about that though -- it is a

how can jmx queueSize be greater than enqueue size?

I am using 5.5.1. I don't really understand how this can be happening. Any advice would be appreciated: ConsumerCount: 1 CursorFull: false CursorMemoryUsage: 375818264 CursorPercentUsage: 70 DequeueCount: 0 DispatchCount: 20803 EnqueueCount: 20807 ExpiredCount: 0 InFlightCount: 20803 ... QueueSi

Re: are session.commit() and consumer.receive allowed simultaneously in separate threads?

For posterity, according to comments on https://issues.apache.org/jira/browse/AMQ-3720, synchronization on the session is not required for a consumer.receive() call. -- View this message in context: http://activemq.2283324.n4.nabble.com/are-session-commit-and-consumer-receive-allowed-simultaneous

should I use trunk or patch 5.5.1?

Hi, I need the fix for https://issues.apache.org/jira/browse/AMQ-3542. Should I try to patch 5.5.1 up as needed to include the fixes for it? Or should I use trunk? I'm not sure how stable trunk is or how close 5.6 is to shipping. Thanks, Martin p.s. I'm trying to deal with a situation where

Re: messages sometimes lost during pure master/slave failover

Ok... I figured out what was going on. I will file a ticket on this shortly. When the master broker is undergoing a controlled shutdown, the BrokerService.stop() method stops in this order: * services * connectors * registered vm transports * broker So there is a period where the broker will

Re: messages sometimes lost during pure master/slave failover

We are using the ActiveMQ in an embedded mode in our application. It may be difficult to reproduce in a test case because of the intermittent nature... On inspection of the code below (from MasterBroker.java), it seems that an exception syncing to the slave is logged but otherwise ignored. Doesn

Re: messages sometimes lost during pure master/slave failover

Sorry, the master exception log message includes a modification we made to the logging on slave failure to distinguish failure conditions (see AMQ-2459). Normally it would say "Slave Failed" with the exception. Full exception trace returned from slave: java.net.SocketException: socket closed

messages sometimes lost during pure master/slave failover

Hi, I have a pure master/slave configuration. I am using 5.3.2 but have observed the same problem in testing 5.5.0. I have an intermittent issue where a message will appear to be successfully sent (the producer send() method returns without error) but will be lost. This occurs sometimes during