Re: Messages stuck in queue which are not expired

2016-04-14 Thread Martin C.
ain wrote: > Great, thanks for reporting back. > > Tim > > On Fri, Jan 8, 2016 at 1:04 PM, Martin C. wrote: > >> Hello, >> >> sorry for the late response, missed the message. We are currently very >> confident that the issue was triggered because one of the c

Re: Messages stuck in queue which are not expired

2016-01-08 Thread Martin C.
Hello, sorry for the late response, missed the message. We are currently very confident that the issue was triggered because one of the client applications was still using a very old 5.7 library to connect to the 5.12 broker. Once we updated the client library in that particular application, thing

Messages stuck in queue which are not expired

2015-12-02 Thread Martin C.
Hi, We've ran into some problems since we updated to Activemq 5.12.1. Our most busy queue has stuck messages which also do NOT expire. The queue has around 200 producers (each producer has it's own message group, making sure messages of a producer do not overtake each other) which send non-persist

Re: ActiveMQ 5.5 SSL network bridge sometimes fails to re-establish after connection failure

2012-08-28 Thread Martin C.
Hi, This might point you in the right direction, but not sure: > > > http://tmielke.blogspot.com/2011/09/activemq-network-bridge-to-masterslave.html Thanks, I will have a look at this and try to apply it to our situation. > Is this something that can be recreated consistently? > Unfortunately

ActiveMQ 5.5 SSL network bridge sometimes fails to re-establish after connection failure

2012-08-28 Thread Martin C.
Hi, We use a ActiveMQ network-of-brokers accross rather unstable WAN links and use SSL with server/client certificates to protect the data. It is a typical star architecture. On the unreliable links, some of the brokers lose connection to the central broker and fail to re-establish the connection

Re: ActiveMQ needs tempUsage for recovery of persistent messages on startup?

2012-08-27 Thread Martin C.
in the temp-store seems to not be freed. Best regards, Martin On Mon, Aug 27, 2012 at 1:05 PM, Martin C. wrote: > Hi, > > in one of the instances I didn't find anything in the broker log, just in > the client log, in the second log I found the same log entry in both cl

Re: ActiveMQ needs tempUsage for recovery of persistent messages on startup?

2012-08-27 Thread Martin C.
in the store till they are needed. > > On 27 August 2012 10:59, Martin C. wrote: > > Hi Gary, > > > > sorry for getting back to this rather old issue, but I just got an issue > in > > the field (twice) with the configuration below. The broker stopped > &g

Re: ActiveMQ needs tempUsage for recovery of persistent messages on startup?

2012-08-27 Thread Martin C.
On Wed, Nov 16, 2011 at 1:50 PM, Gary Tully wrote: > yes. > > On 16 November 2011 12:01, Martin C. wrote: > > Hi Gary, > > > > thanks for the very fast response. I will change the configuration > > accordingly. So basica

Re: Problem upgrading from 5.5.1 to 5.6.0

2012-07-30 Thread Martin C.
Hi Gary, On Mon, Jul 30, 2012 at 4:26 PM, Gary Tully wrote: > Hi Martin, > that will be problematic because it will lead to a clash of clientids > used by the network connectors. > In your current setup on 5.5.0, can you inspect (on central) the > client id of some of the connected satellite netw

Re: Problem upgrading from 5.5.1 to 5.6.0

2012-07-30 Thread Martin C.
Hi Gary, On Mon, Jul 30, 2012 at 12:19 PM, Gary Tully wrote: > the combination of networkConnector *name* attribute and brokerName of > a network needs to be unique. Can in a network of brokers the individual brokers have the same names (as long as they have different IP addresses obviously)? Th

Re: reading several messages in one transaction

2012-03-21 Thread Martin C.
Hi, yes, this is possible. Best regards, Martin On Tue, Mar 20, 2012 at 7:27 PM, yilativs wrote: > Hello, > > Is it possible to reads several messages from queue/topic in ONE XA > transaction, > write the messages to an other source (database) in same XA transaction, > remove all messages from

Re: how to enable persistent message store?

2012-01-27 Thread Martin C.
Hi, expiration and persistence are something different. A persistent message can still expire, a non-expiring message can still be non-persistent. The difference is: if a message is persistent, it will be available even if the broker restarts, if a message has an expiration, it will be deleted if

Re: Active MQ broker side and clientside timeouts

2012-01-17 Thread Martin C.
Hi, have a look at the maxInactivityDuration setting when configuring the transport. OpenWire for instance sends heartbeat packages when the connection is idle. http://activemq.apache.org/configuring-wire-formats.html Best regards, Martin On Tue, Jan 17, 2012 at 3:13 PM, Zagan wrote: > Hello,

Stomp and message-id?

2012-01-11 Thread Martin C.
Hi, I am aware that there is no way in the official STOMP protocol to get the broker-side message-id of a sent message. But since ActiveMQ supports some other non-standard extensions, is there a way for 5.5.1 to get the server-side message-id as part of the Receipt frame maybe? Thanks in advance!

Re: How can a producer/consumer tell if its connection is still good?

2011-12-14 Thread Martin C.
Hi, you are right, I just read to sloppy, and as most of the traffic on this list is about the Java part, I simply jumped to the wrong language in my mind. In my C++ implementations I use the same recommendation as from Ivan Pechorin, I set the cms::ExceptionListener and have built a very similar

Re: How can a producer/consumer tell if its connection is still good?

2011-12-10 Thread Martin C.
Hi, I'd tend to use Spring's SingleConnectionFactory with reconnectOnException set to true. I'd compare my cached connection against the one returned by the SingleConnectionFactory to know if any other consumer encountered a JMS exception. Basically I'd also treat any JMSException I encounter as

Re: [newbie] can't get brokers on two computers to connect

2011-12-04 Thread Martin C.
Hi, please first ensure your network setup is correct by simply trying to each other's ports via telnet. I think you still have some basic networking issues here. Please also beware that you seem to not create duplex connections, which means that you have to create a connection from both sides.

Recover KahDB from missing db.free?

2011-12-01 Thread Martin C.
Hi, one of our installations suffered a power-outage that seems to have corrupted parts of the filesystem. I am missing the db.free file from the KahaDB directory, which now prevents startup. Is there a way from recovering from this missing file? The situation is in this case not particularly a p

Re: Should Total Message Count decrease?

2011-11-30 Thread Martin C.
sconnected, by the session being timed-out. > > Is there a way to cancel the subscriptions on this destination > programmatically? As at this point in the app I am sure there are no > clients and I just want to clean up. > > Many thanks again for your input. > > Kevin. >

Re: Should Total Message Count decrease?

2011-11-30 Thread Martin C.
curs. > > Any ideas? > > Thanks again, > > Kevin. > > On Wed, Nov 30, 2011 at 6:50 AM, Martin C. wrote: >> Hi, >> >> if TotalMessageCount is not decreasing, this indicates that you are >> either not consuming or maybe not committing the consuming tran

Re: Should Total Message Count decrease?

2011-11-29 Thread Martin C.
Hi, if TotalMessageCount is not decreasing, this indicates that you are either not consuming or maybe not committing the consuming transaction / not acknowledging the messages on the receiving side (depends on your acknowledge mode). Best regards, Martin On Tue, Nov 29, 2011 at 4:39 PM, Kevin Ki

Re: Java app hanging at createTemporaryQueue

2011-11-18 Thread Martin C.
Hi, are you using failover-transport? If yes, you'll need to add a "timeout" parameter to the connection URL, as the default behavior of the failover transport is to wait indefinitely for a reconnect to the broker. Please see http://activemq.apache.org/failover-transport-reference.html for further

Re: ActiveMQ needs tempUsage for recovery of persistent messages on startup?

2011-11-16 Thread Martin C.
> with kahaDB. > > On 16 November 2011 10:26, Martin C. wrote: >> Hi, >> >> I a have a question regarding fileQueueCursor and systemUsage on >> ActiveMQ 5.5.0: Below you see my configuration, which limits the >> memory to 64MB, store usage to 10GB and tempUsa

ActiveMQ needs tempUsage for recovery of persistent messages on startup?

2011-11-16 Thread Martin C.
Hi, I a have a question regarding fileQueueCursor and systemUsage on ActiveMQ 5.5.0: Below you see my configuration, which limits the memory to 64MB, store usage to 10GB and tempUsage to 1GB. I have a KahaDB with about 30 messages, using 330MB in the kahadb directory, all messages are persist

Re: What happened to the camel web application in ActiveMQ 5.5.1

2011-11-02 Thread Martin C.
Hi, the only reason for the 5.5.1 release was https://issues.apache.org/jira/browse/AMQ-3491, which actually is the removal of the Camel Web part, as it introduces a dependency to a LGPL library, which AFAIK is in violation of the Apache guidelines for allowed external libraries. Best regards, Ma

Re: Producer blocks on send method when not connected to broker

2011-10-27 Thread Martin C.
Hi, what transport are you using? If you are using the failover transport, look at the failover options at http://activemq.apache.org/failover-transport-reference.html, especially at the timeout. I noticed that the sendTimeout is not always used when using a failover transport, if the connection i

Re: Known issue with gcInactiveDestinations?

2011-10-14 Thread Martin C.
g useful to it: > https://issues.apache.org/jira/browse/AMQ-3540 > > James > > On 13 October 2011 07:18, Martin C. wrote: > >> I reported a similar issue back in January >> ( >> http://activemq.2283324.n4.nabble.com/Possible-Bug-quot-Deleting-inactive-destination-quot-wi

Re: Known issue with gcInactiveDestinations?

2011-10-12 Thread Martin C.
I reported a similar issue back in January (http://activemq.2283324.n4.nabble.com/Possible-Bug-quot-Deleting-inactive-destination-quot-with-pending-messages-td3229098.html). Unfortunately I never got an answer. It seems to me there might be a bug. I never raised a Jira issue, though. We just stoppe

Re: Spring JmsTemplate Messages not consumed depending on session ID

2011-10-05 Thread Martin C.
Hi, you should use JmsTemplate to send messages only. Have a look at http://activemq.apache.org/jmstemplate-gotchas.html. You should use Spring's DefaultMessageListenerContainer to receive messages. We are using this, it works well. Best regards, Martin On Wed, Oct 5, 2011 at 3:47 PM, James Blac

Re: Is it possible to generate message-id before sending the JMS message?

2011-09-22 Thread Martin C.
QMessage and override > org.apache.activemq.command.ActiveMQMessage#onSend > > on that callback, you will have the messageId and be able to commit > the db transaction. On return from that method the message will be > sent. > be sure and call super.onSend() though. > > On 22 September 2

Is it possible to generate message-id before sending the JMS message?

2011-09-22 Thread Martin C.
Hi, I'd like to know the message ID of a message I am going to send before actually sending it. Is this possible? Reason is that I want to delay sending the JMS messages until my database transaction has been comitted, but I already want to record the message IDs as correlation IDs in exactly thi

Re: Retrieve last message published in a topic

2011-08-30 Thread Martin C.
Hi, you may look into "retroactive consumers" and "retroactive subscriptions". For a starting point, visit http://activemq.apache.org/retroactive-consumer.html and http://activemq.apache.org/subscription-recovery-policy.html Best regards, Martin On Tue, Aug 30, 2011 at 12:00 PM, stratio wrote:

Failed network bridge could not be re-established: "Cannot send, channel already failed"

2011-08-17 Thread Martin C.
Hi, we use a network-of-broker configuration with a central broker and a lot of hubs, all using ActiveMQ 5.5.0. Today, one of the bridges collapsed and could not be re-established. Below you see the log-file. You can see, that first a client connection failed with "Cannot send, channel has already

Re: Random hang waiting to consume a message

2011-08-16 Thread Martin C.
Hi, first, you can use JMX on the broker to disconnect the connection of the hanging consumer. But this is a very rude work-around, of course. We had a similar issue connecting with Java-based consumers. We seem to have found a work-around by disabling caching and tight encoding on the OpenWire w

Re: VM transport

2011-08-12 Thread Martin C.
Hi, On Fri, Aug 12, 2011 at 9:35 PM, Mohit Anchlia wrote: > Thanks! Slightly different question. Is there any reason why one > shouldn't use vm transport? Often it is sensible to have the broker as an external running application, so it is available for procuders / consumers in other processes e

Re: Monitoring when there are no consumers for a destination

2011-08-12 Thread Martin C.
Hi, On Fri, Aug 12, 2011 at 11:47 PM, agujral wrote: > Sorry I was not very clear in my initial post. I want to  know if consumer > count is zero even if I dont know the queue name. The above mentioned checks > will work only when I know the queuename which I dont know in this > particular case.

Re: Monitoring when there are no consumers for a destination

2011-08-11 Thread Martin C.
Hi, besides the advisory approach you can use JMX and monitor the "ConsumerCount" property of any "org.apache.activemq:BrokerName=BROKER_NAME,Type=Queue,Destination=QUEUE_NAME" MBean. You need to replace the ALL_CAPS tokens with correct values. Best regards, Martin On Thu, Aug 11, 2011 at 11:09

Re: How does prefetch work with client acknoledgements?

2011-08-11 Thread Martin C.
Hi, On Wed, Aug 10, 2011 at 6:21 PM, pwanner wrote: > Hi, > > We have also an other broker (same very simple config master/slave on SAN) > for an other app, with a queue and only one consumer that is configured with > Camel (see config below), and this consumer also stop consuming messages, > thu

Re: Dispatch Policy

2011-07-26 Thread Martin C.
Hi, The only issue with Spring's DefaultMessageListenerContainer we have encountered with prefetch 0 was that the stop() method caused threads to keep hanging in the DefaultMessageListenerContainer on shutdown, because the receive(timeout) call of ActiveMQ uses a non-timed-out read to the broker i

Difference between prefetch=0 and prefetch=1?

2011-07-05 Thread Martin C.
Hi, When reviewing ActiveMQ code, I see a lot of special treatment for the prefetch=0 case. What exactly is the conceptual difference between 1 and 0 prefetch? We are currently using prefetch=0 via failover, but are in the process of migrating away from failover to multiple connections with Sprin

Re: AMQ does not drop connection on stomp client ungraceful shutdown

2011-07-03 Thread Martin C.
Hi, it sounds to me that it simply takes that long for the STOMP protocol to realize that the connection died. Maybe you can enable tcp.keepalive on the connection via the configuration URL? You might also have a look at the keepalive options for your transport connection, and if you are on Linux

Re: STOMP transport in embedded Broker not working

2011-07-02 Thread Martin C.
Hi, On Sat, Jul 2, 2011 at 7:18 PM, SketchCND wrote: > Hi Martin, > > Thanks for the reply. I don't believe that this issue is on the client side. [...] Hmm, I suppose you are right and I think my reply might have been meant for another topic. I just need to find it again. Sorry! Best regards,

Re: STOMP transport in embedded Broker not working

2011-07-02 Thread Martin C.
Hi, I just noticed I got the documentation for the C++ project, but I suppose there will be similar settings for the broker itself. Best regards, Martin On Sat, Jul 2, 2011 at 3:11 PM, Martin C. wrote: > Hi, > > maybe http://activemq.apache.org/cms/configuring.html can help, > es

Re: STOMP transport in embedded Broker not working

2011-07-02 Thread Martin C.
Hi, maybe http://activemq.apache.org/cms/configuring.html can help, especially the wireFormat.maxInactivityDuration setting. But I don't know if/how it applies to STOMP connections, but I would also be very interested in this, as it might be that I need to connect some clients via STOMP. Best reg

Re: Producer blocked even after termination of all subscribers

2011-07-02 Thread Martin C.
Hi, I haven't done much work with durable subscriptions yet, but as far as I understand the topic in connection with producer flow control, it is guaranteed that no message is lost for any of the persistent subscriptions. As you have stopped a subscription and once you hit a configured storage lim

Re: Fwd: Message groups enhancement feature request

2011-07-02 Thread Martin C.
Hi, > So it sounds like the current Message Groups behaviour is fine; its > just you want to ensure fair load balancing of the message groups > across consumers right? So if lots of other clients are restarted; the > long running clients could end up claiming too many of the message > groups? Yes

Re: Fwd: Message groups enhancement feature request

2011-07-02 Thread Martin C.
Hi, On Fri, Jul 1, 2011 at 4:00 PM, boday wrote: > Martin, message groups (by design) guarantee that only a single consumer will > process messages for a group at a time. Yes, I am aware of that. My problem at the moment is only, that it will always be the SAME consumer processing the message gr

Re: Fwd: Message groups enhancement feature request

2011-07-01 Thread Martin C.
for a group. Would serve to better randomize the > load across consumers to protect against slow consumers, etc... > > > Martin C. wrote: >> >> Hi, >> >> we currently use message groups to ensure ordered delivery of messages >> within a given group. As not

Fwd: Message groups enhancement feature request

2011-06-30 Thread Martin C.
Hi, we currently use message groups to ensure ordered delivery of messages within a given group. As noted on the documentation for message groups, this often does not scale very well with variable consumer counts, as in this case the oldest consumers will hog all message groups. In our use-case,

Fwd: Saving bandwith in a network-of-brokers with lots of brokers via WAN

2011-06-30 Thread Martin C.
Hi, we plan a setup with lots of remote sites, each of them having their own broker which are then connected via a network-of-brokers via a duplex connector. We'd like to use dynamicallyIncludedDestinations, but even in our small test installation we already see huge amounts of advisory messages.

Re: How can I remove old queues without a java client?

2011-06-16 Thread Martin C.
Hi, Have a look at http://activemq.apache.org/delete-inactive-destinations.html This might be what you want. Best regards, Martin On Wed, Jun 15, 2011 at 11:00 PM, James Green wrote: > Not sure this is even possible? > > We dynamically create our queues by pushing messages to channels with > ac

Re: Upgrade "in-production" from AMQ 5.3 to 5.5

2011-06-14 Thread Martin C.
Hi, first: I'm sure you'll need to test it using your data-store (you could attempt to create a crash-consistent store by simply copying your KahaDB directory). I have had some deployments that went from 5.3.2-fuse to 5.4.2 and now 5.5.0, without losing any messages in the queue. So basically, it

Re: KahaDB storage size grows despite almost no pending messages

2011-06-10 Thread Martin C.
NC_ durable clients that had long been disposed of by > ourselves. After deleting these the subsequent expiring / purging run of > kahadb removed the files and freed up literally gigs of space. > > Hope this helps. It should really be documented as a FAQ! > > James > > On 4 Ju

Re: Not able to load-balance messages in a cluster using PrefetchPolicy

2011-06-09 Thread Martin C.
Hi, just as further input: have you checked you didn't declare an exclusive consumer and you didn't use message groups? Best regards, Martin On Thu, Jun 9, 2011 at 4:38 PM, joe smith wrote: > Hi Edan, > > Yes.  with the springframework's PrefetchPolicy bean, I've used both values.  > Unfortuna

Re: How to set message expiry in activemq

2011-06-07 Thread Martin C.
Hi, have a look at http://download.oracle.com/javaee/1.4/api/javax/jms/MessageProducer.html#send(javax.jms.Message, int, int, long) on how to send messages with a time-to-live set. Best regards, Martin On Tue, Jun 7, 2011 at 9:00 PM, agujral wrote: > Hi All, >        We are using active mq as

KahaDB storage size grows despite almost no pending messages

2011-06-04 Thread Martin C.
Hi, I experience the problem that over time my KahaDB storage fills up despite almost no queue showing pending messages. I upgraded from ActiveMQ 5.4.2 to 5.5.0 because I thought that according to the change log these leaks in KahaDB should be fixed in 5.5.0, but for me it seems they aren't. What

Re: How does prefetch work with client acknoledgements?

2011-05-16 Thread Martin C.
Hi, Prefetching only applies when consuming messages. Best regards, Martin On Mon, May 16, 2011 at 4:12 PM, lernen.2007 wrote: > I need your help. > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Messages-stuck-in-queue-tp3244342p3526298.html > Sent from the Activ

Re: message clears from db if application or activemq restarts..

2011-05-03 Thread Martin C.
Hi, you broker's persistence settings are only used if you send your messages as persistent and not as non-persistent. See http://download.oracle.com/javaee/1.4/api/javax/jms/MessageProducer.html for persistence settings. The JMS default is persistent, but I don't know how you configured your fram

Re: message clears from db if application or activemq restarts..

2011-05-03 Thread Martin C.
Hi, are you using persistent or non-persistent delivery for your messages? Any non-persistent message will be discarded on broker restart (however, I don't know why it would go to the storage in the first place, though). And are you using a time-to-live on your messages, which might have expired

Re: Question on consumers

2011-05-03 Thread Martin C.
Hi, the JMS threading model is based around the Session. Each Session is to be used by one thread. If you are using asynchronous mode (you register a MessageListener with the Session), every Session uses one thread or is to be used by one thread (http://download.oracle.com/javaee/1.4/api/javax/jms

Re: Usage memory Limit hit with Network of Brokers.

2011-05-03 Thread Martin C.
Hi, On Tue, May 3, 2011 at 11:20 AM, Gary Tully wrote: > In your setup, when one of the networked brokers goes > down it becomes (looks like) a very slow consumer. Is there a way to "de-register" a broker in such a scenario, if it goes down intentionally "forever"? Best regards, Martin

Re: Messages stuck in queue

2011-05-02 Thread Martin C.
Hi, we are using prefetch=0 with Spring, works well, still we are seeing the same issue but for _non-persistent_ messages. (With prefetch=0 and with prefetch=1.) Any ideas if this could correlate to the issues mentioned here? As an interesting side-effect, the consumption starts again if we delet

A single connection with failover (with send-timeout) + XA, good or bad idea?

2011-04-25 Thread Martin C.
Hi, one of my client is using XA using Atomikos, using a failover connection with ActiveMQ 5.4.2 (broker and client). From time to time, we see sporadic fails via the localhost connection (first question: why?): WARN org.apache.activemq.transport.failover.FailoverTransport - Transport (activemq

Re: EOFException when accessing message's properties

2011-04-23 Thread Martin C.
not sure if this really resolves the issue completely, but at least it didn't happen again for several tenth of millions of messages until now. Best regards, Martin On Thu, Apr 7, 2011 at 3:15 PM, Martin C. wrote: > Hi, > > I investigated the issue further. > > In the corres

Re: "Caught an exception sending to DLQ"

2011-04-23 Thread Martin C.
as if I cannot read the index for that destination. Rebuilding the > index would probably help, but I would be great to figure if it is > reproducible. > > On 17 April 2011 13:18, Martin C. wrote: >> Hi, >> >> in one of my installations using 5.4.2 broker, I got

Out-of-order delivery of messages with XA, Spring MDB, prefetch=1 & "Unmatched acknowledge: MessageAck"

2011-04-17 Thread Martin C.
Hi, one of my clients is using an XA connection inside a SingleConnectionFactory to share the connection with about 150 consumers (in total) in about 10 different Spring DefaultMessageListenerContainers. As Spring is not working with prefetch=0, they are using prefetch=1, but they now see out-of-

"Caught an exception sending to DLQ"

2011-04-17 Thread Martin C.
Hi, in one of my installations using 5.4.2 broker, I got the following exception, after processing of a message failed several times in a row within XA transactions. The message never appeared in a DLQ and seems to have been lost. Any ideas what could be causing this? 2011-04-17 13:41:59,353 | WA

Re: EOFException when accessing message's properties

2011-04-07 Thread Martin C.
to the EOFException happening on the web-interface as well. Should I search for the issue on the broker, the consumer or the producer (my guess being the broker)? Any hints? Thanks in advance, Martin On Thu, Apr 7, 2011 at 12:19 AM, Martin C. wrote: > Hi, > > as a follow-up, I'm curre

Re: EOFException when accessing message's properties

2011-04-06 Thread Martin C.
have to do with prefetch limit being set to 1 and XA transactions (I read about issues with prefetch and spring on the homepage, but this indicates that one should be a valid limit). Thanks in advance for any help! Best regards, Martin -- Forwarded message -- From: Martin C. Date

Re: Cannot browse or consume messages (with ttl setting) from a Queue.

2011-04-04 Thread Martin C.
> 3. Time to live : 30 (5 minutes) I'm not sure and I haven't checked the source-code, but could it be that the field is actually setting the timestamp when the message is going to expire instead of the TTL? Best regards, Martin

EOFException when accessing message's properties

2011-03-11 Thread Martin C.
Hi, I am experiencing a corrupt message (see stacktrace below) which fails when attempting to access the message's properties. We had this on two occurances until now, both on a 5.3.2 broker. The issue happens persists on 5.4.2, if we start it with the KahaDB datastore of the 5.3.2 instance. The m

Re: sometime,messages can not be consumed ,remaining in queue

2011-02-18 Thread Martin C.
Hi, On Thu, Feb 17, 2011 at 3:48 PM, xjchwork wrote: > > thanks,Martin.We use the default , AUTO_ACKNOWLEDGE. in this case I'd try upgrading to one of the bugfix releases of the 5.3.x series, or to the latest 5.4.2 if possible. But I don't know if the issue has been addressed but lots of message

Re: Delete all messages

2011-02-18 Thread Martin C.
Hi, On Wed, Feb 16, 2011 at 3:29 PM, lernen.2007 wrote: > > The problem is how can we delete all messages in a queue if we have a out of > memory. Is there any possiblity to delete messages? you could either purge it via the web-interface or via JMX from inside your code. Best regards, Martin

Re: sometime,messages can not be consumed ,remaining in queue

2011-02-15 Thread Martin C.
Hi, I don't see which acknowledge mode you are using, but beware that you need to call session.recover() as indicated in the JMS specification in order to start redelivery of messages, if there is an exception (see http://download.oracle.com/javaee/1.4/api/javax/jms/Session.html). This is at least

ActiveMQ transport fails with EOFException on localhost

2011-02-03 Thread Martin C.
Hi, lately I recognize sporadic EOFExceptions while being connected to the broker which runs on localhost (activemq1). 2011-02-03 13:44:14,200 [ActiveMQ Transport: ssl://activemq1/127.0.0.1:61617] WARN org.apache.activemq.transport.failover.FailoverTransport  - Transport (activemq1/127.0.0.1:6161

Re: Inconsistent TTL behavior on Topics

2011-01-30 Thread Martin C.
Hi Martin, On Sat, Jan 29, 2011 at 4:10 AM, mgfarme wrote: > Why do we get different behavior on queues than on topics ? I > can put a message on a queue with no subscribers, and see it timeout after > the TTL value. Because that is the defined semantics of a queue. Queues must hold the messages

Possible Bug: "Deleting inactive destination" with pending messages?

2011-01-20 Thread Martin C.
Hi, I am currently experimenting with removal of inactive destinations and I think I found an issue, but I want to confirm if this can be reproduced by anybody else before filing a bug in the issue tracker: I have which is rather short inactivity timeout, but just for testing. If I use the w

Re: ActiveMQ.DLQ created when JMSTimeToLive added.

2010-09-24 Thread Martin C.
Hi, On Thu, Sep 23, 2010 at 3:44 PM, ChicagoBob123 wrote: > > Why is this queue created to hold messages that have timed out?  Is there a > way to avoid this? Please have a look at http://activemq.apache.org/message-redelivery-and-dlq-handling.html, especially at the section "Automatically Disca

Re: *** GMX Spamverdacht *** Re: how to save topics and messages in mysql database

2010-09-17 Thread Martin C.
Hi, On Thu, Sep 16, 2010 at 9:38 AM, pp wrote: > For activemq must we have the broker(activemq) at every subscriber's server > ? No, you just need one server (broker) to which all clients connect to. Best regards, Martin

Re: How to find JMSXUserID in web console

2010-08-24 Thread Martin C.
Hi, On Tue, Aug 24, 2010 at 8:35 AM, Markus Schaber wrote: > But I cannot find a way to show those properties in the web console. Is this > a configuration issue? As far as I remember looking into the code in one of the 3.1.x versions, the JMSXUserID is not part of the regular attributes collec

Re: Global memory limit for all queues / fileQueueCursor question

2010-08-17 Thread Martin C.
Hi, thanks for the very fast answer. On Tue, Aug 17, 2010 at 8:48 PM, Bruce Snyder wrote: >>     >>       >>         >>           >>         >>       >>     > > The memoryUsage above should limit the entire broker to 256mb of > memory. I just tested this by lowering the memoryUsage limit to 15mb

Global memory limit for all queues / fileQueueCursor question

2010-08-17 Thread Martin C.
Hi, I'm a little bit confused by all the memory limit options available in ActiveMQ, maybe someone could help me. I primarily send non-persistent messages, and I'd like them to be spooled to disk in case a global memory limit is reached. Basically, I'd like to set a global limit of 256MB for all

Re: Can the same Java Bean consume from Queues or Topics? Only activemq.xml config change?

2010-08-13 Thread Martin C.
Hi, On Fri, Aug 13, 2010 at 3:21 PM, BenXS wrote: > Can I use the same (unchanged) java bean to consume jms msgs from a(nother) > topic instead from the previous queue? Yes, this should work. You only have to be aware of the changed semantics and delivery guarantees. Best regards, Martin

Re: How to forward a full message received in Java by onMessage() into another queue?

2010-08-13 Thread Martin C.
Hi, On Fri, Aug 13, 2010 at 2:30 PM, Gary Tully wrote: > > you need a message producer and do producer.send(..., message); > will this also preserve the message ID or will a new message ID be used for this message? I am interested as I may need to forward some messages to another broker and I'd

Re: ActiveMQ disconnects producer with large message throughput

2010-08-12 Thread Martin C.
Hi, Thanks for the pointer! Gary Tully wrote: > > filePendingMessagecursor is your man here, and configure a systemUsage > memory limit that controls how much memory resources are consumed by > the cursors before offloading to the local filesystem kicks in. > Could you provide a simple confi

ActiveMQ, SSL and NIO

2010-08-09 Thread Martin C.
Hi, I'm operating a SSL-based broker which is going to be connected by several thousand clients. As the SSL-transport is based on the TCP-transport, it seems that any connection is using its own thread. Is there any way to get SSL via NIO and using a worker thread for handling the connections? B

Re: XA and setMessageListener()?

2010-04-27 Thread Martin C.
Hi, Martin C. wrote: > > At the moment, I am using a Spring JmsTemplate approach. The Spring > JmsTemplates work with polling (i.e. blocking call on receive()) and sets > up the transaction before. This works fine. > I've now put together a very minimal example of what I

Re: XA and setMessageListener()?

2010-04-26 Thread Martin C.
Hi, thanks for your reply. Gary Tully wrote: > > There needs to be some JTA wrapper on the activemq session that will start > a > transaction and enlist the activemq XAResource for you. For Atomikos I > think > it is something like: > > class="com.atomikos.jms.AtomikosConnectionFactoryBe

XA and setMessageListener()?

2010-04-25 Thread Martin C.
Hi, I am trying to use Atomikos-based JTA together with Spring to use distributed transactions. Sending messages in an atomic way works fine, as the transaction is started before sending a message via the message producer. Unfortunately, I'm unable to get asynchronous message listeners (i.e. us

Re: ActiveMQ-CPP Failover transport blocks in interrupted mode

2010-02-12 Thread Martin C.
Martin C. wrote: > > After this, the call to send() hangs, instead of timing out due to either > connection.sendTimeout or timeout. This is rather unfortunate for me, > because possibly "infinite" hangs are not what I want, but want to switch > to some sort of "o

ActiveMQ-CPP Failover transport blocks in interrupted mode

2010-02-12 Thread Martin C.
Hi, I am using the failover transport with an URL constructed like the following: url << "failover://(tcp://" << broker.ip << ":" << broker.port << ")?" << "randomize=false" << "&connection.sendTimeout=5000" << "&maxReconnectDelay=5000&timeout=3000"; I tried unexpected broker failures b

Re: ActiveMQ-CPP Connection monitoring

2010-02-12 Thread Martin C.
Hi Timothy Bish wrote: > > On Thu, 2010-02-04 at 15:43 +0800, Sebastian Rodriguez wrote: > > Actually the transportInterrupted and transportResumed methods would be > invoked if the Failover transport is in use and the connection drops, > the client just needs to register a class that implemen

ActiveMQ-CPP Connection monitoring

2010-02-03 Thread Martin C.
Hi, I am using the failover transport in ActiveMQ-CPP and I'd like to know if there is a similar way to monitor the state of the connection as in the Java implemention, where you can register a TransportListener to the connection, which in turn gets notified if the connection is currently interru