[Solaris 11 - 64 bit]
I am trying to run a C/C++ program that uses ActiveMQ-CPP & Embedded
SQL (Ingres 10.1] and would like some input on build options since the
program crashes.
On Thu, 7 Jan 2016 09:41:56 -0500, Timothy Bish
wrote:
>On 01/07/2016 09:20 AM, spamtrap wrote:
>> Environment: Solaris 11 (sparc)
>> Compiler: Solaris Studio 12.3
>>
>> CFLAGS="-xarch=generic64"
>> CXXFLAGS="-xarch=generic64"
>>
>> Configure options:
>> ./configure '--disable-ssl' '--prefix=' '-
othy Bish
>>>> wrote:
>>>>
>>>>> On 11/25/2015 11:29 AM, spamtrap wrote:
>>>>>> On Wed, 25 Nov 2015 11:07:53 -0500, Timothy Bish
>>>>>> wrote:
>>>>>>
>>>>>>> On 11/25/2015 10:
Hi,
I have the following code:
cms::Message *pMessage;
...
std::vector propertyNames = pMessage->getPropertyNames();
According to valgrind this leaks memory. propertyNames is on the
stack BTW.
==27758== 50,039,920 (289,968 direct, 49,749,952 indirect) bytes in
6,041 blocks are definitely lost
On Sun, 1 Nov 2015 07:44:34 -0700, Tim Bain
wrote:
>This sounds like a bug. Since Tim Bish (the only person I've seen support
>ActiveMQ-CPP) didn't comment on it here, please submit a bug report in
>JIRA, ideally with your consumer code (better: a stripped down minimal
>version that produces the
[ActiveMQ 5.11.2, ActiveMQ-CPP 3.9.0]
A message consumer (using ActiveMQ-CPP) receives a message but does
not send an acknowledgement (INDIVIDUAL_ACKNOWLEDGE mode) due an error
elsewhere. The ActiveMQ consumer is closed and recreated later.
The unacknowledged message is processed by the redelive
Anyone know why this thread might be hanging?
#0 0x00300e20b5bc in pthread_cond_wait@@GLIBC_2.3.2 () from
/lib64/libpthread.so.0
#1 0x7f19fd2c4c86 in (anonymous namespace)::doMonitorEnter
(monitor=0x7f19cc00d1d0, thread=0x1142c80) at
decaf/internal/util/concurrent/Threading.cpp:664
#2 0x00
On Tue, 23 Jun 2015 08:42:46 +0100, spam trap
wrote:
>On Tue, 09 Jun 2015 08:50:58 +0100, spamtrap
> wrote:
>
>>Hi,
>>
>>In some cases we want to allow another consumer to consumer a message
>>that has already been consumed. The session is opened using
>>
On Tue, 09 Jun 2015 08:50:58 +0100, spamtrap
wrote:
>Hi,
>
>In some cases we want to allow another consumer to consumer a message
>that has already been consumed. The session is opened using
>INDIVIDUAL_ACKNOWLEDGE and the message has not been acknowledged. I
>have tried closing the session wh
On Fri, 12 Jun 2015 16:08:05 -0600, Tim Bain
wrote:
Just to be 100% clear what should the behaviour be if I use
INDIVIDUAL_ACKNOWLEDGE (vs SESSION_TRANSACTED) and have not
acknowledged the message?
>It sounds like you can reproduce this reliably; can you submit a bug report
>in JIRA and attach t
On Tue, 9 Jun 2015 10:31:02 -0400, Christopher Shannon
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 consumer of a queue). I
have tried stopping and restarting the session and consumer objects
but not all
On Wed, 18 Jun 2014 11:37:50 -0700 (PDT),
"tabish...@gmail.com"
wrote:
>I've created an issue to track the behaviour as it's not really what you'd
>expect and resolved it in ActiveMQ trunk and ActiveMQ-CPP trunk and the
>3.8.x fixes branch. Should work as you expected now.
Thanks. We've remo
On Wed, 11 Jun 2014 08:51:23 +0100, spam trap
wrote:
>On Tue, 10 Jun 2014 11:07:43 -0400, Timothy Bish
> wrote:
>
>>On 06/10/2014 06:47 AM, spam trap wrote:
>>> On Tue, 10 Jun 2014 06:06:03 -0400, Timothy Bish
>>> wrote:
>>>
>>>> On 06/
On Tue, 10 Jun 2014 11:07:43 -0400, Timothy Bish
wrote:
>On 06/10/2014 06:47 AM, spam trap wrote:
>> On Tue, 10 Jun 2014 06:06:03 -0400, Timothy Bish
>> wrote:
>>
>>> On 06/10/2014 04:42 AM, spam trap wrote:
>>>> [ActiveMQ-CPP 3.8.2]
>>>>
&g
On Tue, 10 Jun 2014 06:06:03 -0400, Timothy Bish
wrote:
>On 06/10/2014 04:42 AM, spam trap wrote:
>> [ActiveMQ-CPP 3.8.2]
>>
>> I am unsure how to configure the failover transport correctly. We
>> have maxReconnectAttempts & startupMaxReconnectAttempts set to t
[ActiveMQ-CPP 3.8.2]
I am unsure how to configure the failover transport correctly. We
have maxReconnectAttempts & startupMaxReconnectAttempts set to the
default which should mean the transport should retry to connect
forever, yes? However, if the broker is not available, the connection
attempt
Hi,
[Linux 2.6.18 64 bit, GCC 4.4.7]
We have a consumer which needs to stop/restart consuming messages. I
have implemented this by calling cms::Session:stop() and
cms::Session::start() [& recover]. Up to now this has worked OK but
we have seen a case where the stop() method hangs forever.
The
On Thu, 15 May 2014 09:41:04 -0400, Timothy Bish
wrote:
>On 05/07/2014 05:22 AM, spam trap wrote:
>> I need to display the complete message sent from an application in
>> debugging mode. However I get the MessageNotReadableException thrown
>> when trying to access the bod
I need to display the complete message sent from an application in
debugging mode. However I get the MessageNotReadableException thrown
when trying to access the body. Is there a way of making the message
readable or otherwise displaying the body?
>From time to time a consumer will disconnect from the Broker and not
attempt to reestablish the connection. The log contains the following
message:
2014-05-12 12:34:07,893 | WARN | ctiveMQ NIO Worker 28664 | Transport
| ivemq.broker.TransportConnection 205 | 72 -
org.apache.activemq.activemq-cor
On Tue, 23 Jul 2013 08:42:34 -0700 (PDT), dpatel
wrote:
>I just upgraded from activemqcpp version 3.6 to 3.7.0. After the upgrade when
>I try to execute the following line in release config the dll crashes.
>
>cms::ConnectionFactory *conn_factory =
>cms::ConnectionFactory::createCMSConnectionFact
On page http://activemq.apache.org/cms/api.html
Clicking on any of the ActiveMQ-CPP API links gives a 404 not found
error.
Also can you put the docs for later versions of the ActiveMQ-CPP
libraries on there, please?
We need to allow message redelivery to multiple consumers of the same
queue. The consumers stop and restart/recover the session when they
need. Unacknowledged messages need to be consumed by any consumer. We
have set the broker up according to the instructions in the page
http://activemq.apache.o
On Mon, 04 Mar 2013 15:26:38 +, spam trap
wrote:
>I want to change the redelivery policy (maximumRetries) from a program
>using ActiveMQ-CPP. It doesn't seem to work if I append
>"?cms.redeliveryPolicy.maximumRedeliveries=-1" onto the broker URI.
>
>Do I have
I want to change the redelivery policy (maximumRetries) from a program
using ActiveMQ-CPP. It doesn't seem to work if I append
"?cms.redeliveryPolicy.maximumRedeliveries=-1" onto the broker URI.
Do I have to use the setRedeliveryPolicy() method of the connection
factory object instead?
On Thu, 28 Feb 2013 10:12:13 +, spam trap
wrote:
>On Wed, 27 Feb 2013 10:22:49 -0500, Timothy Bish
> wrote:
>
>>On 02/27/2013 05:20 AM, spam trap wrote:
>>> [ActiveMQ-CPP v3.4.4]
>>>
>>> I have an ActiveMQ asynchronous consumer that I need to start
On Wed, 27 Feb 2013 10:22:49 -0500, Timothy Bish
wrote:
>On 02/27/2013 05:20 AM, spam trap wrote:
>> [ActiveMQ-CPP v3.4.4]
>>
>> I have an ActiveMQ asynchronous consumer that I need to start and stop
>> consuming. I also need it to redeliver messages that it has
>
[ActiveMQ-CPP v3.4.4]
I have an ActiveMQ asynchronous consumer that I need to start and stop
consuming. I also need it to redeliver messages that it has
previously consumer but not acknowledged. To do this I am using the
INDIVIDUAL_ACKNOWLEDGE mode.
To start and stop the consumer I am using ses
On Mon, 17 Dec 2012 06:14:14 -0500, Timothy Bish
wrote:
>On Mon, 2012-12-17 at 09:57 +0000, spam trap wrote:
>> We are using AcvtiveMQ CPP 3.4.4 and are using a consumer with
>> INDIVIDUAL_ACKNOWLEDGE. Is there any way of getting the
>> un-acknowledged messages redelivere
We are using AcvtiveMQ CPP 3.4.4 and are using a consumer with
INDIVIDUAL_ACKNOWLEDGE. Is there any way of getting the
un-acknowledged messages redelivered without closing and reopening the
session?
On Thu, 30 Aug 2012 15:40:18 -0400, Timothy Bish
wrote:
>On Thu, 2012-08-30 at 12:44 +0100, spam trap wrote:
>> On Wed, 29 Aug 2012 10:08:36 -0400, Timothy Bish
>> wrote:
>>
>> >On Wed, 2012-08-29 at 15:04 +0100, spam trap wrote:
>> >> On Wed
On Wed, 29 Aug 2012 10:08:36 -0400, Timothy Bish
wrote:
>On Wed, 2012-08-29 at 15:04 +0100, spam trap wrote:
>> On Wed, 29 Aug 2012 08:46:18 -0400, Timothy Bish
>> wrote:
>>
>> >On Wed, 2012-08-29 at 13:35 +0100, spam trap wrote:
>> >> I need to mod
On Wed, 29 Aug 2012 08:46:18 -0400, Timothy Bish
wrote:
>On Wed, 2012-08-29 at 13:35 +0100, spam trap wrote:
>> I need to modify a consumed message (add new properties & change
>> payload) and then send it. I know I can't do this directly as a
>> consumed message
I need to modify a consumed message (add new properties & change
payload) and then send it. I know I can't do this directly as a
consumed message is read-only. However I also find that a cloned copy
is also read-only.
How can I achieve this?
On Fri, 24 Aug 2012 09:24:38 -0400, Timothy Bish
wrote:
>On Fri, 2012-08-24 at 14:15 +0100, spam trap wrote:
>> Hi,
>>
>> I am using ActiveMQ-CPP to consume messages asynchronously. In my
>> onMessage() method can I refer to the cms::Message object directly?
>&g
Hi,
I am using ActiveMQ-CPP to consume messages asynchronously. In my
onMessage() method can I refer to the cms::Message object directly?
All the examples show this being casted to another type (eg.
BytesMessage). Some messages may not have payloads so I am not
sure what exact type to use for t
Hi,
Is it possible to tell ActiveMQ to stop delivering messages to an
asynchronous consumer temporarily (if the consumer is unable to
process messages, say).
[This is a consumer that uses the MessageConsumer.setMessageListener()
method.]
On Mon, 28 May 2012 15:42:21 +0100, Gary Tully
wrote:
>there are two aspects to this:
>1) standard jms redelivery semantics. In activemq this is handled by
>the consumer, so client side.
>redelivery occurs on "transacted" sessions if there is a rollback or
>an exception processing the message.
>
Hi,
Can someone help me understand better the way ActiveMQ handles
transactions and acknowledgements?
I need to write a consumer that processes a message. If something
goes wrong or the consumer crashes we need the message to be consumed
again (when the consumer is restarted).
Should I use CLIE
On Wed, 28 Sep 2011 16:55:41 -0700 (PDT), JRR
wrote:
>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 t
On Thu, 22 Sep 2011 08:02:47 +0700, Ivan Pechorin
wrote:
The reason is that the ActiveMQConsumer object is crashing during its
destruction.
>>>Stack traces and sample code that reproduces the issue are needed before
>>>any help here, this could result from a number of different sce
On Wed, 21 Sep 2011 08:23:40 -0400, Timothy Bish
wrote:
>On Wed, 2011-09-21 at 12:17 +0100, spam trap wrote:
>> I am writing a C++ application using the ActiveMQ CPP API. I have
>> based my code on the example in
>> http://activemq.apache.org/cms/example.html
>>
I am writing a C++ application using the ActiveMQ CPP API. I have
based my code on the example in
http://activemq.apache.org/cms/example.html
However I have moved the creation of the Session, Destination and
Consumer objects of the Consumer class to the constructor. I
understand that some of the
On Mon, 12 Sep 2011 14:26:46 -0400, Timothy Bish
wrote:
>On Mon, 2011-09-12 at 09:29 +0100, nospam.1.friedbad...@spamgourmet.com
>wrote:
>> Hi,
>>
>> I can't get the Active MQ library 3.4.0 to build on Solaris. I have
>> the Sun Studio 11 compiler. I think I have read all the READMEs. If
>> I
44 matches
Mail list logo
