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

2013-11-22 Thread Robert Davies
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

what does "Replaying recovery log" mean? Embedded broker

2013-11-22 Thread Brian Reinhold
What does Replaying recovery log: 0.00% done (0/310 bytes) @ 0.00 kb/s, Infinity hrs remaining. mean. Every once and a while I see this when running my embedded broker (protocol tls) type mqtt. To get rid of it I have to delete the created default /data directory and /webapp-resources directori

Re: How to configure embedded SSL broker using just Java code

2013-11-22 Thread Brian Reinhold
It looks like I cannot specify a separate truststore for the server when I require client authentication. It appears that I need to put the client certificate in the same keystore as the server's private key. It would be nice to be able to separate the two as the private key is typically something

Re: Setting PublishedAddressPolicy on TransportConnector (incl workaround)

2013-11-22 Thread brenuart
You should probably try: -- View this message in context: http://activemq.2283324.n4.nabble.com/Setting-PublishedAddressPolicy-on-TransportConnector-incl-workaround-tp4673632p4674775.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: replicatedLevelDB errors after failover

2013-11-22 Thread kal123
Ran failover test again and after about 25 or so fail overs I got the below errors on the master. I did not see any other errors. I will try to run with debug turned on next week to see it helps with debugging. Note: even after this error i was able to do few more failover before things stopped w

Re: Producer Flow Block - Consumer Deadlock after max memory limits exceeded

2013-11-22 Thread Paul Gale
The checkpoint worker (which is responsible for determining which data log files should be removed) runs every 30 seconds. One can learn a lot about how the data log purge is happening by enabling its logger. See here for more details: http://activemq.apache.org/why-do-kahadb-log-files-remain-afte

Re: How to configure embedded SSL broker using just Java code

2013-11-22 Thread Christian Posta
Yah, awesome! We love contributions. On Fri, Nov 22, 2013 at 11:32 AM, Brian Reinhold wrote: > Okay but I have actually already started down that path (using the *DTO > classes). I just couldn't see how they were linked to the brokerDTO. But I > guess many of them are nested and that is why. (Unf

Re: How to configure embedded SSL broker using just Java code

2013-11-22 Thread Brian Reinhold
Okay but I have actually already started down that path (using the *DTO classes). I just couldn't see how they were linked to the brokerDTO. But I guess many of them are nested and that is why. (Unfortunately I tried the SslDTO first which is nested so I didn't see the connection.) So I guess the h

Re: How to configure embedded SSL broker using just Java code

2013-11-22 Thread Christian Posta
Apollo API != ActiveMQ 5.x API. To create an embedded broker with ActiveMQ 5.x with SSL take a look at this: https://github.com/apache/activemq/blob/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AMQ4563Test.java#createBroker(...) To create an embedded broker with Apollo wi

How to configure embedded SSL broker using just Java code

2013-11-22 Thread Brian Reinhold
This question was asked a while ago and the answers involved links and APIs that no longer exist. I am unable to find any documentation to figure out what classes correspond to what xml options, and if one is able to guess at the classes, how to link them to the broker. In the binary distributions

RE: Producer Flow Block - Consumer Deadlock after max memory limits exceeded

2013-11-22 Thread barry.barnett
So once the message is removed from the DLQ, then the journal would clear in 30 seconds? Is that post v5.8? Regards, Barry Barnett WMQ Enterprise Services & Solutions Wells Fargo Cell: 704-564-5501 -Original Message- From: Christian Posta [mailto:christian.po...@gmail.com] Sent: Frid

Re: Storage Limit doesn't take into consideration existing AMQ Storage

2013-11-22 Thread Gary Tully
think you are hitting https://issues.apache.org/jira/browse/AMQ-4832 On 21 November 2013 19:39, thall wrote: > I am using activmq 5.9.0. > Is there a way to get the storage limit check to take into consideration the > ~60G already used for AMQ storage? so that it doesn't block every producer? >

Storage Limit doesn't take into consideration existing AMQ Storage

2013-11-22 Thread thall
I am using activmq 5.9.0. Is there a way to get the storage limit check to take into consideration the ~60G already used for AMQ storage? so that it doesn't block every producer? My experience with the issue: I have a storage limit set using the following parameters:

Re: Producer Flow Block - Consumer Deadlock after max memory limits exceeded

2013-11-22 Thread Christian Posta
Right. It means that particular file that holds the message cannot be deleted/archived. On Fri, Nov 22, 2013 at 6:48 AM, wrote: > If there is a 'useful' artificat in the journal which is 'tied' to a message > on the DLQ, that means the journal can't be cleared, right? The only way to > clear

Re: ORA-01465: invalid hex number

2013-11-22 Thread Gary Tully
or you can be more selective, see: http://activemq.apache.org/59-migration-guide.html On 21 November 2013 18:33, Leonardo K. Shikida wrote: > drop and recreate all JMS tables > > [] > > Leo > > > On Thu, Nov 21, 2013 at 12:34 PM, Leonardo K. Shikida > wrote: > >> Hi >> >> I have an app, it was r

Re: Transactions in ActiveMQ

2013-11-22 Thread Gary Tully
most of that is covered in the jms spec documentation, it is standard. Maybe post some specific questions or concerns with some sample code and we can take if from there. On 22 November 2013 13:54, Sophia Wright wrote: > Hey, > > I want to read about ActiveMQ transactions in detail, I have alrea

Consuming "Virtual Topic" hangs in ActiveMQ 5.9

2013-11-22 Thread patrik
Hi! We are having som issues with "Virtual Topics" running: ActiveMQ 5.9.0, Camel 2.12.1, LevelDB. No network of brokers, No replication. Sending 1 of large messages to virtual topic is working perfectly. But when starting to consume from the "Virtual Topics"-queues, the consumer log starts

Transactions in ActiveMQ

2013-11-22 Thread Sophia Wright
Hey, I want to read about ActiveMQ transactions in detail, I have already googled it but found not much other than http://activemq.apache.org/should-i-use-transactions.html http://activemq.apache.org/how-do-transactions-work.html So if there is some blog or any thing is there, please help me. I

RE: Producer Flow Block - Consumer Deadlock after max memory limits exceeded

2013-11-22 Thread barry.barnett
The journal files were cut down in size to avoid running into the issue, but there is still potential to have a message on the DLQ that is a 'useful artifact' which is in the journal, no? ---+- Regards, Barry Barnett WMQ Enterprise Services & Solutions Wells Fargo Cell: 704-564-5501

RE: Producer Flow Block - Consumer Deadlock after max memory limits exceeded

2013-11-22 Thread barry.barnett
If there is a 'useful' artificat in the journal which is 'tied' to a message on the DLQ, that means the journal can't be cleared, right? The only way to clear the journal is to delete the message from the DLQ first, correct? Regards, Barry Barnett WMQ Enterprise Services & Solutions Wells Farg

Re: java.lang.NoClassDefFoundError: org/apache/activemq/util/IOExceptionSupport

2013-11-22 Thread Jose María Zaragoza
> > So I would suggest that you check your classpath for the ActiveMQ > dependencies and make sure that you don't have a < 5.8 version lingering > somewhere. > Thanks Timothy But I guess that isn't not the problem . I've checked for other AMQ versions and there is not any more. The problem happ

Embedded approach: Broker() versus BrokerService()

2013-11-22 Thread Brian Reinhold
I am hard pressed to find much documentation on using/coding an embedded broker. The single example that comes with the distribution instantiates a Broker() object, but in the FAQ it is illustrated using a BrokerService() object. I don't understand the difference. In the end I need to configure th

RE: java.lang.NoClassDefFoundError: org/apache/activemq/util/IOExceptionSupport

2013-11-22 Thread Timothy Creswick
> How is it possible a "java.lang.NoClassDefFoundError: > org/apache/activemq/util/IOExceptionSupport" exception if I didn't > restart Tomcat server ? > Any ideas ? This sounds like you have a JAR / library conflict somewhere. Specifically, the class that you mention (IOExceptionSupport) was move

java.lang.NoClassDefFoundError: org/apache/activemq/util/IOExceptionSupport

2013-11-22 Thread Jose María Zaragoza
Hi: I'm using AMQ 5.8.0 , on client & server side. Client side is a web application running on Tomcat 6 and its running ok Connection transport is in failover mode "failover:(tcp://broker1:61616?connectionTimeout=3000,tcp://broker2:61617?connectionTimeout=3000)?timeout=5000&startupMaxReconnectAt

Re: Subscribe to multiple topics

2013-11-22 Thread Steven Turner
The link you provided gives a 404 error. When I use testTopic with producer it sends messages on both topics but when I use this with a consumer, it consumes messages from only one topic. I am using spring's DefaultMessageListenerContainer to listen for messages and jmsTemplate to send messa