Hi,
you should use JmsTemplate to send messages only. Have a look at
http://activemq.apache.org/jmstemplate-gotchas.html. You should use
Spring's DefaultMessageListenerContainer to receive messages. We are
using this, it works well.
Best regards,
Martin
On Wed, Oct 5, 2011 at 3:47 PM, James Blac
Hi
You could disable asyncSend on the client connection
http://activemq.apache.org/async-sends.html
On Wed, Oct 5, 2011 at 9:36 PM, manua wrote:
> Hi,
>
> I am using a perl consumer and for the message, building my own frame, as,
>
> my %head;
> $head{destination} = "/queue/Test.Request.Q";
>
Hi all,
I'm using ActiveMQ 5.4.0, in a network of broker configuration, with duplex
connections to send notifications in a server / clients architecture. I was
looking through the logs for an issue I had on site, and I noticed a lot of
warnings and errors related to connection between the members o
I've set up three AMQs in a "Shared Directory Master/Slave" configuration, on
Windows.
All three are running.
I can connect to admin page for all three.
I looked in the logs, but it is not clear to me how I can tell which is the
Master and which are the slaves.
How do I tell, at any given time,
yes, the size of the thread pool is unbounded, if this is the
right source I'm looking at:
http://activemq.apache.org/maven/5.2.0/activemq-core/apidocs/srchtml/org/apache/activemq/thread/TaskRunnerFactory.html
In fact I was hoping to somehow replace that TaskRunnerFactory.
I'll try to create a co
Can someone please help ?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/JMS137-PayloadFactory-not-set-tp3874663p3876065.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi,
I am using a perl consumer and for the message, building my own frame, as,
my %head;
$head{destination} = "/queue/Test.Request.Q";
$request{message} = "Test Message";
$request{sequence_no} = 1;
my $frame= Net::Stomp::Frame->new(
{ command => "SEND", headers => \%head, body => to_js
just to add to the previous post, if the message processing takes time, it
works fine.But if the message processing is fast, it misses some messages in
between.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Activemq-Perl-consumer-miss-messages-from-the-queu-tp3875608p3875
HI,
I have the setup where my consumer receives a message, unsubscribe from the
queue, process the message and starts another instance of the same
consumer.In this process, I am losing some message in between.
Is it due to the prefetch size, When the prefetch size was more, it was
loosing more me
Hello,
we have an issue with our Spring application consuming from queues in
ActiveMQ.
Versions:
Spring 3.0.5
ActiveMQ 5.5.0
All messages are persistent.
We have a need to throttle the rate at which messages are consumed from 1
part of our application therefore we use the jmsTemplate to consume
What's the name of the threads being created continuously on your broker?
not using a dedicated task runner is a good idea, as it uses a thread pool
instead. However from what I know the size of that thread pool is basically
unbounded as well, and if all newly created threads are in use, the brok
Hello there,
I'm using an embedded BrokerService with a single destination,
which is a queue that hands off incoming messages to an SCA
logging service.
Internally, that logging service follows the producer-consumer pattern
with a single blocking queue, so the producer basically gets handed a
mes
I have a test program. Which posts two messages successively on a queue.
There is a listener on the queue which waits for 10 seconds after receiving
the first message.
Message are durable.
Steps
1)Program started.
2)Both the messages are posted to JMS provider and JMS provider sends the
first mess
13 matches
Mail list logo
