Hi,
Could you please give me access to https://the-asf.slack.com/?
Best regards,
Ivan Iliev
Hello.
Anyonone interested to share experience in ActiveMQ/AMQ, in October?
We got two conf (DevOps Stage and PyCon Ukraine 2019), in Kyiv - I can
share details, if someone would be available.
Ivan
I am in serious trouble recently.
Starting to implement using the ActiveMQ, the requirement is to guarantee no
message lost from our JMS producer.
The JMS producer is sending persistent message to the broker. We are still
using Replicated LevelDB setup with 3 ZooKeeper nodes.
The first question
ecker) didn't find any memory leaks at
all. There was a one-time resource leak: some library was loaded with
LoadLibrary() in apr, and it was not unloaded on application exit. That's
not an issue, in my opinion.
OS: Windows 2008 R2 Standard (64-bit).
Any ideas?
Maybe some other configuration, or some changes to the example?
Regards,
Ivan
2012/5/13 richardm
>
> My tools are not that good, though I'll spend some time later today or
> tomorrow to better understanding what I'm seeing. All I know is that the
> most basic dump of leaked memory indicates quite a few problems in the
> Visual Studio environment. I'm guessing this to be
2012/4/22 Mohit Anchlia
> Thanks, but then I would like to know how do people design such a system
> where request comes in goes on the queue and waits on the outgoing queue.
> If responses from different requests go to only one queue then this model
> wouldn't work unless there is some other com
On 04.04.2012, at 21:02, JRR wrote:
> Hello,
>
> I think I know how to do this but I want to confirm with the crowd.
>
> We're using AMQ as the MOM between my group, which use ActiveMQ-CPP, and
> another group which I believe is using camel. They've requested that the
> header's "type" field
2012/2/13 stephenju
> Is there a way to access the text bytes without creating a temporary
> std::string? I am dealing with some large text messages and try not to
> allocate memory when making copies. For example, when I get the message:
>
> std::string reply = myMessage->getText();
>
> getText(
2012/1/14 Ganuke Perera :
> I am using a topic name MarketData. I have set the time to live to 5
> minutes in the producer. Also I am using the default configuration for
> ActiveMQ. I am adding messages with the rate of 200 messages per second.
> And there is one subscriber to the topic and at the
2012/1/8 beep02 :
> How can I release the request thread and in the same time keep user in wait
> without response?
> Is there some way to achieve that?
Yes, either use Servlet 3.0 container such as Tomcat 7 (just google
for AsyncContext [1] and ServletRequest.startAsync [2]).
Or (for older versio
2011/12/29 Bill Moo :
> I have build myself a libactivemq-cpp.lib file (525MB) from source using
> Visual Studio 2010 (x64) and the Release-SSL configuration and I now want
> to make use of it in my test program. I am trying to build a test
> application using Qt with the MSVC 10.0 (amd64) toolchai
2011/12/14 mikmela :
> I'm having a lot of issues passing std::strings into ActiveMQ-CPP interfaces,
> i.e. Connection, Session, Message and etc.
> Even though I'm using MS VS2010 to build both activemq-cpp dll and my
> application with the same version of multithreaded c-runtime dll
> MSVCP100.dll
2011/12/10 JRR :
> I am using the Active MQ CPP 3.4.0 client.
>
> We have a multi-threaded application that has multiple producers, and they
> share a single connection. These connections are */not/* fail over
> connections, nor can they be.
>
> I'm trying to find the fastest, most efficient way to
2011/12/6 JRR :
> My question is more along the lines of what would happen if shutdownLibray()
> was **not** invoked when a process exits?
I believe, this is really important only when you want to use
something like valgrind.
2011/12/2 Timothy Bish :
> If you are using a mac then you need to get the 3.4. SNAPSHOT code from the
> link on the v3.4.1 download page.
The same issue (https://issues.apache.org/jira/browse/AMQCPP-369) is
applicable to Solaris too.
So, it's not Mac-specific at all, and I suggest to try 3.4.1 on
2011/12/2 stretch_kiwi :
> [michael@blackbox test]$ ./activemq-test
> Segmentation fault (core dumped)
> I would appreciate any practical suggestions.
Stack backtrace should be the first thing to look at:
$ gdb activemq-test core
> where
2011/11/22 manua :
> Each consumer is running in a different thread, though listening on the same
> queue.
> We dont see any concurrent access.
Consumers always belong to some session; session is thread-specific
(this is a generic principle of JMS, and as far as I know it's valid
both for ActiveM
2011/11/22 manua :
>
> We have used activemq cpp and created a session. The session is set in the
> auto acknowledge mode.
> Multiple threads have been launched from that code and each thread has a
> consumer.All consumers are listening on the same queue, and sharing the same
> session.
Do you pro
> Just to make sure I am getting things right I do the following in the
> cleanup:
>
> delete destination;
> consumer.stop();
> session.stop();
> consumer.close();
> delete consumer;
> delete session;
>
> Is this the correct order?
Yes, it looks correct.
>>> 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 scenarios.
>
> I am in the process of creating a standalone example
It seems like you hit prefetch limit (the default prefetch size is
1000). Try setting prefetch size to something larger for the
particular connection or consumer used by your 'queue sorter'.
On 8/19/11, Matías García Isaía wrote:
> Hi all...
>
> Another one here trying to implement kind-of-a-stac
2011/7/7 mahens :
> i want to build activemq-cpp-library-3.4.0, using microsoft visual studio
> 2010 i am trying to build activemq-cpp-library-3.4.0.
>
> Actually i want to test connection to activemq broker using c++ program.
> Please suggest.
What's you question?
false&jms.objectMessageSerializationDefered=true&jms.useAsyncSend=true
The NPE occurs occasionally, we were not able to reproduce it
deterministically so far.
Any suggestions on how to investigate this NPE?
I've created an issue in JIRA: https://issues.apache.org/jira/browse/AMQ-3369
Regards,
Ivan
2011/6/9 Ken Moore :
>>
>> Yes, that was definiately part of the problem. Also I had not used the
>> correct macros for checked iterators in the STL, to be consistent with the
>> rest of our build. It is all working now. Many thanks for your help
>>
> Can you tell me what macros you corrected to so
2011/5/4 Suneel Papineni :
>
> I am getting problems in sending or receiving Unicode messages. Could
> someone please tell me how can I implement this correctly.
We use UTF-8 successfully in ActiveMQ's TextMessage since activemq-cpp-3.0.x.
In particular, we UTF-8 between C++ and Java clients.
remember, winspool.h won't be included if you define
WIN32_LEAN_AND_MEAN.
Regards,
Ivan
be a more general problem.
>
>
> On 28 December 2010 02:29, Ivan wrote:
> > Hi,
> >I am learning the ActiveMQ RA module, and could not understand some
> > codes in the getXAResources method of ActiveMQResourceAdapter class,
> please
> > help to give some c
Could anyone help to give some comments ?
Thanks.
2010/12/28 Ivan
> Hi,
> I am learning the ActiveMQ RA module, and could not understand some
> codes in the getXAResources method of ActiveMQResourceAdapter class, please
> help to give some comments, thanks.
> a. The imple
rce[] {};
} catch (JMSException e) {
throw new ResourceException(e);
} finally {
try {
connection.close();
} catch (Throwable ignore) {
//
}
}
}
<
--
Ivan
Johan,
Thank you. How do I get hold of the CamelContext instance that is defined in
the ActiveMQ configuration.
I looked at StartAndStopRoutesTest.java and it creates a new CamelContext.
Regards
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Programmatically-changing-Ca
Hi,
I have several routes defined in the ActiveMQ configuration. I need to be
able to programmatically change the list the routes - add new and delete
existing ones without changing the configuration and restarting the broker.
I suppose I need to get hold of the Camel Context and then modify the
Forgot to cc activemq user list.
-- Forwarded message --
From: Ivan
Date: 2010/12/21
Subject: Re: EOFException in ActiveMQ 4.1.2
To: d...@geronimo.apache.org
Finally, I found the codes caused this, it is related to activemq resource
adapter.
In the finally block
at
org.apache.geronimo.kernel.util.MainConfigurationBootstrapper.main(MainConfigurationBootstrapper.java:45)
at org.apache.geronimo.cli.AbstractCLI.executeMain(AbstractCLI.java:67)
at org.apache.geronimo.cli.daemon.DaemonCLI.main(DaemonCLI.java:30)
2010/12/17 Ivan
> Sorry for the repeated sending, just add ge
Sorry for the repeated sending, just add geronimo mail list.
2010/12/17 Ivan
> After adding some outputs, the error seems to happen after the socket of
> the server side received the wireformatinfo, then on the next call of
> readCommand, it fails to read bytes ...
>
> -->
and(TcpTransport.java:268)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:244)
at java.lang.Thread.run(Thread.java:736)
<--
2010/12/17 Ivan
> Hi,
> I am using Geronimo 2.1.7, which shipped ActiveMQ 4.1.2, it sometimes
> reported the error below after deploying a M
7)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:269)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:245)
at java.lang.Thread.run(Thread.java:736)
<---
--
Ivan
2010/10/14 Ed :
> All the tests show that pool size
> defined under affects connections pooling only.
>
> Is sessions pooling really done so strange way?
> Sessions are pooled but no way to manage/configure that pooling from
> outside?
My understanding is that the resource adapter implements one
2010/10/15 Oscar Pernas :
> Thanks ivan, but are you totally sure? I cant find any reference in the
> webpage or in the readme files about it.
Well, I'm quite sure, because when I tried to use ActiveMQ-C++ for the
first time in June or July 2009, we used VC7.1 (2003) exclusively. I
pro
2010/10/15 Oscar Pernas :
> Only to know, has anyone compiled activemq-cpp in visual c 6? is supported?
As far as I remember, even much newer Visual C++ 2003 (VC7.1) isn't supported.
Hence VC6 is not supported too.
2010/9/28 Oscar Pernas :
>
> ..\src\main\decaf\lang\System.cpp(389) : error C2664: 'strlen' : cannot
> convert parameter 1 from 'LPTSTR' a 'const char *'
> ..\src\main\decaf\lang\System.cpp(395) : error C2664:
> 'std::vector<_Ty>::push_back' : cannot convert parameter 1 1 de 'LPTSTR' a
> 'const s
Hello
> On Tue, 2010-08-03 at 12:33 -0700, Marc Luce wrote:
>> My LD_LIBRARY_PATH=::/usr/lib:/usr/local/lib
I wonder if APR 1.4.x is supported? README in
branches/activemq-cpp-3.2.x still suggests APR >= 1.3*.
Regards,
Ivan
> So it's fine without correlation ID because the producer waits for reply
> message not on the static queue but on the temporary queue registered in the
> JMSReplyTo header.
It's fine without correlation ID as long as the requesting side
(producer) waits for reply before sending next request.
Cor
2010/6/22 :
> As per the advice at
> http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html
> I am using temporary Qs for my replies.
> ...
>
> Because of various technical obstacles that I wont go into here, I am only
> able to run with ActiveMQ locally. ActiveMQ is fine
ble.
P.S. Sorry if I misunderstood you and wrote something very obvious and
irrelevant to your problem :)
Best regards, Ivan
On 2010/5/28 Frank Gynnild wrote:
> How "cheap" is it to create local session,
> producers and consumers for each thread vs using synchronization to create
> thread safe sessions?
There is no need to create local session, producers and consumers for
EACH thread, you can utilize a thread-safe pool
> Why would I have an activemq-ra.rar in $JBOSS_HOME/server/all/deploy if I am
> not embedding it?
You need resource adapter in order to connect your MDBs to ActiveMQ
broker. No matter whether you are embedding the broker, or not.
By the way, if you need to connect your MDBs to more than one brok
2010/4/30 ed4becky :
>
> I would like to configure an MDB running in JBoss to access a JMS message
> queue running in a standalone ActiveMQ instance.
You should configure property "ServerUrl" of ActiveMQ Resource Adapter
(RA) to connect to your standalone ActiveMQ instance.
$JBOSS_HOME/server/all
> what I cannot understand is that why those ActiveMQTempQueue are always
> there even I close the connection.
Because the connection is not closed actually, it is just returned to the pool.
If I understand correctly, the following kinds of ActiveMQ objects
involve sync request to ActiveMQ broker
ctions, how do you manage to create
the 1.5 GB of connection objects?
By the way, why do you use TCP transport for connection to embedded
ActiveMQ? Why not use VM transport, designed for exactly this purpose?
Best regards, Ivan
her thing we had to change is: set jms.useAsyncSend=false in
connection URI (connection to embedded broker) instead of
jms.useAsyncSend=true.
Best regards, Ivan
christoph_75 wrote:
>
> I am using the activemq-cpp-library-3.1.2 and activemq 5.3.1
> one possibility might maybe using the vm transport , but i don't see any
> vmTransportfactory in the activemq-cpp-library-3.1.2 ,
> so i guess the vm transport isn't supported in this library , correct ?
>
, and it looks like it doesn't
support CLIENT_ACKNOWLEDGE mode. Only DUPS_OK_ACKNOWLEDGE and
AUTO_ACKNOWLEDGE are supported.
P.S. Any help of link to proper piece of documentation is highly
appreciated (I failed to find it).
Best regards, Ivan
g bad
happened inside method onMessage() of my MDB. How can I achieve this?
P.S. Any help of link to proper piece of documentation is highly appreciated
(I failed to find it).
Best regards, Ivan
--
View this message in context:
http://old.nabble.com/ActiveMQ-RA%3A-how-to-make-MDB-with-CLIENT_ACKNOW
Hi Tim,
> Care to work up a patch for it and create an issue?
Sure, I will do it soon.
Best regards, IVan
--
View this message in context:
http://old.nabble.com/ActiveMQ-CPP---why-ResourceLifecycleManager-is-not-synchronized--tp27653021p27656486.html
Sent from the ActiveMQ - User mail
ethods.
Any suggestions? Maybe I misuse SessionPool or PooledSession somehow?
Best regards, Ivan
--
View this message in context:
http://old.nabble.com/ActiveMQ-CPP---why-ResourceLifecycleManager-is-not-synchronized--tp27653021p27653021.html
Sent from the ActiveMQ - User mailing list arch
Hi!
Is there any way to purge a queue from a C++ application that uses
ActiveMQ-CPP client?
Best regards, Ivan
--
View this message in context:
http://old.nabble.com/ActiveMQ-CPP---how-to-purge-a-queue--tp27562975p27562975.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> Its possible it could cause an issue. You are welcome to open a new
> Jira issue and submit a patch to fix the problem.
Thanks, Tim.
I'll try to fix it.
Just wanted to check if anybody else already done that :)
--
View this message in context:
http://old.nabble.com/ActiveMQ-C%2B%2B%3A-warni
By the way, is it the right place for such questions, or is it better to open
JIRA issue?
--
View this message in context:
http://old.nabble.com/ActiveMQ-C%2B%2B%3A-warning-%22deletion-of-pointer-to-incomplete-type%22-tp27323723p27323921.html
Sent from the ActiveMQ - User mailing list archive at
One of possible reasons of crash in __pthread_startup could be "-mt" flag
missing in LDFLAGS...
I've seen this few months ago on HP-UX 11i v2 (11.23) on IA64 platform with
latest version of HP aCC compiler. Not sure if it is applicable to GCC
build.
--
View this message in context:
http://old.na
Hello
The latest version of ActiveMQ C++ client (3.1.0) gives the following
warning (multiple times) when compiling it with Visual C++ 2008 SP1 on
Win32:
1>SimpleLogger.cpp
1>c:\dev_vc9\activemq\activemq-cpp\src\main\decaf/lang/Pointer.h(357) :
warning C4150: deletion of pointer to incomplete ty
essage published (preferable with 1 message, instead of
> sending for example 50 published messages).
>
> Any ideas how to do this with ActiveMQ?
> --
> View this message in context:
> http://old.nabble.com/Send-%27cache%27-on-connect-tp27285420p27285420.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
Ivan
ks,
Truly yours,
Ivan Pryvalov.
Dejan Bosanac пишет:
Hi Ivan,
have you tried 5.3 snapshots? There were some similar issues that could be
fixed.
Cheers
--
Dejan Bosanac
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nightta
new message to AMQ, it can be read, but
old messages are still unread..
Have someone face it or can explain it?
Thanks in advance,
Truly yours,
Ivan Pryvalov.
connection?
Best regards, Ivan
--
View this message in context:
http://www.nabble.com/ActiveMQ-CPP%3A-how-to-send-to-temp-queue--tp24516906p24517865.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ject
instead of storing std::string with a name of the temporary queue?
P.S. I tried hard to find answer on this question in this mailing list, in
ActiveMQ-CPP examples and docs, but I failed.
Best regards,
Ivan
--
View this message in context:
http://www.nabble.com/ActiveMQ-CPP%3A-how-to-sen
delete accumulated messages in AMQ after restarting. The one
possible way is to delete /data folder. But is there exist other way,
for example, via configuring aсtivemq.xml?
Thanks in advance!
Truly yours,
Ivan Pryvalov.
Bruce Snyder пишет:
On Wed, Sep 10, 2008 at 10:38 AM, ivan <[EMAIL PROTECTED]> wrote:
Hi!
I use AMQ 5.1.0 and I have following situation:
JMS consumer can reveice JMS-messages and processes it for some time (for
example, more than 1 sec).
For testing I send few messages in a short t
could
not achive required result.
Probably it is because of I'm beginner in using AMQ and I don't know for
now a lot of things around AMQ and JMS...
Thanks in advance,
Ivan Pryvalov.
minutes of working AMQ and SMX (10-15
minutes). I don't send any JMS message, just SMX and AMQ are running.
What can be cause of it?
What specific configuration of AMQ should I use to avoid those problems
with OutOfMemory?
Thanks, Ivan Pryvalov.
The problem is actually with the non-blocking socket implementation in my
PHP/Stomp client. I'll have to investigate little bit more on this in order
to implement it better.
Do you have some experience with non-blocking sockets and Stomp with
ActiveMQ?
Thanks
Cheers,
Ivan
Ivan Jova
HI,
I succeeded to put big messages on my broker with your PHP/Stomp client and
your test code.
I'll look inside my Stomp client a bit deeper to see what happens.
Thanks for bringing back hope on the stage ;)
Cheers,
Ivan
Dejan Bosanac wrote:
>
> Hi,
>
> I've trie
I'm experiencing the same problem with the large messages in PHP/Stomp.
Did you solve this one, since your problem dates from couple of months ago?
Thanks in advance for the answer.
Cheers,
Ivan
gwittel wrote:
>
> Hi
>
> We're using a Perl/Stomp client to retr
port.run(TcpTransport.java:183)
at java.lang.Thread.run(Thread.java:619)
Ivan Jovanovic wrote:
>
> I have installed ActiveMQ 5.1 as broker and I'm using PHP Stomp client
> (not one from codehouse but self made) to communicate with the broker. I
> have no problems for m
find a way to control the message size but
it seems that memory settings are important when not using persistent
storage, otherwise it should be no issue.
Thanks for your help in advance
Cheers
Ivan
--
View this message in context:
http://www.nabble.com/Connection-reset-by-broker-with-messages-gr
I have the same question?
Did anyone implemented this kind of configuration?
Cheers,
Ivan
j0llyr0g3r wrote:
>
> Hey folks,
>
> i have a configuration problem which hopefully can be solved:
>
> I have an up and running mySQL-Cluster consisting of 2 nodes (let's say
&g
75 matches
Mail list logo
