I am using auto_acknowledge.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-not-dequeue-using-Mule-tp4672315p4672435.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Thanks Garry for confirming about maxPageSize.
One more related question, there is memoryLimit attribute for queue policy
too, I am assuming this will supersede the maxPageSize attribute ? i.e. only
the number of messages < maxPageSize that in total size upto memoryLimit
will be loaded from the pe
Christian Posta wrote:
>
> Using the default protocol (Openwire) for Java.
> Use STOMP for your PHP needs.
>
> Apollo has had some good community use. It's not a feature-complete
drop-in
> replacement for ActiveMQ 5.x yet, but should be suitable for the needs you
> describe above.
>
> Apollo also s
That can be implemented as an external pub sub system using temporary queue
advisories and keeping the messages outside Amq until drain time.
Give each consumer a uuid, that uuid is also used as "temp queue name", when a
consumer is attaching, start sending.
Acking can be done back on a normal q
Mr. Bish:
I've read your comments about my jira issue and thanks for resolving
that. However, I found myself in bigger trouble now:
What I want to achieve in the first place is as follow:
1. A producer program will monitor a database . When that database is
updated , the producer will gene
Good point. I don't endorse it, but if there are use cases that require,
you can implement it w/ Advisory messages which would let you know whether
there is a consumer. Could also do w/ JMX mbean lookups, but advisory
messages would probably be best.
On Tue, Oct 8, 2013 at 2:08 PM, Paul Gale wro
Simone's requirements do seem similar to what's described in the
section entitled: "Complete Example: Producer that only Produces when
there is a Consumer" (speaking of which all the code examples are
missing) here:
http://activemq.apache.org/cms/handling-advisory-messages.html
Not endorsing it,
What type of ack mode are you using?
On Mon, Oct 7, 2013 at 2:51 AM, Neha wrote:
> Hi,
>
> I have made a simple application in mule that prints "Hello
> ". Before applying the 'set payload' component of Mule I
> have added the JMS Component to put all the requests in the activemq queue
> first,
Thx. I am there ;-)
Em 08/10/2013 17:48, "Christian Posta" escreveu:
> May want to ask this on the TomEE mailing list. I would think there would
> be some JMX mbeans that can be used to start/stop a EJB/MDB
>
>
> On Tue, Oct 8, 2013 at 9:49 AM, Leonardo K. Shikida >wrote:
>
> > Hi
> >
> > Is the
May want to ask this on the TomEE mailing list. I would think there would
be some JMX mbeans that can be used to start/stop a EJB/MDB
On Tue, Oct 8, 2013 at 9:49 AM, Leonardo K. Shikida wrote:
> Hi
>
> Is there any way to disable/enable a MDB programmatically?
>
> Right now, it consumes from a J
On 08 Oct 2013, at 6:51 PM, Graham Leggett wrote:
> I am using qpid v0.26-SNAPSHOT (AKA trunk) to work around another qpid bug.
>
> Is it possible to set the prefetch policy on the activemq server, or is this
> only possible on the client side?
Trying the following URL shows some even more str
Like Christian stated it doesn't make a whole lot of sense.
You don't need a plugin to reject either, use exclusive consumers.
On Oct 8, 2013, at 1:28 PM, Christian Posta wrote:
> Well, the whole point of queueing messages is to be able to asynchronously
> deliver messages so that consumers don'
Well, the whole point of queueing messages is to be able to asynchronously
deliver messages so that consumers don't have to be aware of producers and
vice versa. That is, if there are no consumers, the producers should still
be able to work. Maybe you can describe the problem you're trying to solve
Is this for temporary destinations that have gone away?
Can you give more info about what is failing or what you're seeing in the
logs?
On Mon, Oct 7, 2013 at 8:50 PM, javaG wrote:
> I am facing the issue of activemq throwing exception when a message sent is
> after some inactivity:
>
> Setup
By default, consumers drive demand for the demand forwarding bridge
(network connectors).
Gary has written a little about the terms:
http://blog.garytully.com/2012/07/activemq-broker-networks-think-demand.html
So if you have consumers popping up, you can expect messages to flow toward
those cons
Using the default protocol (Openwire) for Java.
Use STOMP for your PHP needs.
Apollo has had some good community use. It's not a feature-complete drop-in
replacement for ActiveMQ 5.x yet, but should be suitable for the needs you
describe above.
Apollo also supports Openwire and STOMP protocols.
You might be able to put together a broker filter/plugin that shuts down
the broker if the store becomes full. That might not be a good idea,
however.. what happens with messages that are already stored on the first
broker?
Maybe you can set an exceptionListener on the connection and for
ResourceA
Yah, your best bet is to try to reproduce this in a junit test so we can
take a closer look.
Can take a look at these tests if you need help:
https://github.com/apache/activemq/blob/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/JmsQueueRequestReplyTest.java
https://github.com/apach
I'm using ActiveMq in a request/response configuration.
I was wondering if it is possible to reject Producer message if no Consumer
is available.
I did search the forum, googled very much, but found nothing close to my
scenario.
My implementation is about a RPC mechanism. So if the requestor (Pro
On 08 Oct 2013, at 5:48 PM, mrich wrote:
> You are using ActiveMQ with AMPQ (1.0). Which client library are you using
> for this?
>
> I recently ran into an issue with the Qpid 1.0 client as it doesnt appear to
> handle the same URL parameters as earlier versions of the client (e.g. amqp
> 0.10)
Hi
Is there any way to disable/enable a MDB programmatically?
Right now, it consumes from a JMS queue and the queue definitions are coded
using @ActivationConfigProperty. if I just set a flag in the database and
let the MDB check it before executing the onMessage() message, I guess I'd
have to re
Hi,
You are using ActiveMQ with AMPQ (1.0). Which client library are you using
for this?
I recently ran into an issue with the Qpid 1.0 client as it doesnt appear to
handle the same URL parameters as earlier versions of the client (e.g. amqp
0.10). Just something to check if you are using Qpid li
Hi all,
I am having a further problem that has me stumped.
I have 8 nodes, each node makes a short lived connection to poll a central
activemq server in the expectation of picking up exactly one message for
processing, processing may take many seconds to minutes. The activemq server
has a queu
On 08 Oct 2013, at 4:22 PM, Gary Tully wrote:
> yes this is possible and should be the norm.
>
> What version are you using and what persistence adapter?
currently v5.8.0 using levelDB.
We discovered that kahadb has a memory leak in it:
https://issues.apache.org/jira/browse/AMQ-4789
> How ar
yes this is possible and should be the norm.
What version are you using and what persistence adapter?
How are messages acknowledged?
seems like you may be using optimizeAcknowledge mode?
some pointers:
use kahadb - concurrentStoreAndDispatchQueues=false - dispatch after
persistence, enableJourna
Hi all,
We have a system that does heavy message processing where we have very few
(tens, hundreds) of messages that take minutes to process each.
What we also have is periodic activemq v5.8.0 instability that causes the "java
service wrapper" to proactively send a "kill -9" signal to the activ
each broker requires exclusive access to the DB. So the broker is the
shared entry point.
In each of your servers have just client side jms, producers and
consumers and have a single or replicated broker topology that is
shared by all servers.
If you want some level of isolation for your servers
Thanks for the response.
I haven't yet checked the logs, but I have found the cause of the problem.
When increasing the overall heap of the vm, the producer is allowed to
publish all messages. I would have expected to get an OutOfMemoryException
if the producer tries to write to the queue when t
Hi,
I am also trying to use http transport, and I also like to know about http
transport more, I have searched on internet but didn't get much, If someone
from ActiveMQ dev team will help me.
In addition to above questions i want to ask:
-- Can ActiveMQ http transport be used for java web applicat
29 matches
Mail list logo
