Re: Queue messages not dequeuing

2012-02-23 Thread Jakub Korab
Hi Matt, When you say that the message is not being dequeued, do you mean from the queue on the broker? The overall scheme itself seems to be pretty complicated; where are the topic messages coming from? If you are trying to ensure that messages for a particular id are consumed in sequence then

Re: Queue messages not dequeuing

2012-02-23 Thread Matt Lachman
Hi Jakub, Yes, from the queue on the broker. As far as the broker is concerned, it remains "in-flight" permanently. What's weirder is when I run a standalone java client to consume the messages, it has no trouble whatsoever. So I think there's something going on in the client side that's causing m

how can jmx queueSize be greater than enqueue size?

2012-02-23 Thread mserrano
I am using 5.5.1. I don't really understand how this can be happening. Any advice would be appreciated: ConsumerCount: 1 CursorFull: false CursorMemoryUsage: 375818264 CursorPercentUsage: 70 DequeueCount: 0 DispatchCount: 20803 EnqueueCount: 20807 ExpiredCount: 0 InFlightCount: 20803 ... QueueSi

Re: master/slave within a network of brokers

2012-02-23 Thread mserrano
john, I have been using connections like between two sets of master/slave brokers that are networked together. This generally works but I am working on tracking down some occasional failures of my tests that seem related to the network never getting set up (not sure about that though -- it is a

Re: how can jmx queueSize be greater than enqueue size?

2012-02-23 Thread mserrano
Ok, after poking around a bit, I realized that there must be persisted messages being restored from a previous execution. Does that make sense? -- View this message in context: http://activemq.2283324.n4.nabble.com/how-can-jmx-queueSize-be-greater-than-enqueue-size-tp4414406p4414654.html Sent fr

Re: Connecting via SSL using .NET

2012-02-23 Thread Chris Robison
Looking at the code, it looks like I have to be able to set the AcceptInvalidBrokerCert on the SslTransportFactory, but I can't seem to find a way to get access to that unless I create my own factory and url scheme. This seems a little severe to me. Is there something that I'm missing? Chris On T

Re: Connecting via SSL using .NET

2012-02-23 Thread Timothy Bish
On Thu, 2012-02-23 at 14:53 -0700, Chris Robison wrote: > Looking at the code, it looks like I have to be able to set the > AcceptInvalidBrokerCert on the SslTransportFactory, but I can't seem to > find a way to get access to that unless I create my own factory and url > scheme. This seems a littl

Re: Connecting via SSL using .NET

2012-02-23 Thread Chris Robison
Thank you! That worked swimmingly! chris On Thu, Feb 23, 2012 at 2:59 PM, Timothy Bish wrote: > On Thu, 2012-02-23 at 14:53 -0700, Chris Robison wrote: > > Looking at the code, it looks like I have to be able to set the > > AcceptInvalidBrokerCert on the SslTransportFactory, but I can't seem to

Re: how can jmx queueSize be greater than enqueue size?

2012-02-23 Thread Matt Pavlovich
Enqueued and dequeued are counters for the number of total messages that have traveled through the system over time. QueueSize is the current count. On 2/23/12 1:00 PM, mserrano wrote: Ok, after poking around a bit, I realized that there must be persisted messages being restored from a previou

Failover with networkConnectors

2012-02-23 Thread hodgesz
Hi, Is it possible to use the failover construct in the networkConnectors uri? I have tried the following two uri values and both prevented ActiveMQ from starting with an exception. Both returned the following stack trace: ERROR: java.lang.RuntimeException: Faile

out of memory using producer flow control and fileQueueCursor

2012-02-23 Thread mserrano
version 5.5.1 broker cfg: memory: 256M, Store:10g, Swap/tmp:10g, persistence=true, producerFlowControl=true I'm using the http://activemq.apache.org/message-cursors.html fileQueueCursor destination policy for a queue. It appears to properly page in messages in the cursor without blocking when

Re: Failover with networkConnectors

2012-02-23 Thread mserrano
I'm using: Note, no // after the static. But it looks like something else is misconfigured for you. Notice the /start/ after no scheme specified. hodgesz wrote > > ERROR: java.lang.RuntimeException: Failed to execute start task. Reason: > java.l > ng.IllegalArgumentException: Invalid broke

Re: Failover with networkConnectors

2012-02-23 Thread hodgesz
Thanks for your reply! I noticed I had the trailing ')' in the incorrect spot based on your example. It is working now. The start issue was getting my Windows and Linux environments confused and typing 'activemq start' in Windows. -Jonathan -- View this message in context: http://activemq.

JMS goes in, sometimes STOMP comes out (but not always)

2012-02-23 Thread davidw
I'm seeing a weird issue in an AMQ installation. basically I can see with TCP dump that a JMS message gets published to ActiveMQ, but if that message is a particular type of message, ActiveMQ doesn't forward that on to it's (STOMP) subscribers. AMQ version: 5.5.1 Setup: Glassfish v3.1.1, conne

Re: JMS goes in, sometimes STOMP comes out (but not always)

2012-02-23 Thread davidw
OH - here's an example of what gets printed to the logs when it works and the message that seems to break it -- View this message in context: http://activemq.2283324.n4.nabble.com/JMS-goes-in-sometimes-STOMP-comes-out-but-not-always-tp4416098p4416114.html Sent from the ActiveMQ - User mailin

Trying the read the current master at runtime

2012-02-23 Thread archa
The message broker used in my application has the failover protocol used over 2 brokers. While creating the consumer, I need to know on which broker the actual consumer was formed. i.e I want to fetch at runtime the the current master IP/Hostname While debugging, I saw that the QueueConnection obje