from yours.
Can you give me some guide about TTL you mentioned in early reply?
Cristian Botiza wrote:
This is not AMQ specific; it's rather JMS API specific - the JavaDoc of
interface javax.jms.Message.
Did this approach work with P2P and multiple consumers
# (via the Apache.NMS.ActiveMQ):
http://remark.wordpress.com/articles/publish-subscribe-with-activemq-and-nms/
The author of this blog have a bunch of ActiveMQ related blog entries that
are worth reading.
Hope this helps you,
Seb
On 19 May 2010 16:22, Cristian Botiza cristian.bot...@endava.com wrote
Message selectors?
From: alanchb [alanchbm...@gmail.com]
Sent: 18 May 2010 11:12
To: users@activemq.apache.org
Subject: How to post message to a certain queue consumer?
under the P2P mode,if i have sevaral queue consumers,how to make the producer
post
queue consumer?
Thanks for your reply.
but how to use message selector to identify a consumer when producer send a
message?
Cristian Botiza wrote:
Message selectors?
From: alanchb [alanchbm...@gmail.com]
Sent: 18 May 2010 11:12
To: users
to learn about ActiveMQ?
Cristian Botiza wrote:
In the producer code, when creating the Message object:
message.setStringProperty(myFilterProperty, my consumerID);
In the consumer (QueueReceiver or Message Driven Bean), define the message
selector expression (SQL syntax) as myFilterPropert='my
Hi all,
By reading the JavaDoc I wasn't able to figure out exactly what
setJMSExpiration(long) does.
If I use a value of 6 for example (IN THE SENDER CODE) does that mean that
the message will be deleted from the store if not consumed in aproximately 1
minute? Is there any guarantee for
@activemq.apache.org
Subject: Re: Message expiration
yes, it is specified in milliseconds and with 5.3.1. for queues, the message
will be automatically expired, independent of consumer activity.
On 29 March 2010 11:21, Cristian Botiza cristian.bot...@endava.com wrote:
Hi all,
By reading the JavaDoc I
will be automatically expired, independent of consumer activity.
On 29 March 2010 11:21, Cristian Botiza cristian.bot...@endava.com wrote:
Hi all,
By reading the JavaDoc I wasn't able to figure out exactly what
setJMSExpiration(long) does.
If I use a value of 6 for example (IN THE SENDER
...@gmail.com]
Sent: 26 March 2010 20:26
To: users@activemq.apache.org
Subject: Re: Messages stuck in the queue
catching Throwable would be best. You wouldn't need to redeploy the JMS queue -
just restart the client should do
On 26 Mar 2010, at 16:40, Cristian Botiza wrote:
When you say 'you miss an ack
I notice this error (logged as debug) from time to time in the AMQ logs:
java.io.EOFException
at java.io.DataInputStream.readInt(Unknown Source)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
at
: java.io.EOFException
On Mon, Mar 29, 2010 at 3:54 PM, Cristian Botiza
cristian.bot...@endava.com wrote:
I notice this error (logged as debug) from time to time in the AMQ logs:
java.io.EOFException
at java.io.DataInputStream.readInt(Unknown Source
Hi all,
I'm using an activation spec where maxSessions=maxMessagesPerSessions=1.
Using a client application I'm sending a TextMessage to the queue
The MDB consumes some messages and then the messages start piling up in the
queue and never get dispatched.
I restarted the server, redeployed the
Forgot to mention, I also see this in the active mq logs:
2010-03-26 14:37:07,490 DEBUG [PrefetchSubscription] Prefetch limit.
So I assume the queue is 'full'?
From: Cristian Botiza [cristian.bot...@endava.com]
Sent: 26 March 2010 17:18
To: users
and maxMessagesPerSessions =100 may help. so that you get a prefetch of 100.
On 26 March 2010 15:18, Cristian Botiza cristian.bot...@endava.com wrote:
Hi all,
I'm using an activation spec where maxSessions=maxMessagesPerSessions=1.
Using a client application I'm sending a TextMessage to the queue
The MDB consumes
Can you chunk the file? In this case you might split it between multiple
producers and consumers
and play with the number of producers/consumers and chunck size. You may send
and process chuncks
concurrently and also limit the message size.
Just one option...
I would look for some streaming options in ActiveMQ if you want to send the
full file. But 100 MB is quite huge...anyway see class BytesMessage. You may
try using a BufferedStream around the byte array, or read it in chuncks using
readBytes(byte[]).
16 matches
Mail list logo
