strange error when consume message from queue/topic.

I am facing a strange issue. I pushed a message in a queue. Then I created an application which acts as consumer of a message. In AciveMQ Web console I can see 1 message is Enqueued and in Pending Messages column. Then When I call consumer.Recieve() an error is thrown. *Not a valid Win32

strange error when consume message from queue/topic.

Need help for a strange issue I am facing when try to consume a message in ActiveMQ. I pushed a message in a queue. Then I created an application which acts as consumer of a message. In AciveMQ Web console I can see 1 message is Enqueued and in Pending Messages column. Then When I call

Re: strange error when consume message from queue/topic.

Have you considered to use an asyncronous receiver? Try to implement the asyncronous function onMessage(const Message*)...see the ActiveMq CMS documentation. -- View this message in context:

Re: How to improve the performance of composite queue

I have tried to use non-persistent messages. Messages are still blocked on broker A. The CPUs remains 2x% usage while using top to monitor. If non-persistent messages are still blocked, can eliminate io as the cause of this issue? -- View this message in context:

Ambiguous class names

Hi to all, I'm trying to design GUI applications with VisualStudio2012 to test my Producer and Consumer activeMq CMS libraries. To explain my problem I attached, some pictures and code. I'm using: -ActiveMq cpp library 3.8.1 -Apache ActiveMq 5.8.0 -Visual Studio 2012 this is a part of the code

Re: Ambiguous class names

On 02/10/2014 06:27 AM, cecchinoSMI wrote: Hi to all, I'm trying to design GUI applications with VisualStudio2012 to test my Producer and Consumer activeMq CMS libraries. To explain my problem I attached, some pictures and code. I'm using: -ActiveMq cpp library 3.8.1 -Apache ActiveMq 5.8.0

Re: Ambiguous class names

If I don't use the namespace, I need to include manually all the header file that are necessary to implement my classit is not very elegant... -- View this message in context: http://activemq.2283324.n4.nabble.com/Ambiguous-class-names-tp4677683p4677691.html Sent from the ActiveMQ - User

Re: Ambiguous class names

But...I say...why you call a file System.h in the folder cms::decaf when you well know that exist the same in the folder of windowsI'm locked cause now I can't use Windows Form in Visual C++ with cms libraries -- View this message in context:

Re: Ambiguous class names

On 02/10/2014 09:11 AM, cecchinoSMI wrote: But...I say...why you call a file System.h in the folder cms::decaf when you well know that exist the same in the folder of windowsI'm locked cause now I can't use Windows Form in Visual C++ with cms libraries -- View this message in context:

Re: Error using OSGi services in activemq spring xml

I noticed you are references the karaf.base property in your config like ${karaf.base}... typically that won't resolve unless you use the blueprint cm extension ... I don't know tbe namespace offhand but if you do a search on it or look at the karaf docs, it talks about the karaf placeholders and

activeMQ topics via rest - missing messages

I'm trying to set up a framework for our AMQ testing and running into a roadblock. Say I make a POST to http://localhost:8161/api/message/TESTTHISTOPIC?type=TopicclientId=testClient with body=foo1 Then I make a DELETE (or GET, neither work) to the same url with no body param. The call returns a

jdbcPersistenceAdapter limits ?

Hi, I'm using simple configuration : bean class=com.mchange.v2.c3p0.ComboPooledDataSource name=storeDataSource destroy-method=close property name=jdbcUrl value=${broker.store.jdbc.url}?autoReconnect=true / property name=user value=${broker.store.jdbc.user} / property

Re: question about producer flow control

Any pointers, links, etc? -- View this message in context: http://activemq.2283324.n4.nabble.com/question-about-producer-flow-control-tp4677629p4677709.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Hawt.io error

We receive this error in our karaf logs, and am wondering what it is? I can login to Hawt.io with no issues, but do see this error: org.apache.maven.wagon.TransferFailedException: Error transferring file: Connection refused

Re: jdbcPersistenceAdapter limits ?

Answer to myself, I corrected the situation with : systemUsage systemUsage memoryUsage memoryUsage limit=0/ /memoryUsage storeUsage storeUsage limit=0/ /storeUsage tempUsage tempUsage limit=0/ /tempUsage

Re: question about producer flow control

On the extra thread per queue, last I checked that was true and would need to research to see if it has changed. Disabling Producer Flow Control removes all limits as there is nothing in place to prevent a producer from sending more messages to the broker regardless of the limits, and the broker

Kahadb visibility?

Do I have any visibility into the contents/metadata of the kahadb datastore? The mbean attributes exposed by the persistent adapter are quite minimal (the location of the on-disk store, and a Size value which I do not really understand). It'd be nice to see how many messages it has in storage

Re: question about producer flow control

Thanks for the update. Having an extra thread per destination worries me, but running without limits worries me way more, so i guess i will have to accept that for now. I couldn't track down where in the code those threads might be generated. i was wondering if they are dedicated threads or

Re: activeMQ topics via rest - missing messages

First off, let me warn that this isn't a recipe that I would use; actually any REST interface for JMS is a nice feature for prototyping, but not something I would use for production-quality code. Add Topics to that mix, and it's really concerning. With that said, your problem may be easy to

Re: Ambiguous class names

For those names which the compiler complains are ambiguous, try the full class name. If the name is in the toplevel namespace, try prefixing it with ::. I suspect the problem is overlapping names in the imported namespaces. On 02/10/2014 09:11 AM, cecchinoSMI wrote: But...I say...why you

Re: strange error when consume message from queue/topic.

Perhaps the message is not truly an ActiveMQMapMessage? Also, with the catch (Exception ev) {}, is it possible the error is coming from another line of code? -- View this message in context:

Re: Ambiguous class names

For the name of the header file, I recommend using -I on the ancestor directory and #include cms/decaf/System.h - that will prevent any possibility of conflict with O/S (or other library) headers named System.h. -- View this message in context:

Re: Broker Hangs after some time - or does nothing.

I have producerFlowControl to false. I seperated my producer and consumers. But still I was able to reproduce issue. For some time bunch of messages started pile up in queue. Then they started to endup in DLQ. In DLQ I saw most of them have these property: dlqDeliveryFailureCause:

Re: Broker Hangs after some time - or does nothing.

Perhaps I misunderstood Broker Hangs. It helps to have more detailed symptoms. The messages in the DLQ are failing at the consumer - either transactions rolling back, or otherwise failing before commit, or CLIENT_ACKNOWLEDGE client calling Session.recover(). See here for more details:

RE: activeMQ topics via rest - missing messages

When I read http://activemq.apache.org/rest.html;, I don't see anything saying the REST/HTTP interface should not be used in production code. Please elaborate, send me, or direct me to a list of your concerns. I understand that Java clients would want to use the JMS API, but what is so wrong

how can I call REST management API in c# ?

I want to set a unique guid for each message in message head , then if I want , I could delete a specific message by its guid. I did some search and I think only jmx management api can help me with this task.But ActiveMQ.NMS did not have such apis. The activemq website says Starting with

Re: Can I delete a message from a queue in c# code ?

Hi Mr. Bish : the IKVM way did not work fine, and I can't come up with any simple solution by now. Can you help me a little bit ? Here are my use case : the messages I sent are notifications for future work in a workflow system. Everyone who is responsible for doing the work should receive

how can I call REST management API in c# ?

Rest api is a cross-platform approach for java\c# or others. You can create a text http request by WebRequest to send a command and parse the response text to get the result. -- View this message in context:

Re: Broker Hangs after some time - or does nothing.

i said broker hangs bcs if i tried to send more messages or messages on queue doent get processed. i cannot even create queue or send message using webconsole. will try again and rhis time will moniter memory. On Feb 10, 2014 6:22 PM, artnaseef a...@artnaseef.com wrote: Perhaps I misunderstood

unsubsribe

unsubscribe NOTICE: This email message is for the sole use of the intended recipient(s) and may contain confidential and privileged information. Any unauthorized review, use, disclosure or distribution is prohibited. If you are not the intended recipient, please contact the sender by reply

Re: how can I call REST management API in c# ?

Hi kimm. Thanks very much for quick reply. I have two further problems: first, I can not find any documentation about REST management api, I think there should be a list of available apis , and the convention to call them, at the very least, how to send api parameters and how to receive return

on which limit is the cursorMemoryHighWaterMark based

i'm trying to figure out how the memory limit based on the cursorMemoryHighWaterMark is actually calculated. some posts i've read seem to claim the high water mark is a percentage of the per-destination memory limit. other posts seem to claim it is based on the broker system usage memory limit.

How can I call REST API for brokerMbean.getQueues() and queueViewMbean.removeMatchingMessage(java.lang.string) in c# ?

I think the subject itself explains my problem pretty good. Thanks very much for any help. Really getting into trouble to find solutions today. -- View this message in context: