Re: Can I make createQueue on embedded broker session create a queue on the remote broker as well?

e when using > the dynamic network setup (other than messages not being sent until a > consumer is available)? > > On Thu, Jun 18, 2015 at 6:29 PM, Tim Bain wrote: > > Have you set up your dynamically included destinations as described by > the > > "dynam

Re: Potential threading bug in MemoryMessageStore.

pening not that > often . Maybe a test could be created to try to introduce the race. > > On Thu, Jun 18, 2015 at 9:57 PM, Tim Bain wrote: > > > Did you look at this any further? Looking at the code, it looks like the > > call will be protected without explicit s

Re: How to get added to the support page as a listed company

I can make that change. All the other entries on that page use third-person voice, so to be consistent how about the following: TytoEASE offers support, consulting and training on enterprise ready open source projects including ActiveMQ. Support offerings are a

Re: ActiveMQ master-slave topology issue[BUG]

come master. That seems like a very unlikely scenario, but easy enough to guard against by doing the read-before-write that you asked about, so I think it's worth doing. Tim On Fri, Jun 19, 2015 at 10:19 AM, James A. Robinson wrote: > On Mon, Jun 15, 2015 at 7:08 AM Tim Bain wrote: &

Re: Active MQ 5.11.1 MQTT Message is automatically sent to subscriber when it is connected

I'm at a bit of a loss. Your expectation that a durable subscriber should only get delivered those messages it hasn't already received is correct, so there's probably a bug here. I'd like you to submit a bug in JIRA along with your broker config and client code and a description of the behavior (

Re: unable to reconnect after exception "Channel was inactive for too long"

ecting quickly. > > I don't think my application can really control which port it is getting > moved to, that would be decided after I connect to the server on 61616 and > we negotiate to a new port. > > Are there any transport connector options on the client or server that

Re: Performance issues regarding authentication

Since you're not getting any response here, I'd recommend you submit an enhancement request in JIRA. If there's a better way to do this, you'll get that feedback, and if there's not, you'll get a fix (eventually). Tim On Mon, Jun 15, 2015 at 7:16 AM, Shilen Patel wrote: > Hi folks, > > I'm run

Re: Active MQ 5.11.1 MQTT Message is automatically sent to subscriber when it is connected

If I understand correctly, what you're saying is that the messages that were being redelivered each time were doing so because they'd been sent with the RETAIN flag set, which (according to that page) means that they are supposed to

Re: ActiveMQ does not keep durable subscription when re-start

I agree with Tim: you haven't provided enough details about your configuration and your test case when asking for help. (The same was true for your issue that turned out to be the RETAINED flag; knowing how many and which messages were being re-delivered might have made it easier to zero in on the

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

I had always understood it as Kevin did: that the prefetch size (which is computed on the broker) was the number of outstanding, unacknowledged messages that the broker had dispatched to the consumer, and that once the number of unacknowledged messages equaled the prefetch limit, the broker would s

Re: activeMQ and MariaDB 10.

Are you telling us that you've tried and couldn't get it to work, or are you asking for pointers before you try? On Mon, Jun 22, 2015 at 7:16 AM, eyal wrote: > Hello, > has anyone succeeded running activeMQ while its system DB was MariaDB > 10.0.x > ? > if so, > can you please share any configur

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

If his understanding is correct, the last paragraph of Chris's first response in this thread seems especially relevant: if you're going to spawn work off into other threads while using transactions (as implied by your reference to commit() in the other post), you either need to wait for your worker

Re: questions on virtual topics and failover, useVirtualTopics=true

Did you set up forwarding between the brokers? See the Dynamic Networks section of http://activemq.apache.org/networks-of-brokers.html. Note that I vaguely remember others having found they have to set an attribute on the element along the lines of virtual="true"; search the archives for more de

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

Waiting to return from onMessage() till its work is completed on the other thread sounds like it should give you what you want. On Jun 23, 2015 3:53 PM, "Kevin Burton" wrote: > > If you want to pause message acknowledgement and wait before consuming > more > > messages then you should probably us

Re: questions on virtual topics and failover, useVirtualTopics=true

The thread I was thinking of is http://activemq.2283324.n4.nabble.com/How-to-forward-a-topic-using-network-of-brokers-td4696688.html#a4696745, though it doesn't mention any attribute along the lines of virtual="true". On Jun 23, 2015 12:20 PM, "breakbad" wrote: > So I simplified my test to remove

Re: questions on virtual topics and failover, useVirtualTopics=true

for '.', which would mean the broker doesn't know that your consumer queue is related to your virtual topic (which would produce the behavior you're seeing). If so, fix that and try the single-broker test again and see if that gets it working. On Jun 23, 2015 9:42 PM, "Tim

Re: questions on virtual topics and failover, useVirtualTopics=true

s that get forwarded. In practice, this may make it impossible to use virtual topics as you'd want to in a network of brokers. The thread where I described what I deduced is http://activemq.2283324.n4.nabble.com/Bridging-virtual-topics-td4696791.html#a4696794 Tim On Jun 24, 2015 6:50 AM, &q

Re: Rfresh org.apache.activemq.broker.SslContext from disk/jks content

Matteo, if you'd like to be able to do this (in a future version of ActiveMQ), I encourage you to submit an enhancement request in JIRA, including Gary's description of approximately what would be required to implement it. On Jun 25, 2015 4:40 AM, "Gary Tully" wrote: > it is a limitation. the thr

Re: ActiveMQ does not keep durable subscription when re-start

ubscriber. > < > http://activemq.2283324.n4.nabble.com/file/n4698085/durable_restartgateway.png > > > < > http://activemq.2283324.n4.nabble.com/file/n4698085/durable_jmx_restartgateway.png > > > > 5. At the time restart the broker, MQTT client can connected and c

Re: Active MQ 5.11.1 MQTT Message is automatically sent to subscriber when it is connected

to the client > even the message already delivered to this client before. > > Thank you, Tim, for your time following my problem. > > > Tim Bain wrote > > If I understand correctly, what you're saying is that the messages that > > were being redelivered each time were

Re: ** JMS Client HANGING - AMQ 5.9, AIX 6.1

The stack trace you quoted is irrelevant; it's just executors waiting to be given work to do. There are also lots of threads trying to read messages from sockets in org/apache/activemq/transport/tcp/TcpBufferedInputStream.fill() or waiting for a message to be available during a call to org/apache/

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

"Stopped the second" == "stopped the slave of each pair"? Or something else? When the "second" (whichever one you meant) is running, have you connected to it using JMX (via JConsole or similar) and confirmed that its name is in fact what you expect it to be? Tim On Thu, Jun 25, 2015 at 6:38 PM,

Re: ** JMS Client HANGING - AMQ 5.9, AIX 6.1

e expecting add the option > wireFormat.maxFrameSize= to the TCP/NIO transport > connector definition in activemq.xml. This will cause the sending of > messages larger than the configured threshold to fail. > > > Thanks, > Paul > > On Fri, Jun 26, 2015 at 10:01 AM, Tim B

Re: ActiveMQ Pooled Session

Chris, Would that advice (to not use pooling if you client was solely a consumer) apply even if the OP was not running inside a container? I didn't see anything in the description that indicated whether this setup included a container... Tim On Jun 26, 2015 10:34 AM, "Christopher Shannon" < chri

Re: Broker queue attributes not displayed in jconsole with active mq 5.9.0

Is the icon (folder vs endpoint) the only thing that was wrong? If memory serves, I've been able to view the attributes of destinations even when the icon showed as a folder... Is option 3 not "remove the really old copy of the ActiveMQ client JAR from the webapp dir and replace it with the 5.9.0

Re: ** JMS Client HANGING - AMQ 5.9, AIX 6.1

When this is happening, how often are full GCs happening and how long are they taking on average, and are young gen GCs occurring between the old gen GCs? Also, do you believe that the compaction phase ( https://www-01.ibm.com/support/knowledgecenter/mobile/#!/SSYKE2_6.0.0/com.ibm.java.doc.diagnos

Re: ActiveMQ broker is stopping after it is unable to destroy inactive durable subscriber.

Did you read Paul Gale's email from 9/20 to see if his root cause could be yours as well? If it's not, Anuj and bansalp both replied to that thread later to say they saw the same problem; maybe the three of you can work together to figure it out and tell the rest of us... On Jun 30, 2015 6:09 AM,

Re: Is jdk required?

Can you provide the URLs of the docs (I assume you're referring to pages on the wiki) that imply that a JDK is required so they can be clarified? Tim On Tue, Jun 30, 2015 at 2:33 PM, Timothy Bish wrote: > On 06/30/2015 03:53 PM, harry wrote: > > Not clear to me if jdk is actually required to be

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

Clearly your master brokers have "master" in the name; do your slaves have "slave" in the name when viewed in JMX? That was the question I was asking. Have you confirmed (via ps -ef or something similar) that no other processes are running ActiveMQ on the host in question? And are you running an

Re: Transport failed, please helpT_T

Assuming that intranet == "stable network without any firewalls, misconfigurations, or hiccups" sounds like a huge mistake to me, and even more so when you've posted a question indicating that your logs are full of messages indicating that you have connection problems. That's not to say that there

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

I'm guessing here because I don't really know the relevant code, but maybe when you don't set useJmx="true", it's creating two different JMX contexts for your broker? I can't explain why that would be, but maybe someone else here can. However, another user appeared to have the same problem two ye

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

Are you able to make a minimal test case that illustrates the problem consistently and quickly? (Ideally this would be a single consumer on a single destination; the simpler the better.) If you can make something that someone else can easily run to demonstrate the problem, one of us would be able

Re: ActiveMQ advantages/disadvantages with/ without SSL

The only ActiveMQ-specific aspect of this question is that to use SSL you have to configure it appropriately: http://activemq.apache.org/how-do-i-use-ssl.html. So there's a cost of a small amount of effort. Otherwise you can research whether you should use SSL in general via Google: https://www.g

Re: If my ActiveMQ brokers are down, how do I tell my producer to stop blocking the thread?

The failover transport will retry forever by default, so a failure to connect will never result in control being returned to your code. If you want that, you can set the maxReconnectAttempts URI option to return control after a certain number of successive failures. See http://activemq.apache.org

Re: Active MQ Message Processing Failed

Art, is there a known issue with the cacheEnabled URI option that would make you expect it to change this behavior? Or are you suggesting it simply because it will change what gets written to the wire and so it might avoid whatever bug might be causing this behavior? Either is fine (especially if

Re: DemandForwardingBridge stops after network error

If there are transactions (and persistent messages), you'd actually get redelivered messages, not lost messages, when you restart the broker. Neither one is ideal, but it might be less of a problem than lost messages. Are there other relevant log lines on either broker prior to the one you quoted?

Fwd: Warning from users@activemq.apache.org

Every month or two I get a message like the one below indicating failure to deliver a few messages to me. Without me doing anything, everything goes right back to working normally, so I assume there's some transient failure somewhere, but I have no idea what it is. Do other people get these as we

Re: Transport failed, please helpT_T

roblems. > > 3. the Version I use is 5.10.0, sorry for missing that. > > > Tim Bain wrote > > Assuming that intranet == "stable network without any firewalls, > > misconfigurations, or hiccups" sounds like a huge mistake to me, and even > > more so

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

OK, then I won't bug my email provider about it. Thanks for the confirmation. On Thu, Jul 9, 2015 at 7:34 AM, Timothy Bish wrote: > On 07/09/2015 09:29 AM, Tim Bain wrote: > > Every month or two I get a message like the one below indicating failure > to > > deliv

Re: Client reaction to server failure

I believe there is no way to guarantee once-and-only-once delivery in the face of failures; there will always be race conditions that allow the two sides of the interaction to believe different things about whether the transaction succeeded or failed, and you have to choose whether you'd rather hav

Re: Is jdk required?

I've updated the content on the wiki ( https://cwiki.apache.org/confluence/display/ACTIVEMQ/Getting+Started); it should be automatically pushed to the web site within a day. On Tue, Jun 30, 2015 at 4:21 PM, harry wrote: > This is the link which i found. > > http://activemq.apache.org/getting-sta

Re: supported versions

I added https://cwiki.apache.org/confluence/display/ACTIVEMQ/How+does+ActiveMQ+compare+to+Artemis and https://cwiki.apache.org/confluence/display/ACTIVEMQ/What+version+should+I+use to the General category of the FAQ; those updates should auto-populate on the web page within a day. On Tue, Jun 30,

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

Requesting the index of the last 100 messages and looking them up on Nabble has worked for me when I get them. On Jul 9, 2015 8:38 AM, "Robbie Gemmell" wrote: > On 9 July 2015 at 14:34, Timothy Bish wrote: > > On 07/09/2015 09:29 AM, Tim Bain wrote: > >> Every month

Re: ActiveMQ uses 100% CPU

Can you take a thread dump so we can see what the various threads are doing? On Jul 13, 2015 2:40 AM, "Kacu" wrote: > Hi, > > I have a strange situation with my AMQ 5.9.0. I describe it here: > http://stackoverflow.com/questions/31314867/activemq-uses-100-cpu > > Maybe, someone knows what is wron

Re: Master / Slave Issue

If your master/slave setup uses KahaDB and shared storage, there is a known possible failure condition where both brokers can become the master if the slave loses its NFS connection and can no longer maintain control of the lock. If you think that might have been your situation (if you discover yo

Re: Enqueue Messages are not deleted from broker

Every message sent to a topic counts as one enqueue, whether it is eventually delivered to zero, one, or many consumers. (Each message delivered to a consumer counts as a dequeue, so you could get zero, one, or many dequeue counts for each enqueue count; do not assume they'll match for topics!) B

Re: unable to reconnect after exception "Channel was inactive for too long"

Jeff, does your keystore work fine up until the error happens and then begin failing (semi-)consistently, or does it fail with this SSL error right off the bat? On Tue, Jul 14, 2015 at 7:06 PM, Hadrian Zbarcea wrote: > Jeff, > > I would start with figuring out the reason for "PKIX path validatio

Re: Are all queues actively serviced or is there potential for unfair servicing?

Kevin, are you still seeing this behavior consistently? On Mon, Jun 8, 2015 at 7:37 PM, Kevin Burton wrote: > I think I’m seeing a situation where the broker isn’t sending messages on > queue A when there are a lot of messages on queue B.. > > I have consumers listening but just not receiving me

Re: Broker queue attributes not displayed in jconsole with active mq 5.9.0

Aditya, I'm never going to recommend downgrading to a version that's almost six years old and for which lots of bug fixes have been made in later versions, so particularly not because you can't get JMX to work for you. And I'm especially not going to recommend that because you spent a small amoun

Re: ActiveMQ uses 100% CPU

Want to tell us what that error message was? JVisualVM isn't the only way to take a thread dump: https://access.redhat.com/solutions/18178 On Jul 15, 2015 2:12 AM, "Kacu" wrote: > I use jvisualvm to do a dump, but when I have 100% CPU I can't do this, > because I get failed message. > I use Wind

Re: unable to reconnect after exception "Channel was inactive for too long"

Jeffrey, In an earlier email, you wrote, "I'm not sure if the Java application ever gets the exception, but if it is, then it's reconnecting quickly." That sounds to me like the problem is *not* happening for Java clients, yet your latest email says "Also, I beleive this happens for both C++ and

Re: ActiveMQ uses 100% CPU

Didn't you say in you SO question that you're using non-persistent messages? What makes you think a persistence store is causing problems if you're not persisting messages? If you finish characterizing your problem, you should be able to narrow in on what the problem actually is; to me that seems

Re: ActiveMQ uses 100% CPU

It's possible that's the cause. It's also possible that it's not. If you finish characterizing your problem, you should be able to tell whether it is or not. Or you could just make the change (though I don't know whether it's possible to configure LevelDB as your temp store provider; I assume yo

Re: message stucks in 4 brokers network

Did you read and apply the Stuck Messages section of the page you linked? Also, is your F5 configured to make clients sticky to a particular broker? ActiveMQ is not like a web server where each request is stateless; you can't bounce a connected client between brokers and have it behave correctly.

Re: Persistent messages sent to queue not picked up by JMS consumer, unless restarted.

Since it sounds like this is easily reproducible, can you try the same setup with 5.11.1? It's entirely possible this is simply a bug that was fixed sometime between 5.7.0 (which is pretty old) and the latest release. If it is, you'll have two options: upgrade to a version that has the fix (the la

Re: Persistent messages sent to queue not picked up by JMS consumer, unless restarted.

I'm glad you found the cause; that's not something that would have crossed my mind even if you had posted the POM. If there was a page on the wiki that you think should have had this information (somewhere you looked when initially setting up your POM or where you looked when you were having probl

Re: Thread spike every 5 minutes

Here's a theory for what those threads are, though it doesn't explain why they got created. Maybe every 5 minutes, something happens that requires lots of threads. The thread pools create a bunch of new threads, the tasks all end quickly, and then the threads sit around waiting for work (which is

Re: ApplicationProgramer throw "Connection Refused"

Here's what I understood your question to be; please tell me if I've misunderstood. "My application throws a 'Connection Refused' exception when it can't connect to my ActiveMQ broker if the broker is not running, which crashes my application. I want my application to keep running even if the Act

Re: FailoverTransport reconnecting too fast on Linux compared to Windows.

It sounds like you're seeing exponential backoff disabled in Linux; if exponential backoff is in use then the delay will increase quickly from 10ms up to whatever max is set (see lines 1145-1151 of http://grepcode.com/file/repo1.maven.org/maven2/org.apache.activemq/activemq-all/5.11.1/org/apache/ac

Re: FailoverTransport reconnecting too fast on Linux compared to Windows.

point client at FailoverTransport:1073 (the catch block of the try/catch in doReconnect()) and see whether the exception is the same in Windows vs. Linux and see if that explains the difference. Tim On Tue, Jul 21, 2015 at 8:07 AM, Tim Bain wrote: > It sounds like you're seeing exponential backof

Re: ActiveMQ replicated leveldb with 2 brokers(replica = 1)

That also means that during a network partition, both brokers can serve clients. Is that really what you want? Tim On Jul 23, 2015 9:16 AM, "khandelwalanuj" wrote: > Hi Jim, > > But I am using replica =1 and > (quorum = replica/2+1) AND quorum != (no of broker/2 +1). > > So in my case a single

Re: Monitoring?

I've used primitive log-monitoring tools such as Swatch to notify us when producer flow control kicked in or when a consumer became slow and was aborted, because those were both situations we were concerned about. I've also written Java code to interrogate the JMX stats for specific destinations a

Re: Monitoring?

don't expect to get all stats for all destinations and clients every 100ms. On Jul 23, 2015 1:52 PM, "James A. Robinson" wrote: > Thank you. I'll explore using nagios check_jmx to query the activemq > MBeans. > > Jim > > > On Thu, Jul 23, 2015 at 11:48 AM

Re: Monitoring?

n it first-hand. Tim On Thu, Jul 23, 2015 at 10:11 PM, James A. Robinson wrote: > I was thinking more like every five minutes. Is it equally expensive to > query via the restful api? > On Thu, Jul 23, 2015 at 21:07 Tim Bain wrote: > > > Keep in mind that remote JMX calls are p

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

And have you confirmed that you updated the URI the client uses so it refers to the new non-local host? It's a basic thing, but could be easy to forget. If you haven't already, enable JMX for your broker. It'll let you see which clients are successfully connected, how many messages are pending f

Re: zookeeper reconnects

James, You've tested two of the three cases; would it be possible to test the third one? - ActiveMQ timeout < ZooKeeper timeout: fails - ActiveMQ timeout = ZooKeeper timeout: succeeds - ActiveMQ timeout > ZooKeeper timeout: ??? If we can zero in on exactly what the recommendation is, I

Re: BlobMessage: fileserver webapp does not work in tomcat

Is the dependency problem simply that you don't have the right JAR on the classpath? (In which case, the solution seems like it should be pretty straightforward...) Tim On Thu, Jul 23, 2015 at 4:46 AM, Jonas Decker wrote: > Hello, > > i try to use BlobMessages with an embedded AMQ_5.11.1 in to

Re: Error on page latest release 5.11.1

java.util.Map.Entry changed its definition from Java 7 to Java 8 (source: http://stackoverflow.com/a/26105217), so it's possible that the installed version of Jasper isn't Java 8 compatible. According to https://blogs.oracle.com/java/entry/glassfish_server_open_source_edition, GlassFish 4.1 should

Re: message stucks in 4 brokers network

If all brokers connect to all other brokers using duplex="false", then you have a complete graph and messages can pass from any broker. So I don't think duplex has anything to do with your problem. (Though if you have a duplex connection from every broker to every other broker, then there are two

Re: zookeeper reconnects

e client ought to reinitialize itself in the event of failures and > sometimes it is not. > On Sat, Jul 25, 2015 at 08:25 Tim Bain wrote: > > > James, > > > > You've tested two of the three cases; would it be possible to test the > > third one? > > > &

Re: Negative count in pending message

The enqueue count didn't increase when you did the second batch of enqueues, which is a bug. I assume you can reproduce this reliably? What version are you using? If it's not 5.11.x, can you please try to reproduce the problem under 5.11.1 to confirm that it's not been resolved in a later versio

Re: message stucks in 4 brokers network

estart the consumer). > > In this case, how to adapt the borkers to make all the messages consumed? > > > > Tim Bain wrote > > If all brokers connect to all other brokers using duplex="false", then > you > > have a complete graph and messages can pass from

Re: BlobMessage: fileserver webapp does not work in tomcat

Ah, I see what you mean now. You can submit an enhancement request in JIRA ( https://issues.apache.org/jira/browse/AMQ/?selectedTab=com.atlassian.jira.jira-projects-plugin:summary-panel) to allow the webapp to work when embedded in any web server. In the meantime, if the fileserver app was a must

Re: Store percent used

If you examine the broker via JMX, do you see an increasing number of messages on the various destinations as the percent usage increases (which would indicate that the deletions are not succeeding)? Have you confirmed that messages are not building up in the DLQ (dead letter queue)? You either n

Re: Store percent used

s the month goes on is definitely a symptom of what > Gary describes in his post. > > On Tue, Jul 28, 2015 at 1:00 AM, Tim Bain wrote: > > > If you examine the broker via JMX, do you see an increasing number of > > messages on the various destinations as the percent us

Re: Destination wildcard at first path token

One trick would be to prepend a meaningless prefix to all destinations that match your pattern, so dev.mycomponent.process becomes a.dev.mycomponent.process and your pattern becomes "a.*.mycomponent.process" which no longer has the wildcard in the first position. It might not be too unpalatable if

Re: Reply message not forwarded across temporary bridged destination

Gary's recommendation to follow the unit test was explicitly for the situation where you are trying "to achieve a bridge with no advisories - so statically configured"; is that actually what you're looking for? If not, why are you trying to follow it instead of using the dynamicallyIncludedDestina

Re: Store percent used

One old message in the DLQ is all it takes to keep every single KahaDB data file after it from being deleted. Not thousands, not hundreds, not tens. One. As currently implemented, KahaDB requires you to choose between a DLQ policy that involves keeping DLQ messages around and a KahaDB storage pro

Re: Store percent used

Hmm, that doesn't sound like the magnitude we were expecting. How old was oldest DLQ message compared to the oldest "live" message? Is there any chance there are old messages in destinations other than the DLQ? (Either queues or durable topic subscriptions.) Your initial description sounded lik

Re: Reply message not forwarded across temporary bridged destination

Thanks for clarifying your use-case. In response to your original questions: 1. getPhysicalName() returns a String, which allows wildcards (*, >, and I think <, though that might be a 5.11 feature, I don't remember). 2. The staticallyIncludedDestinations attribute controls which desti

Re: ACTIVEMQ_CLASSPATH

Yes, file a bug requesting that Unix-style separators be the only one accepted in Unix-like OSes. Java classpath are supposed to use the local OS separator; if we're not doing that, we're doing it wrong (and the result is broken behavior when someone tries to follow the standard convention and we

Re: User Memory Issues

Later versions give a few addition stats (such as average message size) via JMX, but that won't help you till that upgrade in production is complete. Do you have producer flow control enabled? The error you're getting doesn't match what I remember it being the last time I hit it, so I'm assuming

Re: java.lang.ClassNotFoundException: org.apache.xbean.spring.context.v2.XBeanNamespaceHandler

Have you confirmed that xbean-spring.jar is actually making it into your EAR and then onto the classpath? On Aug 18, 2015 1:59 AM, wrote: > Hi, > I have a Artemix-Spring-Arquillian setup. I am loading some bean from > spring-beans-embedded.xml using the 'import' statement in > applicationCont

RE: java.lang.ClassNotFoundException: org.apache.xbean.spring.context.v2.XBeanNamespaceHandler

schemaLocation="urn:activemq > /schema/artemis-server.xsd"> > > > > > > > > > false > > > vm://0 > > > > > > > > > > > > > &g

Re: What is the correct way to throttle ActiveMQ producers who send persistent messages in batches to a queue?

I think you might be misunderstanding the (not very clearly written) content on the PFC wiki page. (Either that, or my understanding of PFC is wrong.) As I understand it, the references to differences in behavior for async senders on that page are not between performing and not performing PFC, bu

Re: java.lang.ClassNotFoundException: org.apache.xbean.spring.context.v2.XBeanNamespaceHandler

; > Are all these needed ? > activemq-spring( 5.8.0 ) , artemis-server( 1.0.0 ) and artemis-jms-server > ( 1.0.0 ) > > > Thanks, > Mohan > > From: tbai...@gmail.com [tbai...@gmail.com] on behalf of Tim Bain [ > tb...@alumni.duk

Re: What is the correct way to throttle ActiveMQ producers who send persistent messages in batches to a queue?

I understand that, and I agree with you that it doesn't seem like expected behavior. My point was that I don't believe what you're seeing is specifically because of asynchronous sends, though I can't say for sure, and I gave you an easy way to test whether asynchronous sends do indeed produce the

Re: User Memory Issues

mb and still had an issue. It's very hit and > miss. I can run for a week without issue, then when I get hit hard, it > falls over. > > > > > On 8/18/15, 5:58 AM, "tbai...@gmail.com on behalf of Tim Bain" < > tbai...@gmail.com on behalf of tb...@alumni.duke.

Re: Durable client removal caused broker to shutdown in replicated leveldb

On Aug 19, 2015 7:41 AM, "Tim Bain" wrote: > It looks like the broker shut down because LevelDB wasn't running (or > thought it wasn't because its test of whether it was running failed). Were > there any system-level failures that happened around the same time? In

Re: What is the correct way to throttle ActiveMQ producers who send persistent messages in batches to a queue?

Hey James. The PFC documentation is very clear that async producers will not be notified when PFC kicks in, and that per-producer PFC will not be used. It does not say that whole-connection PFC won't kick in, and I believe that it will, as I outlined in my first response. From the Advantage sect

Re: User Memory Issues

ivemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:210) > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84) > at > org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203) > at > org.apache.activemq.transport.tcp.TcpT

Re: AMQ pauses sending to consumers

You'll see messages in the broker logs if PFC is kicking in. Are full GCs taking place? 10 to 15 minutes seems like far too long for that to be likely as an explanation, but it's worth checking. You can always use a profiler and take thread dumps to figure out what's going on when this happens.

Re: User Memory Issues

M, "Daniel Israel" wrote: > Oooh, that's a good idea to add another subber. I may be able to try that. > > Also, could something on the client side cause a backup? Or will the > broker just fall through if a client hangs? > > > > On 8/20/15, 7:18 AM, &

Re: org.apache.activemq.usage.MemoryUsage consumes 95% of the memory?

I see no references to a Map or to a field called callbacks in http://www.grepcode.com/file/repo1.maven.org/maven2/org.apache.activemq/activemq-client/5.11.1/org/apache/activemq/usage/MemoryUsage.java Can you give more details of what you're seeing? On Aug 20, 2015 1:25 PM, "yang.yang.zz" wrote:

Re: User Memory Issues

pending messages. (Note that this only works for topics, and only for non-durable subscriptions, but I think both of those apply to your scenario.) On Aug 21, 2015 12:30 AM, "Daniel Israel" wrote: > > > > > > On 8/20/15, 9:56 PM, "tbai...@gmail.com on behalf of T

Re: Stomp for .NET - Multiple Consumers on 1 Queue

Correct: putting messages in a group ensures that they will be consumed in order by the same single consumer, which is not what you want. On Aug 21, 2015 3:34 AM, "Straal" wrote: > I adapted the code from the examples on the Apache website, but this is for > single consumer. > > Removing the foll

Re: AMQ pauses sending to consumers

When this occurs, are some consumers "paused" while others merrily churn through their backlog, or are all consumers "paused"? Is the rate of publishing messages to each message group relatively uniform, both across time and from group to group? JConsole u s an easy way to get a rough idea of whe

Re: What is the correct way to throttle ActiveMQ producers who send persistent messages in batches to a queue?

James, Thanks for the additional information about the test you ran. Would you mind re-running it with a storeUsage limit of 2 MB? I'd like to test whether PFC isn't kicking in at all, or just isn't respecting the per-destination limit you set via the policy. I know you're interpreting the wiki

Re: Durable client removal caused broker to shutdown in replicated leveldb

I don't see an obvious causal link between those two, though I haven't looked at that code (my usual trick of going to GrepCode didn't work; maybe GC doesn't index Scala code?) so I can't say for sure. Unless you see a causal link I'm missing and want to explain it? Hopefully someone who knows th

Re: AMQ pauses sending to consumers

That disproves the theory that the broker is fully unresponsive due to a full GC. (It was unthinkable that it would take 10+ minutes anyway.) Is the consumer that gets the scheduled messages on a separate queue from the other consumers? Are selectors used by any of your consumers? How many queu

<    1   2   3   4   5   6   7   8   9   10   >