On Wed, Feb 24, 2010 at 2:31 PM, Josh Carlson wrote:
> Hi Gary,
>
> Thanks for the explanation. The order is:
>
> consumer retrieves message
>
> connection is lost and consumer re-establishes connection to new master
> broker
>
> consumer acks the message retrieved from the former broker
Hi Gary,
Thanks for the explanation. The order is:
consumer retrieves message
connection is lost and consumer re-establishes connection to new
master broker
consumer acks the message retrieved from the former broker
consumer retrieves the same message it just ack'ed.
I gues
On failover, redispatch of unacked messages will occur and this is
unordered. There is no guarantee that the same consumer will get the same
messages after failover of a connection.
On the java client there is a message audit that will suppress duplicates
that may occur, I think the same is true fo
When using a shared file system master/server activemq configuration and
client acknoledgements we run into a problem when
our clients fail over to a new server. The problem is that the new
server does not appear to have any knowledge of pending
messages that the old server had dispatched to clie
Hello,
I want to build a 'highly available' system and am now wandering why a
message is owned by a single broker in a "Store and Forward Network of
Brokers", as when a broker dies the messages it owns will be lost (until
broker restart when using persistence)? This seems a strange choice, why
ha
what version of the broker are you using?
On 24 February 2010 15:50, RuralHunter wrote:
>
> Looks there is similar issue raised already:
>
> http://old.nabble.com/Brigded-brokers-wont-reconnect-td27427208.html#a27427208
>
> My point is that, no matter what caused the connection between 2 brokers
Hi all,
I'm currently prototype the usage of activemq for spooling / queuing
in JAMES Mailserver. The delivery to the users mailboxes work out of
the JMSQueue. Anyway I get the following exception after the
successfully delivery:
org.apache.camel.NoSuchEndpointException: No endpoint could be foun
Yes. Enqueued - dequeued equals the queue size.
Maarten_D wrote:
>
> Aha. And enqueued - dequeued corresponds to what's in the queue?
>
>
> Elliot Barlas wrote:
>>
>> Okay, the issue I am seeing is slightly different then. In my case the
>> broker isn't even dispatching some messages, at
Aha. And enqueued - dequeued corresponds to what's in the queue?
Elliot Barlas wrote:
>
> Okay, the issue I am seeing is slightly different then. In my case the
> broker isn't even dispatching some messages, at least according to the
> broker stats. Dequeued = Dispatched and Dispatched < Enqu
Okay, the issue I am seeing is slightly different then. In my case the
broker isn't even dispatching some messages, at least according to the
broker stats. Dequeued = Dispatched and Dispatched < Enqueued.
Thanks,
Elliot
Maarten_D wrote:
>
> It appears that our problem had to do with prefetch
Looks there is similar issue raised already:
http://old.nabble.com/Brigded-brokers-wont-reconnect-td27427208.html#a27427208
My point is that, no matter what caused the connection between 2 brokers
broken, activemq should be able to re-establish the connection when things
get fixed/recovered. I do
Hi,
I created a network connector from my local activemq to a remote activemq
server with configuration below:
The problem is that sometime I got InactivityIOException and the connector
never gets recovered after that. The communication between 2 servers is
stopped until I recycle
It appears that our problem had to do with prefetching. We had our prefetch
values for queues set fairly high, and when I client application would
crash, a bunch of messages that were prefetched, but not ack'ed, would
remain stuck in the queue. We added "jms.prefetchPolicy.queuePrefetch=1" to
our
Dear all:
my use activemq -5.3.0 version.In the project ,my activemq.xml
config:
http://activemq.apache.org/schema/core";
brokerName="localhost" dataDirectory="${activemq.base}/data"
persistent="true">
-
2.my web.xml con
Also - the trick with camel is when things are not doing as you want,
turn on tracer...
http://camel.apache.org/tracer.html
On 24 February 2010 10:38, Gary Tully wrote:
> you may have more luck with a useful reply on the camel users forum.
> One thought, are you sure the header property is prese
you may have more luck with a useful reply on the camel users forum.
One thought, are you sure the header property is present?. Could it be
"in.header.JMSPriority" (with a capital 'P')? Possibly try using a property
that you explicitly set on the original message, just the be sure the naming
and re
On 24 February 2010 09:06, harrygoo wrote:
>
> hi, I am using activemq-4.0, sometimes my consumer cant receive any message
> from ActiveMQ. In the JConsole, I can see the connection is connected, the
> QueueSize is bigger than 0, and DequeueCount is bigger than EnqueueCount
> (this make me feel co
hi, I am using activemq-4.0, sometimes my consumer cant receive any message
from ActiveMQ. In the JConsole, I can see the connection is connected, the
QueueSize is bigger than 0, and DequeueCount is bigger than EnqueueCount
(this make me feel confused) . Then I close the connection of the consumer
Hi all,
I found the cause of getMessage() to return null. MimeMessage itself
is not Serializable :/ So I worked arount this problem by put the
whole MimeMessage into a byte[] array and now it work.
Anyway thats quite inefficent, so I'm currently investigating into
using a StreamMessage to store th
19 matches
Mail list logo
