Re: Failover Transport hangs forever on connection.start() in Master/Slave

You haven't mentioned a version of your activemq, there were some issues with that in older versions... We're on 5.6.0 and above - no issues... See http://activemq.apache.org/failover-transport-reference -- Sent from: http://activemq.

Re: Migrating storage from 5.10.0 to 5.14.5

I don't think there's any current fallback option for SQL right now. Contributions are welcome though so if you wanted to take a shot at adding a property for that you could create a PR. We might give it a shot - should we follow https://activemq.apache.org/contributing.html and create a patch

Re: Migrating storage from 5.10.0 to 5.14.5

We seems to experience the same issue upgrading from 5.6.0 to 515.8, but in our case we use SQL database as a message store. As it was mentioned and confirmed by us KahaDB has a fallback capability when it encounter older (Version 6) of OpenWire. Unfortunately, it looks like for SQL databases there

Re: pluggable MessageTransformer available in trunk

MessageTransformer plugin has access to a message. I wonder what would be a proper way to handle exceptions occurred while performing transformations and how actual message can be accessed in the exception handler? -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: setting up c++ client app using CMS using SSL client certificate auth

" To: "mikmela" Subject: setting up c++ client app using CMS using SSL client certificate auth Date: Tue, Nov 26, 2013 4:12 AM Thank you very much, What I want to do is I want to create an ActiveMQ cluster. This cluster will use mutual authentication.(client and broker) And each ac

Re: setting up c++ client app using CMS using SSL client certificate auth

*error:0906D06C:PEM routines:PEM_read_bio:no start line error:140B0009:SSL routines:SSL_CTX_use_PrivateKey_file:PEM lib * appears if a private key is not found during SSL handshake Overall, looks like you're on a right path... You enabled client auth... Therefore for successful handshake you n

Re: I want to create two queues with the same name?

I believe, queue name is unique only in the scope of broker instance, but nothing prevent you from running 2 broker instances (not sharing the same message store, of course) on the same machine. -- View this message in context: http://activemq.2283324.n4.nabble.com/I-want-to-create-two-queues

Re: Re:Clarifcation on KahaDB support for message priority is needed

Excellent article! You really took time detailing priority support issues on ActiveMQ broker's side. I wish you could get into a bit more specifics on “Client side message priority” – googling jms.messagePrioritySupported didn’t bring much… How does it impact final message consumption priority-wise

Re: Re:Clarifcation on KahaDB support for message priority is needed

Ok. Thanks. -- View this message in context: http://activemq.2283324.n4.nabble.com/Clarifcation-on-KahaDB-support-for-message-priority-is-needed-tp4665014p4665057.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Re:Clarifcation on KahaDB support for message priority is needed

It's been a bit confusing... According to http://activemq.apache.org/message-cursors.html : The store based cursor also handles cursors for non-persistent messages, which are not stored in the message store. Non-persistent messages are passed dire

Re: Clarifcation on KahaDB support for message priority is needed

with prefetch size=1 going to 5o messages still maintains message priority... Based on your description I thought the number of reordered messages correlated to prefetch size, am I missing something? My messages are non-persistent. Maybe, the limit on the number of reodered messages depends on the

Re: Clarifcation on KahaDB support for message priority is needed

We tried 6 messages 2 of each priority; prefetch was set to 1 -- View this message in context: http://activemq.2283324.n4.nabble.com/Clarifcation-on-KahaDB-support-for-message-priority-is-needed-tp4665014p4665030.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Clarifcation on KahaDB support for message priority is needed

Thank you, guys - that explains it. -- View this message in context: http://activemq.2283324.n4.nabble.com/Clarifcation-on-KahaDB-support-for-message-priority-is-needed-tp4665014p4665029.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Clarifcation on KahaDB support for message priority is needed

The http://activemq.apache.org/how-can-i-support-priority-queues.html says that *For KahaDB three priority levels are supported, Low (<5), Default (=5) and High (>5).*. However, our tests show that messages with different priori

Re: ACtiveMQ CMS and JMSXUserID property

I agree if it is classified as a bug and not as unimplemented feature that has work around. I will create a jira and the test case per your request. Thanks again... -- View this message in context: http://activemq.2283324.n4.nabble.com/ACtiveMQ-CMS-and-JMSXUserID-property-tp4664762p4664830.htm

SSL certificate based authentication

The article http://activemq.apache.org/jmsxuserid.html has the following: Note, though, that for SSL certificate based authentication, e.g., when using TextFileCertificateLoginModule JAAS module, this will change the semantics of the broker-provided JMSXUserID. Instead of returning the DN of the ce

ACtiveMQ CMS and JMSXUserID property

Java implementation (5.6.0) does something special for this property /public String getStringProperty(String name) throws JMSException { Object value = null; if (name.equals("JMSXUserID")) { value = getUserID(); if (value == null) { value =

Re: setting up c++ client app using CMS using SSL client certificate auth

It turned out that the PEM file that was configured as keystore didn't have a private key. So, to answer own question decaf::lang::System::setProperty( "decaf.net.ssl.trustStore", pathToClientTrustStoreInPemFormat); decaf::lang::System::setProperty( "decaf.net.ssl.keyStore", pathToClienteyStore

setting up c++ client app using CMS using SSL client certificate auth

I'm having problem setting client app using ActiveMQ CMS with enabled client certificate auth. Someone already asked similar question http://activemq.2283324.n4.nabble.com/SSL-with-ActiveMQ-cpp-td4499106.html. I'm doing the following: activemq::library::ActiveMQCPP::initializeLibrary(); deca

Re: What are limitations/restrictions on destination name?

OK, I've testest some use cases... This list is far from being comprehensive... Looks like only destination names containing "?" that are accepted by JMS api, will have issues as ActiveMQ parses destination name as URI string. Consequently, “?” is removed and everything after it is treated as query

What are limitations/restrictions on destination name?

What are limitations/restrictions on a destination name in terms of special characters usage, unicode characters and the max length? Any standard specification it should confirm to? -- View this message in context: http://activemq.2283324.n4.nabble.com/What-are-limitations-restrictions-on-desti

Re: How to get niotified when broker service stops

My concern is that in cases when there are no messages to persist and the next thing that does db access is keepAlive()... It won't notify IOExceptionHandler, instead just returning "false" and, consequently, stopBroker() will be called silently... I got yet to try this scenario.. -- View thi

Re: How to get niotified when broker service stops

Thanks Christian. I've been thinking along lighter broker.setIoExceptionHandler() way, but looks likes keepAlive eats up all exceptions? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-get-notified-when-broker-service-stops-tp4663430p4663434.html Sent from the Ac

How to get niotified when broker service stops

There is a situation when JDBC persistence adapter simply stops the broker service. This is happening when database locker's keepAlive check fails due to some database issues... What would be the best way to get notified about it... In other words, is any way to register a an observer object? or

Re: java.lang.OutOfMemoryError: unable to create new native thread

Have you tried -Dorg.apache.activemq.UseDedicatedTaskRunner=false http://activemq.apache.org/how-do-i-configure-10s-of-1000s-of-queues-in-a-single-broker-.html -- View this message in context: htt

How to protect broker from broker from exhausting resources requested by clients creating temp queues

Is any way to protect broker from malicios or badly written client code that keep creating temp queues? At some point broker hits virtual memory limits and number of live threads is very high... javax.jms.JMSException: unable to create new native thread at org.apache.activemq.util.JMSExcep

Getting e-mail notification when issue in JIRA gets updated?

I'd like to get e-mail notifications when jira gets updated? Looks like just registering in issue's Watch List is not enough... -- View this message in context: http://activemq.2283324.n4.nabble.com/Getting-e-mail-notification-when-issue-in-JIRA-gets-updated-tp4655804.html Sent from the Active

cms crashing when SSL certificate's subject alternative name doesn't match the specified in failover URI

When we specify self-signed certificate in PEM-formatted file as value of the "decaf.net.ssl.trustStore" property and SAN that does't match any name in failover URI, cms is crashing on Windows with "R6025 Pure Virtual Function Call" run-time error. Debugger shows that cms is trying to fire an exce

composite uri

Can someone give the definition to the term "composite URI"? I thought, failover uri containting two uri's as follows : /failover://(tcp://bla:61616,tcp://bla:61617)/ is the composite URI, but URISupport.isCompositeURI(uri) returns false on it? Meanwile, CompositeData compositeData = URISupport.p

Re: Problem with TransactDatabaseLocker's lock statement

Thanks for pointing to this issue. But the method that overrides lock create statement has a bug... If isUseLockCreateWhereClause() is true, the produced statement will look something like this: *SELECT * FROM ACTIVEMQ_LOCK WHERE ID=1 WITH (UPDLOCK, ROWLOCK)* which will throw a */com.microsoft.sq

Re: Problem with TransactDatabaseLocker's lock statement

Have you seen this simple select *SELECT * FROM ACTIVEMQ_LOCK WHERE ID=1* working for MS SQL Server? It doesn't for me in terms of master/slave synchronization (i.e. slave is not blocked on this select) unless I do something like this *SELECT * FROM ACTIVEMQ_LOCK(rowlock, updlock, REPEATABLEREAD)

Problem with TransactDatabaseLocker's lock statement

I'm not sure if it's the specific version of SQL server that we're using, but S*ELECT * FROM ACTIVEMQ_LOCK WHERE ID=1 FOR UPDATE* throws exception *"FOR Update clause allowed only for DECLARE CURSOR" *... I'm using 5.6.0 - Am I missing something in connection string or configuration properties?

OracleBlobJDBCAdapter

In what cases the usage of OracleBlobJDBCAdapter is more appropriate than OracleJDBCAdapter? -- View this message in context: http://activemq.2283324.n4.nabble.com/OracleBlobJDBCAdapter-tp4652990.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: A question of activemq-cpp

The answer in the spirit of your short question - Yes, you can... -- View this message in context: http://activemq.2283324.n4.nabble.com/A-question-of-activemq-cpp-tp4623243p4632708.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

journal log file gets incremented while there is no activity

I'm observing the behavior that looks strange to me - for some reason, broker keep deleting existing journal log files and creates a new ones with incremented number even though there is no active producers running. I'm doing acceptance testing on 5.5.1 -- View this message in context: http://ac

Re: how to make activemq switch to JDBCPersistenceAdapter in source code?

There are many ways to do it, but steps are 1. Create a datasource 2. Set it on JDBCPersistenceAdapter object. 3. Set PersistenceAdapter object on the broker instance... Below code for illustration only... protected PersistenceAdapter createJDBCPersistenceAdapter(DataSource ds, boolean createOn

JDBC based Master/slave configuration

As it was mentioned in http://activemq.2283324.n4.nabble.com/activemq-user-Network-of-brokers-and-db-schema-td2342357.html#a2342360 "Its technically possible to patch the JDBC message store to include a broker ID column in all the tables to allow the same JDBC database to be used for multiple b

Re: ACTIVEMQ_LOCK.BROKER_NAME Is Always NULL

Does anyone know if this issue with BROKER_NAME in ACTIVEMQ_LOCK table has ever been resolved? It seems that for some reason it was decided that broker cluster (i.e. group of 1 master and N slaves) must have a dedicated database instance?! Using BROKER_NAME (which, actually, should be a broker cl

Re: Problem using ActiveMQ-CPP interfaces where std::string are used as parameters

quote author="tabish...@gmail.com"> On Thu, 2011-12-15 at 10:11 +0400, Ivan Pechorin wrote: > 2011/12/14 mikmela <[hidden email]>: > > I'm having a lot of issues passing std::strings into ActiveMQ-CPP > interfaces, > > i.e. Connection, Session, Mess

Problem using ActiveMQ-CPP interfaces where std::string are used as parameters

I'm having a lot of issues passing std::strings into ActiveMQ-CPP interfaces, i.e. Connection, Session, Message and etc. Even though I'm using MS VS2010 to build both activemq-cpp dll and my application with the same version of multithreaded c-runtime dll MSVCP100.dll, MSVCR100.dll(/MD) , string ob