Re: Re: What is the effect of dedicatedTaskRunner Attribute?

Hey, So If I use this configuration : *"optimizedDispatch=true" and "org.apache.activemq.UseDedicatedTaskRunner=true" * It means the sending thread will do dispatch, (There will not be a separate thread for dispatch) and it will not use ActiveMQ thread pool (since I have enabled dedicated tas

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

Tabish, I actually used *Recieve(TimeSpan.FromSeconds(10))* not /Recieve(TimeSpan.AddSeconds(10))/. It was a typo. But still unable to get the message. -- View this message in context: http://activemq.2283324.n4.nabble.com/strange-error-when-consume-message-from-queue-topic-tp4677680p4677846.ht

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

1. use WebRequest to access http://localhost:8161/admin with credentials to login,(you can post a form request to http://localhost:8161/hawtio/#/login instead), 2. keep your WebRequest with cookieContainer of previous request 3. then access jolokia rest api -- View this message in context: htt

Re: REST WSDL/WADL

Hi, I don't think you need a WSDL to make RESTful calls. Here's a good starting point to come up to speed on making REST calls in C#: http://stackoverflow.com/questions/9620278/how-do-i-make-calls-to-a-rest-api-using-c As far as the specific REST API for ActiveMQ, I imagine it's documented somew

Re: Logentry "Setup of JMS message listener invoker failed for destination"

Try changing the "timeBetweenExpirationCheckMillis" to -1. This will turn off the eviction thread. I don't know what implications this will have for your application so test if there's any impact. See http://activemq.apache.org/maven/apidocs/org/apache/activemq/pool/PooledConnectionFactory.html

Re: Send a message to a distant ActiveMq Queue (using MS-DOS Command Line)

I'm not aware of existing command-line friendly tools. Some ideas: * Use ActiveMQ-CPP to create a command-line program * Write a simple java program run from the command-line * Use ActiveMQ-NMS to create a command-line program * Use wget or curl to POST the messages to the activemq REST api Note

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

I tried again and this time I didnt send bunch of messages at same time. I noticed that some message gets processed right away but some messges stays on queue and doesnt get processed. If send few more messges let say 50 messages and it processes 40 messages and 10 msgs left on queue. I can send mo

Re: on which limit is the cursorMemoryHighWaterMark based

I assume you are referring to the broker's "SystemUsage", but I'm not sure what you mean by "by default"? are you implying that something can change it, and if so, what? -- View this message in context: http://activemq.2283324.n4.nabble.com/on-which-limit-is-the-cursorMemoryHighWaterMark-based

Re: Leveldb on Solaris?

On 02/11/2014 03:40 PM, jlindwall wrote: I'll try that snapshot, thanks. Um ... my svn skills are rusty. ANy idea why this "svn co" command below does not actually seem to do anything? $ svn checkout https://repository.apache.org/content/repositories/snapshots/org/apache/activemq/ svn: OPTIONS

Re: Leveldb on Solaris?

I'll try that snapshot, thanks. Um ... my svn skills are rusty. ANy idea why this "svn co" command below does not actually seem to do anything? $ svn checkout https://repository.apache.org/content/repositories/snapshots/org/apache/activemq/ svn: OPTIONS of 'https://repository.apache.org/content/r

Re: Leveldb on Solaris?

There was a lot of fixing done for LevelDB after v5.9.0 was released. You might want to try the same test using a 5.10-SNAPSHOT and see how that goes. On 02/11/2014 03:21 PM, jlindwall wrote: I'm trying out leveldb persistence on Solaris (sparc). Is this a supported platform? I get a DEBUG

Leveldb on Solaris?

I'm trying out leveldb persistence on Solaris (sparc). Is this a supported platform? I get a DEBUG msg/stacktrace at startup saying the system cannot find leveldbjni library, but I assume that is ok since we are using the pure java implementation. I then run my test with 100 durable subscriber

Re: More than 10 consumers

@Singleton @Lock(LockType.WRITE) ??? <- this is a bottlenck PS: i dont know if that's my gmail but i dont have the stacks, justt the thread names Romain Manni-Bucau Twitter: @rmannibucau Blog: http://rmannibucau.wordpress.com/ LinkedIn: http://fr.linkedin.com/in/rmannibucau Github: https://github.

RE: activeMQ topics via rest - missing messages

Allow me to clarify. First, perhaps my statement is a little stronger than it should be - I wouldn't use it, but I can see it being used. Here's my reasoning: * REST and JMS protocols are notably different; REST is one-message-per-connection while JMS is many-messages-per-connnection * JMS subsc

Error creating subscription

Hi I am running hornetQ with stomp on. I am running the following code: Apache.NMS.Stomp.ConnectionFactory factory = new Apache.NMS.Stomp.ConnectionFactory("tcp://localhost:61613"); using (IConnection connection = (IConnection)factory.CreateConnection()) using

Send a message to a distant ActiveMq Queue (using MS-DOS Command Line)

Hi ! My company uses a very old application developed in Uniface 7 My team currently develops a new application based on Talend ESB and Java Programs. Today, we have a big issue. We need to run the too application together. So we need to send a message from Uniface 7 to ActiveMq. However, Uniface

Re: More than 10 consumers

I think it is linked, in all case once you get a complete thread stack it should be quite obvious (maybe use gist to share it) Romain Manni-Bucau Twitter: @rmannibucau Blog: http://rmannibucau.wordpress.com/ LinkedIn: http://fr.linkedin.com/in/rmannibucau Github: https://github.com/rmannibucau 2

performance Replicated LevelDB vs. SAN

The following links states: http://activemq.apache.org/masterslave.html For those willing to try out new tech, the Replicated LevelDB Store gives speeds similar to a SAN solution without the hassle of having to setup a highly available shared file system. During our testing with Replicated LevelD

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

you got to peek at the code to get exact detail. see: https://github.com/apache/activemq/blob/trunk/activemq-client/src/main/java/org/apache/activemq/thread/TaskRunnerFactory.java?source=cc#L86 so it is either dedicated or shared (pooled) optimizeDispatch is per destination, and controls whether

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

On 02/11/2014 10:26 AM, neosmrt wrote: It is an ActiveMQMapMessage since my application was able to push message into queue, verified by Web Console. Error is coming from the same line, I verified it by debugging line by line and error was thrown when Recieve() method is called. I even tried Reci

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

It is an ActiveMQMapMessage since my application was able to push message into queue, verified by Web Console. Error is coming from the same line, I verified it by debugging line by line and error was thrown when Recieve() method is called. I even tried RecieveNoWait() and Recieve(TimeSpan.AddSecon

Re: More than 10 consumers

this is for producers, the bottleneck is in the consumers I guess [] Leo On Tue, Feb 11, 2014 at 1:05 PM, Romain Manni-Bucau wrote: > @Singleton > @Lock(LockType.WRITE) ??? <- this is a bottlenck > > PS: i dont know if that's my gmail but i dont have the stacks, justt > the thread names > Roma

Showing entire xml in activmq

Hi, I'm a newbie to activemq... I want to know how I can combine all the messages in activemq queue (for eg I have 900 records)to form an xml? TIA for help -- View this message in context: http://activemq.2283324.n4.nabble.com/Showing-entire-xml-in-activmq-tp4677677.html Sent from the Ac

Re: More than 10 consumers

Hi I really don't know where is the bottleneck. I've created a new project from the scratch to try to isolate the variables. Now I have something as simple as producer: public void createTasks() throws JMSException { for(int i=0;i<1000;i++){ if (i%100 == 0){

Re: Kahadb diagnostic logging

Hi christian, How frequently this diagnostic logging happens? Does it happen for every persistent message received by broker? Could you please tell me for what operations i can expect these kind of log messages? Thanks, Abhi -- View this message in context: http://activemq.2283324.n4.nabble.co

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

Hi kimmking: I could access the urls you provider in my chrome browser, they give me correct responses. However, I write a sample c# program to access these uri , I get "403 forbidden" error. I think I should "log in" in my program , as I log in to hawtio in my browser. How can I do that in c#?

Re: OptimizedDispatch and DedicatedTaskrunner

Hey, So If I use optimize dispatch there will not be one thread per queue for message dispatching; than how does the message dispatch processing will happen. (I am using dedicated task runner which is by default ) AND I am little bit confused here. I have my thread trace here which is pasted bel

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

Guys please respond !! Give me some idea about dedicated task runner. I am now totally confused between *dedicated task runner Pooled task runner *and o*ptimizedisaptch * By making * org.apache.activemq.UseDedicatedTaskRunner=false * is it by default enable pooledtaskrunner or it's just disab

Re: REST WSDL/WADL

Hi Mr. JGomes: I want to call REST management API in c# code, where can I get the wsdl file? Is using HttpWebRequest/Response class the only way to do it? -- View this message in context: http://activemq.2283324.n4.nabble.com/REST-WSDL-WADL-tp2361712p461.html Sent from the ActiveMQ - Use

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

Still confused but thanks anyway.I should try it. -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-call-REST-API-for-brokerMbean-getQueues-and-queueViewMbean-removeMatchingMessage-java-lang-tp4677762p4677768.html Sent from the ActiveMQ - User mailing list archive

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

1. http://localhost:8161/hawtio/jolokia/read/org.apache.activemq:brokerName=localhost,type=Broker/Queues 2. http://localhost:8161/hawtio/jolokia/exec/org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=a/removeMatchingMessages(java.lang.String)/type='1'

Re: on which limit is the cursorMemoryHighWaterMark based

SystemUsage by default -- View this message in context: http://activemq.2283324.n4.nabble.com/on-which-limit-is-the-cursorMemoryHighWaterMark-based-tp4677761p4677763.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.