Migrating storage from 5.10.0 to 5.14.5

Good Day, I've been working on migrating servers and upgrading from 5.10.0 to 5.14.5. We have a number of scheduled tasks and I want to preserve those along with other items in the queue. I tried moving the files in kahadb to the new server (after shutting down both servers), but have run into

Re: Migrating storage from 5.10.0 to 5.14.5

oker to the new one and then to the consumers. > > On May 24, 2017 2:45 PM, "Christopher Shannon" < > christopher.l.shan...@gmail.com> wrote: > >> What kind of errors are you getting? If it's related to data >> marshalling>> then it could be because

ActiveMQ with Sybase for persistence

Does anyone have a working example of using ActiveMQ with Sybase ASE as the persistence store? The online docs make mention that Sybase is supported butASE does not support SELECT FOR UPDATE and I was wondering how to configure ActiveMQ so it will work. Thanks

RE: ActiveMQ with Sybase for persistence

Looks like I still have problems. I downloaded the 4.2 that you sent me the link to (thank you) and I configured it for my data source. The problem is that my ASE is actually 12.0.0.8 and not 12.5. The SELECT WITH XLOCK raises an error. ASE complains about the WITH syntax. Any suggestions

RE: ActiveMQ with Sybase for persistence

For a large integer you can use the numeric data type. Per the Sybase ASE documentation for ASE 12.5: http://manuals.sybase.com/onlinebooks/group-as/asg1250e/sqlug/@Generic__BookTextView/15426;pt=15426#X Datatypes by category Synonyms Range

Re: Unable to build 5.0 source

Oh how you got my hopes up that it was going to be that simple. I did find that my java.exe was in WINDOWS/system32 directory and it was version 1.6, so I deleted it. I made certain that my JAVA_HOME was pointing to my java 1.5 installation and that javac version was also 1.5. They both are. So I

Re: Unable to build 5.0 source

This error seems to be associated to the activemq-tooling project. By removing this project from the pom.xml residing in the parent directory I was able to successfully get the project to compile. I did need to modify the MAVEN_OPTS beyond what was specified on the build page to the following:

Re: Unable to build 5.0 source

I found the solution. It seems there was something odd about my maven repository (.m2/repository). I'm not certain what but I simply depleted it, cleaned the source directory and performed a build. Surprisingly everything worked this time. Chris Mathrusse [EMAIL PROTECTED] Sybase, Inc One Sybase

Comet Style AJAX Servlet Problems

Hi all, We're trying to use the Jetty continuations MessageListenerService as an endpoint for an AJAX app where people get near-realtime updates in their browser, where each end user subscribes to their own queue of notifications. (If the user were to leave and then come back, they'd get

ActiveMQ 5.5 fails to start

The class is there, paths look right as well. Any ideas on what could be causing this? jvm 1| Java Runtime: Sun Microsystems Inc. 1.6.0_22 /usr/java/jdk1.6.0_22-x86_64/jre jvm 1| Heap sizes: current=182208k free=172684k max=466048k jvm 1| JVM args:

Re: ActiveMQ 5.5 fails to start

...@fusesource.com tmie...@blogspot.com On Nov 25, 2011, at 5:43 PM, Christopher Johnston wrote: The class is there, paths look right as well. Any ideas on what could be causing this? jvm 1| Java Runtime: Sun Microsystems Inc. 1.6.0_22 /usr/java/jdk1.6.0_22-x86_64/jre jvm 1| Heap sizes

Re: ActiveMQ 5.5 fails to start

Turned out to be a permission problem in my package, the top level directory had permission to only allow root to access it so once I stated drilling down I was able to pin point it. -Chris On Mon, Nov 28, 2011 at 10:14 AM, Christopher Johnston chjoh...@gmail.comwrote: I actually got

php ack problem

I have a problem with ActiveMQ not removing messages from a queue when the ack is received from PHP. Do you list denizens possibly know what's going on? As background, it appears that Net::STOMP::Client adds a content-length header to a message, whereas PHP's Stomp doesn't. When

Re: No network bridges started in Network of brokers.

Can you share you activemq.xml on a pastebin? What is your TTL? do you have duplex enabled? -Chris On Tue, Jan 24, 2012 at 6:22 AM, Laures baetz.alexan...@googlemail.comwrote: Hi, i have a Network of 6 nodes in 3 datacenters, each one connected to every other server. upon startup some

Re: No network bridges started in Network of brokers.

Are you looking to do a mesh? Not sure your config looks right and I believe you need a TTL of at least 2 with duplex enabled. Think of a minimum 3 nodes setup, your config for each node should have networkConnectors pointing to each other to maintain the mesh and ability to failover. As you

Re: No network bridges started in Network of brokers.

Right - I believe thats called a mesh topology which is similar to what I have setup with the exception that I am using 6 brokers to scale out a bit more horizontally. Here is a good example setup from the mcollective project. Its pretty much exactly what you are looking for I believe. And yes

server-side stomp timeout?

My ActiveMQ daemon is not disconnecting dead stomp consumers. Is there a server-side timeout setting that I can use somewhere? I'm having difficulty finding one. I have a chaos monkey intermittently killing processes on my consumer hosts, and if this happens when the consumer is slurping down

Re: ActiveMQ EOL?

Apollo lacks clustering support as far as I am aware. Looks like an interesting upgrade though. On May 10, 2012, at 6:31 AM, Gary Tully gary.tu...@gmail.com wrote: ActiveMQ 5.x and ActiveMQ Apollo development will continue in parallel with a view to convergence in 6.0 Innovations in Apollo

dlq handling stops activemq from starting?

I've read this about DLQ: http://activemq.apache.org/message-redelivery-and-dlq-handling.html But when I try to use it as in the example (queue=) ActiveMQ doesn't start (5.5.1, although similar behaviour with 5.6.0). If I take the attached activemq.xml and use it as is, I get a working

Re: dlq handling stops activemq from starting?

vmQueueCursor/ /pendingQueuePolicy /policyEntry /policyEntries /policyMap /destinationPolicy and your broker should start up. Hope this helps. Torsten Mielke tors...@fusesource.com tmie...@blogspot.com On May 29, 2012, at 5:19 AM, Christopher

Re: ActiveMQ 5 - Specifying a broker's destinations in an external file

On Mon, Jun 11, 2012 at 07:26:43AM -0700, ndipiazza wrote: We want to specify our destinations in a separate file, so that activemq.xml file. So something like: broker xmlns=http://activemq.apache.org/schema/core; destinations path=/home/activemq/activemq-destinations.xml / Is

Re: ActiveMQ 5 - Specifying a broker's destinations in an external file

: Christopher, Thanks for shedding some light on this with this suggestion. So I'm unfortunately not super familiar with this plug-in. So in your case LdapConfiguration maps back to a configuration in activemq where destinations are configured to be looked up from your LDAP server? If you

ldap, system user can't create a topic

What gives the system user permission to create topic://ActiveMQ.Advisory.Connection? Without this ActiveMQ will not start. (Working with 5.5.1 since 5.6.0 is a jump requiring further testing.) I'm getting this error (all pasted text munged slightly to obfuscate things): 2012-06-18

Re: ldap, system user can't create a topic

-module.html Regards -- Dejan Bosanac Senior Software Engineer | FuseSource Corp. dej...@fusesource.com | fusesource.com skype: dejan.bosanac | twitter: @dejanb blog: http://www.nighttale.net ActiveMQ in Action: http://www.manning.com/snyder/ On Mon, Jun 18, 2012 at 11:55 PM, Christopher

Re: ldap, system user can't create a topic

5.6.0 and ldap authentication/authorization works better for me than 5.5.1. I was denied read/write to unpermitted queues. Dejan: Thank you for the pointer, very much appreciated. On Tue, Jun 19, 2012 at 02:36:43PM -0400, Christopher Wood wrote: Unfortunately the blog post didn't help (my

periodic 5.6.0 ldap permission issues, solved by restart?

I upgraded our lab ActiveMQ to 5.6.0 and am using the cached ldap auth module. I appear to be having a problem where at times ActiveMQ loses its authorization data cache and does not refresh this from ldap. Is there any way of forcing a retry if it has a connection issue, or otherwise further

Re: periodic 5.6.0 ldap permission issues, solved by restart?

Engineer | FuseSource Corp. dej...@fusesource.com | fusesource.com skype: dejan.bosanac | twitter: @dejanb blog: http://www.nighttale.net ActiveMQ in Action: http://www.manning.com/snyder/ On Thu, Jun 21, 2012 at 6:56 PM, Christopher Wood christopher_w...@pobox.com wrote: I upgraded our

Deploy issues in Karaf/Blueprint

I'm attempting to hot deploy a Camel route using the ActiveMQComponent into Karaf via the deploy folder using a blueprint xml file but I'm running into dependency issues. When Karaf attempts to start the created bundle I see this error: 2014-01-22 13:41:51,092 | ERROR | -SNAPSHOT/deploy |

Re: Deploy issues in Karaf/Blueprint

/2014 01:53 PM, Christopher Arnold wrote: I'm attempting to hot deploy a Camel route using the ActiveMQComponent into Karaf via the deploy folder using a blueprint xml file but I'm running into dependency issues. When Karaf attempts to start the created bundle I see this error: 2014-01-22 13:41

Error using OSGi services in activemq spring xml

I'm attempting to configure a broker in Karaf for SSL using encrypted properties for the keystore/truststore passwords. These properties were encrypted using Jasypt and we have a bundle responsible for the handling of the jasypt password that exports a PBEConfig as an OSGi service. Now I'm

Re: Allowing another consumer to have a message (ActiveMQ-CPP)

The use case you are trying to achieve is probably best done by using a transaction instead of individual acknowledgements. If you call rollback on the session then the message would be available to be redelivered to another consumer. On Tue, Jun 9, 2015 at 3:50 AM, spamtrap

Re: Allowing another consumer to have a message (ActiveMQ-CPP)

, Christopher Shannon christopher.l.shan...@gmail.com wrote: The use case you are trying to achieve is probably best done by using a transaction instead of individual acknowledgements. If you call rollback on the session then the message would be available to be redelivered to another

Re: put a message in queue using org.apache.activemq.broker.Broker

I'm glad that helped. At a quick glance your new code looks pretty good. The important thing was being able to only send the message to the next broker so that your broker filter doesn't get called in an infinite loop and your new code does this. Your new code is also much more efficient than

Re: Total consumer count negative

to see if it works and if it doesn't have any problems with it. And we don't know if it worths the update. But as we are having this incident we need to think about it. El 09/06/2015 01:33, Christopher Shannon christopher.l.shan...@gmail.com escribió: The count shouldn't

Re: Using MessageListener to read up to a limit of message?

). Christopher, can you point to code or documentation that explains how the broker would dispatch more unacknowledged messages than the prefetch buffer size? Kevin, if the wiki (and your assumption) really is correct about how prefetch works, the crucial word here is unacknowledged: your messages

Re: Using MessageListener to read up to a limit of message?

Right, you will continue to receive messages if you process them. The prefetch size is used as an optimization and doesn't have anything to do with message acknowledgement. The broker will always try and keep your prefetch full on your client so you can quickly consume messages. As you process

Re: Do all Message usage have to be within onMessage?

Usually, if you think you might need to rollback a message you should just want to handle that message in onMessage. What is the reason to share messages between threads? Is it just to be able to consume more than one message at a time? If so I would encourage you to just start multiple

Re: Do all Message usage have to be within onMessage?

of implementing it. What is a bit of a cause for stress (for me) is the time it takes to run the unit tests. @Christopher, in addition to not being able to roll back you basically take responsibility for the message. If you don't persist, you risk loosing the message if the consumer process goes down

Re: Using Broker clusters, javax.management.InstanceAlreadyExistsException:xx

Did you set the broker name of the master and slaves to be different? This is usually the cause of this error. You can set the broker name on the BrokerService class or from xml you can set it on the broker element. On Wed, Jun 24, 2015 at 2:26 AM, softwbc soft...@163.com wrote: ActiveMQ

Re: Exception when stopping an embedded broker

There should be a nested exception that displays what the real error is. The BrokerStoppedException is the result of another error and it is hard to tell what is going on without the real exception causing the issues. Is there any more to the stack trace? On Fri, Jun 19, 2015 at 6:36 AM, pubudu

Re: ActiveMQ Pooled Session

Hi, It's generally not recommended to use a pool of connections when using a listener container. Pooled connections are mostly useful for Message producers. In fact if you look at the documentation for the DefaultMessageListenerContainer (which is the parent of

Re: ActiveMQ Pooled Session

that indicated whether this setup included a container... Tim On Jun 26, 2015 10:34 AM, Christopher Shannon christopher.l.shan...@gmail.com wrote: Hi, It's generally not recommended to use a pool of connections when using a listener container. Pooled connections are mostly useful for Message

Re: Is there any way to encrypt connectionPassword in LDAPLoginModule

Yeah unfortunately it doesn't look possible right now. I pulled up the source and did some digging and I don't see any current way to specify and encrypted value. If you want, you can go ahead and put a ticket in on Jira and I (or someone else) can take a look at it. On Thu, Jun 18, 2015 at

Re: Is there any way to encrypt connectionPassword in LDAPLoginModule

Anything that goes in activemq.xml can be encrypted because of Spring support (see http://activemq.apache.org/encrypted-passwords.html) Unfortunately, I do not believe there is a way to encrypt a password in the login.config file however. There is also newer way to use LDAP that you could try

Re: Allowing another consumer to have a message (ActiveMQ-CPP)

, 2015 at 6:44 AM, spam trap nospam.1.friedbad...@spamgourmet.com wrote: On Tue, 9 Jun 2015 10:31:02 -0400, Christopher Shannon christopher.l.shan...@gmail.com wrote: OK. Thanks. Now I am looking at the case where we want messages to be redelivered to the same consumer (assume there is only one

Re: How to get number of unacknowledged messages on the broker?

The ManagedRegionBroker keeps track of subscriptions. Inside that broker class it keeps track of queueSubscribers and topicSubscribers. The maps store SubscriptionView objects and they have a method called getMessageCountAwaitingAcknowledgement() that you could use. ManagedRegionBroker will be

Re: Allowing another consumer to have a message (ActiveMQ-CPP)

...@spamgourmet.com wrote: On Wed, 10 Jun 2015 12:32:00 -0400, Christopher Shannon christopher.l.shan...@gmail.com wrote: OK. I've tried this. However when I create the new consumer object, nothing is consumed and I notice that there are no messages in the queue to consume. Any ideas why

Re: advisory messages username logging

No problem, let me know if you have any more questions. Chris On Tue, Jun 16, 2015 at 9:13 AM, ALi osat...@gmail.com wrote: Thank you very nice explanation I will try in this manner

Re: advisory messages username logging

://ActiveMQ.Advisory.Consumer.Queue.TEST.Q, JMSPriority=0} perhaps the headers are twice (i dont remember my last editiion) and i dont see the user in this log (guest) the username in jmx is null On Tue, Jun 16, 2015 at 1:42 PM, Christopher Shannon christopher.l.shan...@gmail.com wrote: Advisory messages delivered

Re: Allowing another consumer to have a message (ActiveMQ-CPP)

With individual acknowledgement, if you don't acknowledge the message it will be kept on the broker and tracked until you either acknowledge it or close the consumer. If you close the consumer it should be redelivered to another consumer. With transactions you need to explicitly call commit or

Re: Errors trying to build ActiveMQ-5.5.1 from source

I'm not entirely sure why it's giving that error, but it could be related to your version of maven. Just out of curiosity, why are you trying to build a version that is so old? Would it be possible to upgrade to a more modern version of ActiveMQ? On Tue, Jun 16, 2015 at 2:02 PM, bbuzzard

Re: Errors trying to build ActiveMQ-5.5.1 from source

That is an error that was fixed in later versions of ActiveMQ. ActiveMQ 5.8.0 should work because the interface methods in MapContainer have been changed to fix that error. It has to do with the compiler checking type erasure and it seems that maybe the newer compilers are stricter about that.

Re: advisory messages username logging

}, readOnlyProperties = true, readOnlyBody = true, droppable = false} 20150617-08-33-20 it seems that connection messages arent printable On Tue, Jun 16, 2015 at 4:00 PM, Christopher Shannon christopher.l.shan...@gmail.com wrote: No problem, let me know if you have any

Re: advisory messages username logging

... the connectioninfo is not in the advisory of connection (perhaps it must be in the connection if i make a filter but i wanted to do it by configuration just to log the user that connects to a topic/queue) On Wed, Jun 17, 2015 at 1:23 PM, Christopher Shannon christopher.l.shan...@gmail.com wrote

Re: advisory messages username logging

Advisory messages delivered to ActiveMQ.Advisory.Connection will contain a ConnectionInfo object as part of the data structure field of the message. That object will contain the user name used for the new connection. Passwords will always be cleared, however. On Tue, Jun 16, 2015 at 5:41 AM, ALi

Re: Errors trying to build ActiveMQ-5.5.1 from source

You can't use JDK 8 to build a version that old, try using JDK 6. JDK 7 support was added in ActiveMQ 5.7.0 and JDK 8 support was added in ActiveMQ 5.10.0 On Fri, Jun 12, 2015 at 11:54 AM, bbuzzard billy.buzz...@bnsflogistics.com wrote: Yes I know there are newer versions, but I'm trying to

Re: ActiveMQ(MQTT) crash when subscribe

Minor correction...the version in master is 5.12-SNAPSHOT On Tue, Jun 30, 2015 at 10:39 PM, Christopher Shannon christopher.l.shan...@gmail.com wrote: Is the full stack trace in a log file that you could paste? It would make it easier to track down where the out of bounds exception happened

Re: Transport failed, please helpT_T

I don't think there is enough information here to really solve the issue. The EOFException just means that the clients have been disconnected but it doesn't say why. It could be a number of reasons including network issues causing the disconnect or exceptions on message receive, etc. Can you try

Re: Connection reset by peer warning without useful info.

The serviceTransportException method only logs what you see. A code change would be needed to add extra information to the log like connection id. On Tue, Jun 30, 2015 at 6:17 AM, bansalp bpradee...@gmail.com wrote: Hi, I am using ActiveMQ 5.11.1 and getting this error quite often (more as

Re: AMQ pauses sending to consumers

Does the producer stop sending messages or is the producer still sending and the Consumer is hung? If the producer is blocked and waiting it could be flow control kicking on: http://activemq.apache.org/producer-flow-control.html On Thu, Aug 20, 2015 at 11:37 AM, Richard Sinek

Re: Download Integrity FAILING Unexpected EOF

I just downloaded the release from the apache site and I verified the md5 signature as d04620cbd9912ebfd85c3b4d736ac214 Can you try it again and see if it works for you now? On Mon, Aug 3, 2015 at 10:10 PM, andrewhelicopter andrew.mo...@petcircle.com.au wrote: Hello, So I've tried to

Re: ActiveMQ upgrade from 5.5.1 to 5.10.2

There is some information here on an old thread: http://activemq.2283324.n4.nabble.com/Upgrade-from-5-5-1-to-5-9-td4680777.html On Fri, Jul 31, 2015 at 8:26 AM, geekcoder ravi.chakravar...@gmail.com wrote: Hi All, Planning to a do a upgrade from 5.5.1 to 5.10.2 for our client. Would like

Re: Store percent used

that problem would manifest as something visible from within the broker like what Mark has described, only from the outside when examining the file system. Tim On Mon, Jul 27, 2015 at 3:06 PM, Christopher Shannon christopher.l.shan...@gmail.com wrote: If you are using KahaDB you might

Re: Depending on TransportListener for cache consistency

I don't know the exactly details of your use case but this seems reasonable to me as long as you account for the fact that messages could still be lost or not received in a timely matter even if there isn't a broker restart or lost connection. An example where a message could be lost is if the

Re: Redeliverypolicy per detination in Spring

You don't need a getter to call a setter with spring injection. Your problem is your attempting to call a protected setter. Change your redeliverPolicyMap configuration to: bean id=redeliveryPolicyMap class=org.apache.activemq.broker.region.policy.RedeliveryPolicyMap property

Re: Maven dependencies

The easiest way to figure out dependencies is probably to just look at the parent pom that ActiveMQ is using. Here it is on github for 5.11.1 https://github.com/apache/activemq/blob/863e8a5d1ba38f262bdbec4484d704fba8e4f695/pom.xml Your specific issue is that you have mismatched versions of

Re: Getting continuous integration for ActiveMQ *much* faster using CircleCI.

I've been thinking about how to improve the speed of builds as well and I think the biggest thing is just getting the tests to run in parallel, regardless of whether or not some form of continuous integration is used. Maven supports parallel tests but it would be more work than just splitting up

Re: ERROR: Compilation error in web-console with Java 1.8

This is a known issue: https://issues.apache.org/jira/browse/AMQ-5356 It has to do with the Jetty version that is being used not playing nicely with JDK 8. 5.12.0 is going out soon but I plan on upgrading Jetty to a newer version to fix this problem soon. Probably version 5.13.0. (or maybe a

Re: Store percent used

If you are using KahaDB you might be running into a limitation of mixing destinations with fast message rates vs slow message rates. Gary wrote a good blog post about it here: http://blog.garytully.com/2011/11/activemq-multiple-kahadb-instances.html Take a look at that and see if it helps you.

Re: Error on page latest release 5.11.1

Tim, you are correct. This is an issue with multiple web servers. The only solution is to upgrade to a newer version of the application/web server that is having the issue or to downgrade to Java 7. Jetty 7 and 8 also have this problem but Jetty 9 should work, for example. On Sat, Jul 25, 2015

Re: How to use persistenceAdapter for persistent Scheduled Messages ?

You need to configure a custom JobSchedulerStore outside the persistence adapter. You can use the setJobSchedulerStore method in BrokerService or do this in xml with something like the following: broker brokerName=static-broker1 dataDirectory=${activemq.data} persistent=true

Re: ActiveMQ 5.12 release date ?

I don't have an exact release date but 5.12 is in the process of being wrapped up right now so it should be released soon. On Thu, Jul 23, 2015 at 2:39 AM, khandelwalanuj khandelwal.anu...@gmail.com wrote: Hi, I just want to know about ActiveMQ-5.12 release date. It has a very important fix

Re: Receiving messages in a topic works local, but not remote

First, with your clients, did you call start on the connection? It's a common mistake and easy forget to do but I'm guessing you did that since it worked with an embedded broker. Second, are you connecting with your MessageListener before publishing your messages or after? Your message consumer

Re: ActiveMQ uses 100% CPU

To elaborate on the thread dump, it would be good to know the specific thread that is using the CPU usage. If using linux, you can run top -H and that will show you the PID of each of the individual threads. You can then find the PID with the highest cpu usage and convert it to hex. Then look

Re: how to disable InactivityMonitor with ActiveMQ 5.7.0.fuse-71-047 ?

;wireFormat.maxInactivityDuration=0/ /transportConnectors On Tue, Jul 14, 2015 at 10:37 AM, Jason Vas Dias jason.vas.d...@gmail.com wrote: On 14/07/2015, Christopher Shannon christopher.l.shan...@gmail.com wrote: The useInactivityMonitor option appears to have been added in 5.3.0

Re: ActiveMQ(MQTT) crash when subscribe

It's difficult to track down the cause based on what you have provided because unfortunately the full stack trace is missing for the ArrayIndexOutOfBoundsException. The broker needs to be updated to log the full stack trace which I can update. I can let you know when the latest snapshot has that

Re: ActiveMQ(MQTT) crash when subscribe

of the ArrayIndexOutOfBoundsException that you are getting. On Tue, Jul 14, 2015 at 9:42 AM, Christopher Shannon christopher.l.shan...@gmail.com wrote: It's difficult to track down the cause based on what you have provided because unfortunately the full stack trace is missing

Re: how to disable InactivityMonitor with ActiveMQ 5.7.0.fuse-71-047 ?

The useInactivityMonitor option appears to have been added in 5.3.0 and maxInactivityDuration even earlier than that. You can set the properties on your connection string in the client. For example: tcp://localhost:61616?transport.useInactivityMonitor=falsewireformat. maxInactivityDuration=0

Re: Message getting stuck on topic, leading to KahaDB log files not being deleted and disk running out of space.

esi...@gmail.com> wrote: > Hi Christopher, thanks for quick responds. > > I have some further information regarding my setup. > > Regarding the client ID and subscription ID, I am using the same value > (i.e. > "client-1") as the clientID and durableSubscriptionName. >

Re: Message getting stuck on topic, leading to KahaDB log files not being deleted and disk running out of space.

Nevermind, I just double checked the expiration task. It will only browse up to 400 messages, but expired messages are not counted in that number so that probably isn't the issue. On Mon, Oct 26, 2015 at 12:35 PM, Christopher Shannon < christopher.l.shan...@gmail.com> wrote: >

Re: Message getting stuck on topic, leading to KahaDB log files not being deleted and disk running out of space.

How fast are messages being sent to the topic? By default, the expire messages task only pages in the max browse page size (which defaults to 400 messages) before stopping. So one thing to check would be if your incoming message rate is faster than the broker can keep up with expiration. On

Re: Dead Letter Queue and detect message

is described here: http://activemq.apache.org/per-destination-policies.html On Tue, Nov 10, 2015 at 12:31 PM, Christopher Shannon < christopher.l.shan...@gmail.com> wrote: > Yes, you can listen to the advisory messages for DLQ'd messages. An > advisory will be sent when a message is

Re: Dead Letter Queue and detect message

Yes, you can listen to the advisory messages for DLQ'd messages. An advisory will be sent when a message is moved to DLQ and the advisory will contain a copy of the message. The advisory topics to listen on are ActiveMQ.Advisory.MessageDLQd.Queue and ActiveMQ.Advisory.MessageDLQd.Topic Take a

Re: Amq 5.12.1 Failing to start with Oracle Data Store

This was solved here https://issues.apache.org/jira/browse/AMQ-6038 The problem was commons pool was updated to a new version. On Wed, Nov 11, 2015 at 9:25 AM, Tim Bain wrote: > Clearly DBCP isn't on the classpath and the solution is to get it in the > classpath; the

[ANNOUNCE] Apache ActiveMQ 5.12.1 Released

Hi everyone, Apache ActiveMQ 5.12.1 has now been released. This release contains a number of improvements and bug fixes found since the 5.12.0 release. A list of issues fixed in this release is available here: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311210=12333269

Re: Active MQ Message Processing Failed

Which version of the broker and client are you using? If you are using an older version of the broker or the client you could try updating to newer versions to see if the problem still exists. If you are using the newest versions, are you able to reproduce this issue in a unit test or test case?

Re: Fwd: Warning from users@activemq.apache.org

Yeah, I got this message last week as well. As you said it seems to be fine and I continue to get messages. On Thu, Jul 9, 2015 at 9:40 AM, Tim Bain tb...@alumni.duke.edu wrote: OK, then I won't bug my email provider about it. Thanks for the confirmation. On Thu, Jul 9, 2015 at 7:34 AM,

Re: Disabling SSLv3 in embedded web-console jetty

If you are using JDK 8u31 or greater, SSLv3 is disabled by default. The typical way to disable a cipher is to use the addExcludeProtocols method on the ssl context factory, such as: sslContextFactory.addExcludeProtocols(SSLv3); I'm not sure if there is an easy way to do this with a websocket

Re: ActiveMQ Brokers starts the reindex of the KahaDB on every startup

Tim, I think you are referring to this fix here: https://issues.apache.org/jira/browse/AMQ-4832 Looks like it was done in 5.9.1 and later. There's also been some other fixes and improvements done in this area recently so I would definitely recommend upgrading to a more recent version and giving

Re: STOMP over secure websocket

You should just use wss://myurl:61616 for your URL. I don't believe you need the stomp+wss at the end. On Wed, Aug 26, 2015 at 9:01 PM, ArturoBelano lauraerinm...@gmail.com wrote: I configured and restarted activemq according to the documentation to allow ssl, wss and stomp+ssl (abbrevated

Re: Is there any way to encrypt connectionPassword in LDAPLoginModule

Yeah I can take a look at getting that into 5.13 or 5.12.1. It's kind of a pain to do because the module is instantiated using reflection so it isn't as simple as just using the spring encryptor that's already there but I can figure out something to get the password encryption to work. On Mon,

Re: activemq5.11 producer speed and consumer speed is lower,why?

What do you mean by "test message from supplier to consumer is 12000"? A lot of things factor in to the performance of ActiveMQ such as message size, persistent/non-persistent messages, disk speed, message selectors, number of consumers and producers, etc. 3000 mps is a reasonable speed

Re: ActiveMQ JDBC persistence with MSSql

The class can't be found because it isn't part of dbcp 2. org.apache.commons.dbcp.BasicDataSource is the package for dbcp 1.x not 2.x Take a look at: https://commons.apache.org/proper/commons-dbcp/apidocs/org/apache/commons/dbcp2/BasicDataSource.html You should be using

Re: ActiveMQ exits on startup with UTFDataFormatException: bad string

OpenWire v11 was introduced in 5.12.0. Can you try using a 5.11.1 client with a 5.12.0 broker? I'm curious to see if the error still exists if the OpenWire version falls back to v10. On Sat, Sep 12, 2015 at 11:14 AM, Tim Bain wrote: > The interesting line in the stack

Re: how do you test rollback with an embedded broker?

Your problem is you are always creating a new consumer in your consume() method but never closing it. So the consumer is sticking around and hanging onto messages in prefetch. You either need to reuse your message consumer (call receive() on the same open consumer after rollback because it's

Re: how do you test rollback with an embedded broker?

; > - Prefetch is an issue because you shouldn’t assume it’s going to be > sent > > > to a specific connection unless prefetch is 0… > > > > > > - The redelivered message is always sent back to the consumer that > > > originally consumed the message , if it’s sti

Re: Stomp over websocket connections timeout/hearbeat

I think you can also configure the heart beat in the connect frame of a STOMP session by setting the heart-beat header. https://stomp.github.io/stomp-specification-1.1.html#Heart-beating On Mon, Sep 28, 2015 at 12:14 PM, Christopher Shannon < christopher.l.shan...@gmail.com> wrote: >

Re: Nothing on queues, Journal files not getting cleaned up

There is no option to compact KahaDB. The current solution for the problem of journal files not being cleaned up is to use multi kahadb. Gary has a good post about it here http://blog.garytully.com/2011/11/activemq-multiple-kahadb-instances.html There's a couple open tickets to add compaction

Re: Stomp over websocket connections timeout/hearbeat

Yes you can use heartbeats and it gets configured by using the inactivity monitor settings. There was also a bug just fixed for it in 5.12.0: https://issues.apache.org/jira/browse/AMQ-5155 To configure this on the server side you just need to set the inactivity monitor for the timeout period you

Re: Not able to receive the events in the client

What is the exact error message that you are getting? Is there a stack trace? On Mon, Sep 21, 2015 at 2:10 PM, neelam wrote: > Hi All, > > I have a requirement where I need to monitor active MQ events. For this I > have created two Java clients, 1st where I publish the

  1   2   3   4   >