Failure reason: javax.management.InstanceAlreadyExistsException 5.5.1

Hi all, I've durable consumers connected to activemq 5.5.1. Sometimes, these durable consumers were disconnected and could connect again. In activemq debug log I can see this traces: Setting up new connection id: ID:V1222-1044-1349553778453-0:1, address: /10.4.23.22:1050 | org.apache.activemq.bro

Problem expired messages for durable consumers in 5.6

Hi all, I have several durable consumers that could be disconnected some time. I have a high traffic load, so if there are one or more durable consumers disconnected, Im running into a java heap error (no space). I'm sending messages with timeToLive property to 6 ms (sets in the message), and

ActiveMQ-CPP. Any way to obtain clientId in a producerInfo advisory message?

hi all, I have this case: case activemq::commands::ProducerInfo::ID_PRODUCERINFO:{ Pointer info = amqMessage->getDataStructure().dynamicCast(); Pointer& aux=info->getProducerId(); } but I cant find the way to obtain the real client Id, I've only can get the real identification [hostname-:xxx

Activemq IPV6 Client Connection (Java and C++)

Hi all, Im trying to use ActiveMQ with IPV6 but Im running into some problems. I'm in debian linux, and seems that ActiveMQ(5.5.1) is up and listening IPV6. tcp6 0 0 :::61616 :::* LISTEN 24671/java I can make a ping and a telnet to ::1 61616 and all seems that works fi

Re: Problem pure nothing slave-master

| Listening for connections at: tcp://localhost:61620 INFO | Connector openwire Started I could see some issues in jira but Im not sure, any advice? thanks! El 20 de marzo de 2012 14:33, Oscar Pernas escribió: > Hi all, > > Im having a problem and I dont know how to resolve it. I have

Problem pure nothing slave-master

Hi all, Im having a problem and I dont know how to resolve it. I have a broker called master, that doesnt have any changes between the file to make a cluster. I have a slave node that contains this (only thing that changed is bold) http://www.springframework.org/schema/beans"; xmlns:amq="http://

disable a specific advisory message

Hi, I've disabled the deadletters queue like this: because I dont want to post process expired messages. Now Im seeing that when the broker discards this expired messages, it drops messages from the client. I was thinking that could be because a lot of messages are sen

Re: producer flow control questions

roker drops this packets, because if you use fileCursor, I thought that any message will be discarded and all will be store into disk. Is it normal? regards 2012/1/27 Matt Pavlovich > Oscar- > > What is your Java heap size? > > > On 1/27/12 5:29 AM, Oscar Pernas wrote: >

Re: producer flow control questions

When the memory usage grows to 100% and outOfMemory of java heap is thrown, Are the cursors working well? did I miss some configuration? Im using activemq 5.5.1. regards 2012/1/27 Oscar Pernas > I dont know why, but If I set fileCursor and to a topic my broker starts > to consume

Re: producer flow control questions

I dont know why, but If I set fileCursor and to a topic my broker starts to consume memory untill hungs with java heap size limit... fileCursor should not avoid this? 2012/1/27 Oscar Pernas > Hi all, > > Im trying to optimize and hardening activemq and I have some question: >

producer flow control questions

Hi all, Im trying to optimize and hardening activemq and I have some question: - If I set producerFlowControl to false, should I need to set the memory limit? I dont know if I set the memory limit, firstly all messages goes to memory until is full, and after that goes to disk? - Do I need to set

CreateTemporaryQueue hungs (stack trace)

Hi all, Im using ActiveMQ-5.3.1, with a Java application (JVM 1.6). Im getting into a problem because when I try to create a temporary queue, my thread is being blocked. The stack trace is: MutexTransport.oneway(Object) line: 40 ResponseCorrelator.asyncRequest(Object, ResponseCallback) line: 74 R

Re: Segfault with ActiveMQ-CPP 3.4.0 (Fedora 15 and Fedora 16)

If you restart and doesnt work, could be any environment variable? library path? 2011/12/15 Donoso Gabilondo, Daniel > After restart the operating system, it fails again. I don't understand > what happens. > The application can't start and I can't debug it, because it doesn't stop > in the first

Re: CMS --> JMS: javax.jms.JMSException: java.io.UTFDataFormatException

Sorry, It was a problem of the encoding of my cpp file. regards 2011/12/9 Oscar Pernas > Hi all, > > Im sending TextMessages from C++ client to a Java Application. Everything > goes fine, except when I add spanish chars like 'ñ'. If I use c++ to send > and receive m

CMS --> JMS: javax.jms.JMSException: java.io.UTFDataFormatException

Hi all, Im sending TextMessages from C++ client to a Java Application. Everything goes fine, except when I add spanish chars like 'ñ'. If I use c++ to send and receive messages with 'ñ' all goes fine. If I send ñ char to a queue and I try to display on the activemq webadmin console, when I click

Re: CMS 3.4.0 - Deadlock in IOTransport With Failover

Hi, I have activemq-cpp in production too, Could you explain the exactly environment in which you fall into the bug? when the connection is interrupted the producer cant switch to the next broker, or is the consumer? When I had synchronous consumer, I had some problems with reconnection but when

Java app hanging at createTemporaryQueue

Hi all, I am using ActiveMQ with a Java application. My problem is if I shutdown the broker, or if I remove the cable, when Java application reconnects, its hangs in method createTemporaryQueue. I've looking for what could be the lock of this method, but I only see that this method should throw an

Re: ActiveMQCPP - Failover and prefetch=0 can result in hung consumers if the MessagePull command is lost

Hi Laugt, Are you using synchronous or asynchronous consumer? When I was using synchronous consuming I used to have problems with failover reconnection. regards 2011/11/8 Daniel Laugt > It seems that email attachment is not allowed... I put the diff directly > below... > > > > Daniel Laügt. >

ActiveMQ - IDLE SCEP@ message

Hi all, I was testing an application and I saw that one producer couldnt send messages to the broker. I cant understand why, and looking for something weird in the broker, I've seen the following trace: IDLE SCEP@13664269 [ d=false, io=1, w=true, rb=false, wb=false] I know that there is one bug

ACTIVEMQ-CPP. All machine memory consumed

Hi all, I have a Java application on one side and a C++ client on the other one. The Java application have a bug and any of the temporary queues that it creates are released. With this bug, the broker start to consume memory, and after a while, I can see an OutOfmemory exception. The problem is

Re: ConnectionInterrupt activemq & activemqcpp

? regards 2011/10/4 Oscar Pernas > Hi all, > > I am seeing a strange behaviour with activemq and activemq-cpp. > > I have different consumer/producers of queues and topics over an unique > broker. > > In traces I could see connections interrupts of only one consumer, but the &

ConnectionInterrupt activemq & activemqcpp

Hi all, I am seeing a strange behaviour with activemq and activemq-cpp. I have different consumer/producers of queues and topics over an unique broker. In traces I could see connections interrupts of only one consumer, but the rest consumer/producers ( that uses the same broker are still working

Re: exit app after broker down

ataStructureType() == RemoveInfo.DATA_STRUCTURE_TYPE){ RemoveInfo removeInfo = (RemoveInfo) data; mLogger.info("DESCONNECT : "+removeInfo.getObjectId()); }else { mLogger.info("Unknow message : "+data); } } catch (Exception e) { mLogger.error("Excepti

exit app after broker down

Hi all, Im using Java Client to make a small application to catch all advisory messages from the broker. Ive set the following connection string: failover://(tcp://localhost:61616) The application starts succesfully, but if I stop the broker, after a few secons, my application exits. The last m

Re: changing time in broker machine

ds > -- > Dejan Bosanac - http://twitter.com/dejanb > - > The experts in open source integration and messaging - > http://fusesource.com > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Wed, Jul 27, 2011 at 8:54 AM, Osc

changing time in broker machine

Hi all, We were making tests of our system and we saw that the time of the broker's machine was not with the same ntp time that the rest. We changed the time of the machine and after that the broker doesn't deliver any more messages. We are using persistent messages, and I think that is reasonable

Re: using activemq-cpp-library

Hi, you have a visual studio project inside the zip file. The problem is that in 2010 doesnt work, or what? 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 t

Re: ActiveMQ-CPP client hangs while connecting when ActiveMQ is not running

If you are using startupMaxReconnectAttempts=3, connection should not block you. Perhaps could be the way of you are writing the address. I allways set address like this: failover://(tcp://localhost:61616)?startupMaxReconnectAttempts=1&initialReconnectDelay=1 and it works fine. Try it. 2011/5/1

Re: How to send a textMessage to an exising queue (destination)

Hi Ming, I think that nobody needs to do something like this because, guessing about your problem, you could be trying to dont allow to send messages to a queue/topic, if you have no consumer of the same one? (the consumer creates the queue/topic). is it? (if I'm wrong sorry) One of the features

Re: Failover, how does it work?

011 10:32 AM > To: users@activemq.apache.org > Subject: Re: Failover, how does it work? > > On Thu, 2011-03-24 at 13:27 +0100, Oscar Pernas wrote: > > Hi all (again), > > > > > > Im trying to understand well, how the failover transport works. I know > > that if you h

Failover, how does it work?

Hi all (again), Im trying to understand well, how the failover transport works. I know that if you have an active-pasive architecture and your active broker goes down, all messages are send to the pasive broker. But, for example, if we have a machine that have configured an active-pasive brokers

ACTIVEMQ-CPP. Someone is using it under windows XP?

Hi all, Why I try to run activemq-cpp in windows environment, with this kind of uris: failover://(tcp://localhost:61616)?startupMaxReconnectAttemps=3&initialReconnectDelay=3000 if a producer configured in failover with only one ip but non-blocking (with maxreconnect attemps and initialreconnect

ACTIVEMQ-CPP. TcpSocketOutputStream

Hi all, I think that this issue is probably related with others that we've talked before, but its could help. How to reproduce: - Sending data - close broker - close producer And the exception thrown is terminate called after throwing an instance of 'decaf::io::IOException' what(): TcpSocke

Re: ActiveMQ-CPP: deadlock when broker restarts and failover is used

This bug was reported some time ago. If you want to make a workaround, if you are consuming messages in asynchronous (by callback), change to synchronous consuming mode. In my case its resolved it. 2011/3/14 chris > Hi all, > > we seem to have a deadlock situation when a broker shutdown happens.

ACTIVEMQ-CPP. Which broker is chosen in a failover URI.

I have an URI like this: ipbroker="failover://(tcp://localhost:61616,tcp://sig-hormes10:61616)" Sometimes when I start the application, the consumer starts to consume to the second IP instead the first one. Why? I've tested using initial reconnect delay but with the same issue. -- Óscar Pernas

Re: AMQ-CMS - questions about threads/producerthreads in AMQ

Hi mzo, To do what you want to do I did a conditional mutex over a concurrent access queue. If you want to take a look of my code: https://code.google.com/p/activeinterface/source/browse/#svn%2FActiveInterface%2Fsrc%2Fcore%2Fwrapper

Re: AMQCPP: unexpected exception

8 INFO (ActiveProducer:965) - Producer::deleting session... 2011-03-07 02:27:48 INFO (ActiveProducer:976) - Producer::deleting connection... pure virtual method called terminate called without an active exception 2011/3/7 Oscar Pernas > Yes, It's probably the same issue. I've reso

Re: AMQCPP: unexpected exception

/failover/FailoverTransport.cpp:186 > #10 0x0109ff9f in > activemq::transport::correlator::ResponseCorrelator::oneway > (this=0x9bd71c0, command=...) at > activemq/transport/correlator/ResponseCorrelator.cpp:82 > #11 0x010093be in activemq::core::ActiveMQConnection::oneway > (this=0

Re: AMQ-CMS - questions about threads/producerthreads in AMQ

I think that if you go to section CMS-API-Overview http://activemq.apache.org/cms/cms-api-overview.html At the end, you could see something that is more addaptable for that you want. I think ;-) regards 2011/3/4 > Hello there, > > greetings from

Re: AMQCPP: unexpected exception

Hi, I ran into this bug before. If I am shutting down and starting the broker so many times, connection are not reestablished and the consumer gets frozen. If you try to close the consumer that is frozen, the closing stucks your thread too? In my case, this problem only happens when I'm debugging

AMQCPP. Closing consumer freezes if broker is stopped while is consuming

Hi, When the consumer is consuming messages, if I stop the broker, and after that I try to delete the consumer, the closing method stops in this instruction: if( consumer != NULL ) delete consumer; This delete, freezes all the application, and never return back. Have I have to use some instructi

Re: ACTIVEMQ-CPP. Connection with broker lost? connection interrupt lost?

reconnect and any new message is received (connectionRestore is never called) 2011/2/10 Timothy Bish > On Thu, 2011-02-10 at 19:41 +0100, Oscar Pernas wrote: > > Activemq-cpp 3.2.4 > > Debian (and tested in windows xp too) > > gcc version 4.4.4 (Debian 4.4.4-1) > > &g

Re: ACTIVEMQ-CPP. Connection with broker lost? connection interrupt lost?

consumer reconnects and the other one not, and viceversa... 2011/2/10 Timothy Bish > On Thu, 2011-02-10 at 17:29 +0100, Oscar Pernas wrote: > > Hi all, > > > > > > I am testing the transport interrupt and restore of Activemq-CPP over > > topics. > > > > I h

ACTIVEMQ-CPP. Connection with broker lost? connection interrupt lost?

Hi all, I am testing the transport interrupt and restore of Activemq-CPP over topics. I have a producer sending messages to the broker and a consumer consuming them. If while we are receiving messages, I close the broker, I can see that Im not always receiving the transport interrupt message, w

Re: ActiveMQ-CPP. mutex.wait( timeOut );

Hi all, Someone test it? it's only happening to me? Regards! 2011/1/17 Oscar Pernas > Hi Tim, > > Here you have the test case, is a visual studio 2005 project, you only have > to compile giving an ip address in where there are no brokers. In this > example when the co

ACTIVEMQ-CPP Error compiling with windows.h header included in the project

Hi all, Im using ActiveMQ-CPP in a dll using windows XP. When I was trying to compile my library (that uses activemq-cpp), I was always having error C2059: syntax error : 'constant' in thread.h class of decaf/lang. I was looking for a solution and I saw that the constant was defined in winspool.

Re: ActiveMQ-CPP. mutex.wait( timeOut );

are going to see that when you delete connection and session, the cpu start to take 100%. Tell me if you need more information. Oscar Pernas Plaza 2011/1/17 Timothy Bish > On Mon, 2011-01-17 at 14:05 +0100, Oscar Pernas wrote: > > Hi all, > > > > > > I've fo

Re: ActiveMQ-CPP. mutex.wait( timeOut );

tForSIngleObject the method that produces the high cpu load. If the connection cannot start, I have to make a close, but it hangs my cpu, If I catch the exception could I set connection to NULL or will be a leak? Any other idea to close connection resource withouth this cpu high load? 2011/1

ActiveMQ-CPP. mutex.wait( timeOut );

Hi all, I am developing an application that uses JMS and needs to start with or without the connection to broker was stablished or not. For this, I am coding a reconnect thread that is spawned when the initial reconnects fail. I've set this connection strings: failover://(tcp://10.0.2.22:61616 )

A ActiveMQ-CPP wrapper opinnion

Hi all, I've developed a ActiveMQ-CPP Wrapper that I think that coulde be useful because allow the users to dont have to implement things that should have to implement in a normal development using ActiveMQ-CPP. It's opensource, and for me will be very useful if someone could take a look of the do

ACTIVEMQ-CPP. Topic consumer after connection interrupt and restore

Hi all, Sorry if I'am missunderstanding something but I have a activemq-cpp topic consumer. I am trying to test connection interrupt and restores, and how messages are sent to a durable topic. To do this, I've put a breakpoint in my code after connect to broker. Some time later, I've press to cont

Re: ACTIVEMQ-CPP. Using ssl

.Transport | Async Exception Handler Any idea please? 2010/12/1 Oscar Pernas > Hi all, > > Im trying to use ssl with activemq-cpp. Im trying to give you a manual of > what I've do, and please correct me if something is wrong (something is > wrong because is not working) >

ACTIVEMQ-CPP. Using ssl

Hi all, Im trying to use ssl with activemq-cpp. Im trying to give you a manual of what I've do, and please correct me if something is wrong (something is wrong because is not working) Generatet the keystore for the broker keytool -genkey -alias broker -keyalg RSA -keystore broker.ks Export the

ACTIVEMQ-CPP MaxInactivityduration

Hi all, I've read something about the maxinactivityduration to prevent the closing of producers/consumers while I'am debugging. I've tried to set in the url like this: ?maxInactivityDuration=0 But I have still seeing that the channel is being closed, What Im doing wrong? -- Óscar Pernas Plaza.

ACTIVEMQ-CPP ReadBytes of streammessage

Hi all, Im using streamMessage to send data. I dont know why, but if I send something by this way: streamMessage->writeString(key); streamMessage->writeBytes(bytesParameter->getValue()); When i catch the message on reception I need to do two readBytes to catch the bytes sent, like this: std::s

Re: ACTIVEMQ-CPP Compiling in Visual C 6

Thanks ivan, but are you totally sure? I cant find any reference in the webpage or in the readme files about it. Thanks El 15/10/2010 14:51, "Ivan Pechorin" escribió: 2010/10/15 Oscar Pernas : > Only to know, has anyone compiled activemq-cpp in visual c 6? is supported? As far

ACTIVEMQ-CPP Compiling in Visual C 6

Only to know, has anyone compiled activemq-cpp in visual c 6? is supported? regards -- Óscar Pernas Plaza.

Re: ACTIVEMQ-CPP Error compiling activemq-cpp release SSL

ok, that's it! 2010/9/29 Ivan Pechorin > 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\S

Re: ACTIVEMQ-CPP Error compiling activemq-cpp release SSL

n was ambiguous ..\src\main\decaf\lang\System.cpp(396) : error C2664: 'strlen' : cannot convert parameter 1 from 'LPTSTR' to 'const char *' Types pointed to are unrelated; conversion requires reinterpret_cast, C-style cast or function-style cast Anyone has tri

Re: ACTIVEMQ-CPP Error compiling activemq-cpp release SSL

there is no option to compile activemq-cpp in visual studio 2005? Im going to try to download visual studio 2008 and I'll let you know. thanks! 2010/9/28 Timothy Bish > > > On Tue, 2010-09-28 at 11:55 +0100, Oscar Pernas wrote: > > yes sorry, I'd read somewhere

Re: ACTIVEMQ-CPP Error compiling activemq-cpp release SSL

yes sorry, I'd read somewhere that I had to change the Version="9.00" to Version="8.00" in vcproj to try to open project with visual 2005 ( i can't use vs2008).. this cause the compile errors? 2010/9/28 Timothy Bish > On Tue, 2010-09-28 at 09:59 +010

Re: ACTIVEMQ-CPP Error compiling activemq-cpp release SSL

Windows XP with Visual Studio 2005, on 386 architecture.. thanks 2010/9/28 Timothy Bish > On Tue, 2010-09-28 at 09:59 +0100, Oscar Pernas wrote: > > Hi all, > > > > > > Im trying to compile Activemq-CPP 3.2.3. My problem is that when I try to > > compile SS

ACTIVEMQ-CPP Error compiling activemq-cpp release SSL

Hi all, Im trying to compile Activemq-CPP 3.2.3. My problem is that when I try to compile SSL versions, I allways get compile errors: ..\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)