ActiveMQCPP::initializeLibrary() usage

2011-09-28 Thread JRR
Greetings all, I have inherited some AMQ CPP client code. Recently we started seeing random crashes when ActiveMQCPP::initializeLibrary() was being invoked. These crashes do not always occur. I used [gdb] and the information relating to this crash is as follows: -

Failed to start jmx connector

2011-09-28 Thread Mohit Anchlia
I am using 5.4 and my config is http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.apache.org/schema/core"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/bean

Re: Understanding basic config

2011-09-28 Thread Mohit Anchlia
On Wed, Sep 28, 2011 at 3:33 PM, Timothy Bish wrote: > On Wed, 2011-09-28 at 14:05 -0700, Mohit Anchlia wrote: >> I have this config. Trying to understand few things: >> >> 1. what's the different between uri="tcp://localhost:0" and >> brokerURL="vm://localhost" ? >> 2. In point 1 why are both not

Re: STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Victor Perez
On Wed, Sep 28, 2011 at 5:19 PM, Timothy Bish wrote: > On Wed, 2011-09-28 at 15:55 -0500, Victor Perez wrote: > > On Wed, Sep 28, 2011 at 3:17 PM, Timothy Bish > wrote: > > > > > On Wed, 2011-09-28 at 15:09 -0500, Victor Perez wrote: > > > > On Wed, Sep 28, 2011 at 1:47 PM, Timothy Bish > > > w

Re: Understanding basic config

2011-09-28 Thread Timothy Bish
On Wed, 2011-09-28 at 14:05 -0700, Mohit Anchlia wrote: > I have this config. Trying to understand few things: > > 1. what's the different between uri="tcp://localhost:0" and > brokerURL="vm://localhost" ? > 2. In point 1 why are both not tcp? > 3. what is :0? That doesn't look like a port to me.

Re: STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Timothy Bish
On Wed, 2011-09-28 at 15:55 -0500, Victor Perez wrote: > On Wed, Sep 28, 2011 at 3:17 PM, Timothy Bish wrote: > > > On Wed, 2011-09-28 at 15:09 -0500, Victor Perez wrote: > > > On Wed, Sep 28, 2011 at 1:47 PM, Timothy Bish > > wrote: > > > > > > > On Wed, 2011-09-28 at 11:41 -0500, Victor Perez

Understanding basic config

2011-09-28 Thread Mohit Anchlia
I have this config. Trying to understand few things: 1. what's the different between uri="tcp://localhost:0" and brokerURL="vm://localhost" ? 2. In point 1 why are both not tcp? 3. what is :0? That doesn't look like a port to me. Is this specifial for embedded broker?

Re: STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Victor Perez
On Wed, Sep 28, 2011 at 3:17 PM, Timothy Bish wrote: > On Wed, 2011-09-28 at 15:09 -0500, Victor Perez wrote: > > On Wed, Sep 28, 2011 at 1:47 PM, Timothy Bish > wrote: > > > > > On Wed, 2011-09-28 at 11:41 -0500, Victor Perez wrote: > > > > We have a Ruby app publishing messages to ActiveMQ thr

Re: STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Timothy Bish
On Wed, 2011-09-28 at 15:09 -0500, Victor Perez wrote: > On Wed, Sep 28, 2011 at 1:47 PM, Timothy Bish wrote: > > > On Wed, 2011-09-28 at 11:41 -0500, Victor Perez wrote: > > > We have a Ruby app publishing messages to ActiveMQ through STOMP. When I > > use > > > Apache.NMS.Stomp in .NET to consu

Re: STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Victor Perez
On Wed, Sep 28, 2011 at 1:47 PM, Timothy Bish wrote: > On Wed, 2011-09-28 at 11:41 -0500, Victor Perez wrote: > > We have a Ruby app publishing messages to ActiveMQ through STOMP. When I > use > > Apache.NMS.Stomp in .NET to consume the messages, they come in as > > IBytesMessage with no content.

Re: STOMP SUBSCRIBE and UNSUBSCRIBE behaviour

2011-09-28 Thread Timothy Bish
On Wed, 2011-09-28 at 06:49 -0700, Steve Powell wrote: > Steve Powell wrote: > > > > I would like some clarification of the precise intended semantics > > of the SUBSCRIBE and UNSUBSCRIBE STOMP commands in ActiveMQ. > > > > I hope this is the right mailing list. > > > I'm guessing this isn't the

Re: Could not correlate acknowledgment with dispatched message

2011-09-28 Thread Timothy Bish
On Wed, 2011-09-28 at 07:53 -0700, jandeclercq wrote: > Hey, > > We have to restart ActiveMQ now and then because it stops working. > > Stop working means: > > > In the activemq.log we see this: > Startup at 2011-09-26 12:39 > Stopped workint at 2011-09-26 21:14 > > > > > > In the clients

Re: STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Timothy Bish
On Wed, 2011-09-28 at 11:41 -0500, Victor Perez wrote: > We have a Ruby app publishing messages to ActiveMQ through STOMP. When I use > Apache.NMS.Stomp in .NET to consume the messages, they come in as > IBytesMessage with no content. > > If I use NMS to publish a message, it can be consumed with

STOMP NMS: cannot retrieve messages published from ruby

2011-09-28 Thread Victor Perez
We have a Ruby app publishing messages to ActiveMQ through STOMP. When I use Apache.NMS.Stomp in .NET to consume the messages, they come in as IBytesMessage with no content. If I use NMS to publish a message, it can be consumed with no problems by our ruby, java and NMS (.NET) apps. When i publish

Local shared filesystem master slave with geo-redundant pure master slave

2011-09-28 Thread Stevo Slavić
Hello ActiveMQ users, Imagine 4 nodes, 2 per location, on each node on same location/LAN a shared filesystem (separate node) used by two local brokers in shared filesystem master slave (SFSMS) configuration. Can destinations and messages be shared for HA across the geo-redundant nodes? Can failov

Could not correlate acknowledgment with dispatched message

2011-09-28 Thread jandeclercq
Hey, We have to restart ActiveMQ now and then because it stops working. Stop working means: In the activemq.log we see this: Startup at 2011-09-26 12:39 Stopped workint at 2011-09-26 21:14 In the clients(c++) we get the error: OpenWireFormatNegotiator::onewayWire format negotiation timeou

Re: STOMP SUBSCRIBE and UNSUBSCRIBE behaviour

2011-09-28 Thread Steve Powell
Steve Powell wrote: > > I would like some clarification of the precise intended semantics > of the SUBSCRIBE and UNSUBSCRIBE STOMP commands in ActiveMQ. > > I hope this is the right mailing list. > I'm guessing this isn't the right mailing list. Please confirm. -- View this message in context

GET method problems using the REST API!

2011-09-28 Thread guerra
Hi, I am kind of making some proof of concept with the REST API to send/receive messages to/from an ActiveMQ broker. Talking about the GET method, the HTTP client blocks until a message is available. That's fine so far, but the problem rises when I send several messages to the queue. The HTTP cli

Re: No. of brokers and performance

2011-09-28 Thread Gary Tully
yes, but there are memory and file descriptor limits for a single java process. have a peek at http://fusesource.com/docs/broker/5.4/tuning/index.html or http://activemq.apache.org/performance-tuning.html On 27 September 2011 18:38, Mohit Anchlia wrote: > In general when dealing with multiple qu

Re: Random persistent messages lost

2011-09-28 Thread Alistair Young
so a batch of 6 messages came into the broker, 5 disappeared. They were not persisted. One was delivered to the consumer and the rest just simply vanished. tcpdump proves they arrived at the boker but never made it to the consumer. The activemq logs show the same set of entries for everything th

Re: Net::Stomp and transactions and receive_frame()

2011-09-28 Thread Gary Tully
you need to correlate the receipt ids as there is nothing to sync replys and message dispatch. Have a peek at http://search.cpan.org/~lcons/Net-STOMP-Client-1.2/lib/Net/STOMP/Client.pm#RECEIPTS that has some built in receipt management On 28 September 2011 10:37, Kevin Goess wrote: > Here's a

Re: Net::Stomp and transactions and receive_frame()

2011-09-28 Thread Kevin Goess
Here's a complete repro case. Either it's not supposed to work this way or I'm doing something wrong: use Net::Stomp; use strict; my $stomp = Net::Stomp->new( { hostname => 'bpdeb', port => '61612' } ); $stomp->connect( { login => 'hello', passcode => 'there' } ); # pre-populate the two queues

Re: Confugring data dir, persistence in embedded broker

2011-09-28 Thread Alistair Young
for Spring, I use this: http://activemq.apache.org/schema/core"; id="matrixBrokerID" brokerName="matrixBroker" useJmx="true" persistent=