Re: Some problem of BlobMessage

To delete the file uploaded on the FTP server you can set the following on the blob message consumer: BlobTransferPolicy btp = new BlobTransferPolicy(); btp.setUploadUrl(blobMessage.getURL().toString()); BlobDownloadStrategy strategy = new FTPBlobDownloadStrategy(btp); strategy.deleteFile(blobMessa

Re: Using BlobMessage with ActiveMQ inside ServiceMix

The configuration for embedding the FTP server into ServiceMix 3.6.0-fuse-00-89 is the following: http://mina.apache.org/ftpserver/spring/v1"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://mina.apache.org/ftpserver/spring/v1 http:

Re: Socket write error when uploading BlobMessage

After 2 days of chasing ghosts we realized that the QA missed one of the installation steps and didn't create the "/base" folder for the Apache MINA FTP server. So the connection to the server kept failing only on that test machine. Thank you for your support. -- View this message in context: h

Re: Model thread question

But it doesn't have any sense for me. If a Session has got a ThreadPoolExecutor to execute its tasks , I think that Session can execute code in a parallel way ( between different consumers) To sum up, my question is if it's possible to send messages to different consumers during the same session

Re: Model thread question

Yep, there would be a pool of threads for a session to use to dispatch to a consumer. But that's not the same thing as one thread per consumer. I believe the PDF doc to be incorrect in that regard. On Wed, Sep 4, 2013 at 2:44 PM, Jose María Zaragoza wrote: > OK. Thanks. > > But PDF doc talks abo

Re: Model thread question

OK. Thanks. But PDF doc talks about "one thread **per MessageConsumer**" , picked from a pool of thread. This is my question. The link that you attatched says "This basically means that session will use its ThreadPoolExecutor to execute its tasks." So, again, looks like there is a pool of thread

Re: Producer connections keep breaking

Not sure. How can we recreate this? On Wed, Sep 4, 2013 at 5:18 AM, Alberto Talavera wrote: > Hi, > > We've been experiencing some trouble with producer connections being broken > and not recovering appropriately. Or that's what we've gathered... > > We're using a PooledConnectionFactory with 10

Re: Model thread question

Reading "ActiveMQ in action" doesn't say anything about pool of threads ( one per consumer ) :-S What a mess ... 2013/9/4 Jose María Zaragoza : > Thanks. > > So , PDF is wrong , right ? > what about pool of thread , i.e, one per MessageConsumer ? is it false ? > does internal queues exists ?

Re: Socket write error when uploading BlobMessage

Any exceptions on the broker side? Is there enough JVM Heap on the broker to accomodate the size of your file? On Wed, Sep 4, 2013 at 1:42 AM, cristisor wrote: > Hello, > > We are using an ActiveMQ 5.5.1.fuse-70-097 broker deployed inside > ServiceMix > 3.6.0-fuse-00-89 to send large files from

Re: How to configure channel/selector thread pools for NIOTransport?

I don't see a nice way to do it through configs, but there is a singleton object of type org.apache.activemq.transport.nio.SelectorManager that has channelExecutor and selectorExecutor respectively. If you happen to be using an embedded broker, you can set this in Java code. On Wed, Sep 4, 2013

Re: NIO transport performance for ActiveMQ

Yes, using the NIO transport vs regular blocking TCP will reduce the number of threads required per connection over large numbers of connections. I don't think you'll see much benefit with just one or two connections. If you have a case where you have lots of connections, and you don't see a diffe

Re: About JMX counters

Inline On Wed, Sep 4, 2013 at 6:13 AM, Jose María Zaragoza wrote: > Hi: > > I'm using ActiveMQ 5.8 and I'm having a look to JMX counters > I only use topics as destination > > I've got a questions: > > 1) > > ExpiredCount is always 0, in spite of I send all the messages with > TTL flag ( 15

Re: Maximum size of DLQ

Well, by default the DLQ is ActiveMQ.DLQ so you would have to set a destination policy. http://activemq.apache.org/per-destination-policies.html If you change the name of the DLQ using different DLQ strategies, you just need to use the respective name in your destination policy. For example:

Re: Model thread question

Double checked the source... so here's the deal.. if you use dedicatedTaskRunner==true or -Dorg.apache.activemq.UseDedicatedTaskRunner=true, then you'll end up with an executor at that session level with only one thread. Otherwise, the PDF docs are correct, you end up using a PooledTaskRunner

Re: Model thread question

Thanks. So , PDF is wrong , right ? what about pool of thread , i.e, one per MessageConsumer ? is it false ? does internal queues exists ? I'm confuse , sorry 2013/9/4 Christian Posta : > AFAIK...you have a logical thread for the transport that pulls data off the > socket, and then a thread fo

Re: AMQ 5.4 - 5.8 network broker

Check this thread: http://activemq.2283324.n4.nabble.com/5-7-doesn-t-consume-on-queue-tt4658025.html On Wed, Sep 4, 2013 at 8:17 AM, Johan Edstrom wrote: > I can confirm that you'll need that for propagation of destinations. > > On Sep 4, 2013, at 8:43 AM, Gary Tully wrote: > > > just a thoug

Re: Model thread question

AFAIK...you have a logical thread for the transport that pulls data off the socket, and then a thread for each session. So a single session can have multiple consumers, but a single session thread would dispatch to the consumers. On Wed, Sep 4, 2013 at 11:17 AM, Jose María Zaragoza wrote: > Hell

Re: active-mq 5.5 to active-mq 5.8 upgrade issue

I've answered you on the Camel list.. On Wed, Sep 4, 2013 at 10:42 AM, prabumc...@gmail.com wrote: > Camel i having code like this > > from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new > MemosProcess(getContext().createProducerTemplate())) > .end(); > > above code worked fine in

Model thread question

Hello: I'm using Apache ActiveMQ 5.8 and I've got a question about thread model on consumer side I don't know either there is a thread pool per MessageConsumer or there is a only one thread About this link http://activemq.apache.org/multiple-consumers-on-a-queue.html "The JMS contract is that

Re: active-mq 5.5 to active-mq 5.8 upgrade issue

Camel i having code like this from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new MemosProcess(getContext().createProducerTemplate())) .end(); above code worked fine in active 5.5 but after upgrade into active 5.8 it not working Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPEC

Re: AMQ 5.4 - 5.8 network broker

just a thought, I recall an issue with the destination filter, can't recall the exact detail but it may help for the server 5.8 case. mod the clients networkConnector to add: wrote: > Thank you christian. > > Unfortunately, i have at least 100 client and upgrade all together require > too much ti

Re: Usage Manager Memory Limit (10737418240) reached on queue

take a look here to understand memory usage a little better http://activemq.apache.org/javalangoutofmemory.html http://activemq.apache.org/producer-flow-control.html http://www.christianposta.com/blog/?p=273 On Wed, Sep 4, 2013 at 3:02 AM, ranjithjce wrote: > Hi > I am new to ActiveMQ.I am usi

Re: AMQ 5.4 - 5.8 network broker

I can confirm that you'll need that for propagation of destinations. On Sep 4, 2013, at 8:43 AM, Gary Tully wrote: > just a thought, I recall an issue with the destination filter, can't > recall the exact detail but it may help for the server 5.8 case. > mod the clients networkConnector to add:

Re: Bug fixes for 5.8

Hi The bug fix is in the 5.9 release which is being closed down, and to be released in not so far future. The guys is working on making sure the OSGi stuff works, and the unit tests passes and some other stuff etc. But the AMQ team would like to see 5.9 stable release out sooner than later. For 5

Re: wireFormat.maxInactivityDuration doesn't work

On 09/03/2013 09:49 PM, kylexy wrote: Hello, I'm using Apache NMS Stomp to connect to an ActiveMQ 5.8 server. I tried to use the heartbeat functionality by specifying wireFormat.maxInactivityDuration. The connection URL looks like "stomp:failover:(tcp://?wireFormat.maxInactivityDuration=1000

wireFormat.maxInactivityDuration doesn't work

Hello, I'm using Apache NMS Stomp to connect to an ActiveMQ 5.8 server. I tried to use the heartbeat functionality by specifying wireFormat.maxInactivityDuration. The connection URL looks like "stomp:failover:(tcp://?wireFormat.maxInactivityDuration=1)". However, the server can't be connec

Usage Manager Memory Limit (10737418240) reached on queue

Hi I am new to ActiveMQ.I am using ActiveMQ 5.6.0 version.In my project in mule ESB we are splitting 4gb file to 10 batches and loaded to Queue,here with send my activemq.xml conf.am getting Usage Manager Memory Limit (10737418240) reached on queue,how to process large volume of batches. any he

Bug fixes for 5.8

Hi, I'm investigating possibility of upgrade to 5.8 version of ActiveMq and have ran into this issue: https://issues.apache.org/jira/browse/AMQ-4595 This is quite a show stopper. Since it is already fixed, I want to ask: Do you plan on some fix release containing this fix? Or when is the 5.9 sch

Re: Maximum size of DLQ

Thanks for answer! How can I set memory limit on DLQ? And will this memory limit also affect persistent messages? We are routing only persistent messages. Thanks Matous -- View this message in context: http://activemq.2283324.n4.nabble.com/Maximum-size-of-DLQ-tp4671133p4671158.html Sent from

Re: active-mq 5.5 to active-mq 5.8 upgrade issue

Yes i am using camel. Before it worked fine,only issue after ugrade Regards Prabu.N On Wed, Sep 4, 2013 at 6:59 PM, ceposta [via ActiveMQ] < ml-node+s2283324n4671153...@n4.nabble.com> wrote: > how are you doing your routing? camel? > > > On Tue, Sep 3, 2013 at 10:44 PM, [hidden > email]

About JMX counters

Hi: I'm using ActiveMQ 5.8 and I'm having a look to JMX counters I only use topics as destination I've got a questions: 1) ExpiredCount is always 0, in spite of I send all the messages with TTL flag ( 15000 ms a.k.a 15 s) MessageProducer producer = session.createProducer(destination); produce

Re: Maximum size of DLQ

AFAIK you cannot set a max limit (in terms of numbers of messages although I thought I saw a JIRA on that at some point)...you can set mem limits + TTL on normal queues... on DLQ might have to just rely on mem limits. On Wed, Sep 4, 2013 at 1:51 AM, matousvoldrich wrote: > Hi all, > > I wou

Re: active-mq 5.5 to active-mq 5.8 upgrade issue

how are you doing your routing? camel? On Tue, Sep 3, 2013 at 10:44 PM, prabumc...@gmail.com wrote: > More than one produce running in same machine deployed in jboss .So it > created issue > > I have given unique name to the each producer above issue solved > > But i am getting new warning messa

Producer connections keep breaking

Hi, We've been experiencing some trouble with producer connections being broken and not recovering appropriately. Or that's what we've gathered... We're using a PooledConnectionFactory with 100 max connections, where there are 15 producers. The rest of the parameters are kept the default in the f

Re: NIO transport performance for ActiveMQ

Exactly !! Throughput is not the major concern but NIO is supposed to decrease no. of threads because it is the main functionality of NIO. Can someone from ActiveMQ team help me with this. Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/NIO-transport-perfor

How to configure channel/selector thread pools for NIOTransport?

Hi, Using activemq 5.6.0, and wonder how I can configure the custom thread pools for channel workers. For example, I'd like to assign only 100 threads for channel event processing and with 5 selector threads. How can I configure these? Thanks, Jake -- View this message in context: http://ac

Re: Apollo 1.6 + Perl client errors where ActiveMQ didn't

Jens Kristian Søgaard writes: > Upgrading to the latest snapshot did the trick. Good. Glad this is not a bug in my Net::STOMP::Client. > I'm not that comfortable running a daily snapshot in > production. Should I be when it comes to Apollo? > > Or is it recommended to stick with ActiveMQ for now

Re: Apollo 1.6 + Perl client errors where ActiveMQ didn't

Hi Lionel, Net::STOMP::Client should work fine with Apollo. However, Apollo 1.6 has several bugs and I would recommend trying its latest snapshot. Upgrading to the latest snapshot did the trick. The problem disappeared - both for Net::Stomp and Net::STOMP::Client. I have been running the sna

Maximum size of DLQ

Hi all, I would like to set a maximum size of DLQ queue. Or ideally to set up multiple persistent stores, one for DQL and second for normal messages. Is this possible with ActiveMq (version 5.8)? This way if DLQ is filled it will not block normal message delivery. Thanks for answer Matous --

Socket write error when uploading BlobMessage

Hello, We are using an ActiveMQ 5.5.1.fuse-70-097 broker deployed inside ServiceMix 3.6.0-fuse-00-89 to send large files from one endpoint to another. The FTP upload URL is on the same server where the broker is and there shouldn't be any kind of problems related to disk space, permissions, etc. T

Re: NIO transport performance for ActiveMQ

Hey, I am seeing the throughput drop using NIO. With 1 producer and 1 consumer in non-persistence mode using queues I got 47K msgs/sec using NIO while 53K msgs/sec using TCP. My major concern is number of threads, there is no decrement in number of threads. At least NIO supposed to reduce threads