activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From janylj <jan...@gmail.com>
Subject Re: Cannot send any PERSISTENT message?
Date Mon, 20 Jul 2009 16:02:52 GMT

Thanks Gary. It totally makes sense. However, I am exactly using pooled
connection factory for producer and message listener container with a
regular connection factory for consumer. I am sorry that I didn't state
clearly in my previous thread. What might cause pending messages unable to
consume under this condition? Thanks again.


Gary Tully wrote:
> 
> consuming messages from a connection pool can be problematic due to
> prefetch[1]. Unconsumed prefetched messages are only returned when the
> connection is closed, but with a pooled connection the connection
> close is deferred (for reuse) till the pool closes. This leaves
> prefetched messages unconsumed till the connection is resued.
> The solution is to use pooled connections for producers and a non
> pooled connection for consumers or disable prefetch or reduce the pool
> to a single connection for consumers.
> 
> [1] http://activemq.apache.org/what-is-the-prefetch-limit-for.html
> 
> 2009/7/17 janylj <janylj@gmail.com>:
>>
>> Yes, I am sure that I am using pooled connection factory. And the enqueue
>> and
>> dequeue counts changes. But the pending messages cannot be consumed.
>>
>> Please note that the problem happens a couple of days or weeks after the
>> initial deployment. And it went away when we restart the broker.
>>
>> Thanks a lot.
>>
>>
>> Dejan Bosanac wrote:
>>>
>>> Hi,
>>>
>>> are you sure you're using pooled connection factory, since that could
>>> cause
>>> some problems.
>>>
>>> http://activemq.apache.org/jmstemplate-gotchas.html
>>>
>>> You said that you don't see the message in the console, but that message
>>> count is incremented. This can happen if your queue is larger than 400
>>> messages, since that much is usually browsed. Does enqueue and dequeue
>>> counts change as well?
>>>
>>> Cheers
>>> --
>>> Dejan Bosanac
>>>
>>> Open Source Integration - http://fusesource.com/
>>> ActiveMQ in Action - http://www.manning.com/snyder/
>>> Blog - http://www.nighttale.net
>>>
>>>
>>> On Thu, Jul 9, 2009 at 5:52 PM, janylj <janylj@gmail.com> wrote:
>>>
>>>>
>>>> Sure. I am using ActiveMQ 5.2. I didn't change anything in the
>>>> activemq.xml.
>>>>
>>>> The producer is using Spring JmsTemplate:
>>>>
>>>> template.send(dest, new MessageCreator() {
>>>> public Message createMessage(Session session) throws JMSException {
>>>> return session.createTextMessage(dest.toString() + "'s Message #" +
>>>> cnt);
>>>> }
>>>> });
>>>>
>>>> Please note that after restarting ActiveMQ, all previously
>>>> un-accessible
>>>> persistent messages are redelivered and consumed just fine! So I don't
>>>> think
>>>> it's a persistent journal problem. But somehow ActiveMQ internal state
>>>> is
>>>> corrupted.
>>>>
>>>> Also the problem does not happen immediately. It usually happens after
>>>> having the broker running for a couple of weeks.
>>>>
>>>> Thanks a lot.
>>>>
>>>>
>>>> Dejan Bosanac wrote:
>>>> >
>>>> > Hi,
>>>> >
>>>> > any chance you can send some more details on your setup and a code
>>>> sample?
>>>> >
>>>> > Cheers
>>>> > --
>>>> > Dejan Bosanac
>>>> >
>>>> > Open Source Integration - http://fusesource.com/
>>>> > ActiveMQ in Action - http://www.manning.com/snyder/
>>>> > Blog - http://www.nighttale.net
>>>> >
>>>> >
>>>> > On Wed, Jul 8, 2009 at 12:21 AM, janylj <janylj@gmail.com> wrote:
>>>> >
>>>> >>
>>>> >> I have a broker running ActiveMQ 5.2. After running for a couple
of
>>>> >> weeks,
>>>> >> all persistent messages would NOT be sent successfully. The symptom
>>>> is
>>>> >> that
>>>> >> the producer sends message ok (there is no hang or exception in
the
>>>> >> client
>>>> >> side). And the message count in the ActiveMQ admin console is
>>>> >> incremented.
>>>> >> But the consumer doesn't see any message to consume. Also click
into
>>>> the
>>>> >> queue at the admin console doesn't have any pending message. We
know
>>>> the
>>>> >> consumer is working because all the non-persistent messages are
>>>> consumed
>>>> >> just fine. And there is no ERROR or WARN in the ActiveMQ log.
>>>> >>
>>>> >> After restarting the broker, the problem would go away. However,
>>>> this
>>>> >> issue
>>>> >> has occurred for a couple of times.
>>>> >>
>>>> >> Any idea why this happens?
>>>> >>
>>>> >> Thanks a lot.
>>>> >> --
>>>> >> View this message in context:
>>>> >>
>>>> http://www.nabble.com/Cannot-send-any-PERSISTENT-message--tp24382410p24382410.html
>>>> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>> >>
>>>> >>
>>>> >
>>>> >
>>>> > -----
>>>> > Dejan Bosanac
>>>> >
>>>> > Open Source Integration - http://fusesource.com/
>>>> > ActiveMQ in Action - http://www.manning.com/snyder/
>>>> > Blog - http://www.nighttale.net
>>>> >
>>>>
>>>> --
>>>> View this message in context:
>>>> http://www.nabble.com/Cannot-send-any-PERSISTENT-message--tp24382410p24412663.html
>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>
>>>>
>>>
>>>
>>> -----
>>> Dejan Bosanac
>>>
>>> Open Source Integration - http://fusesource.com/
>>> ActiveMQ in Action - http://www.manning.com/snyder/
>>> Blog - http://www.nighttale.net
>>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Cannot-send-any-PERSISTENT-message--tp24382410p24541430.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
> 
> 
> 
> -- 
> http://blog.garytully.com
> 
> Open Source Integration
> http://fusesource.com
> 
> 

-- 
View this message in context: http://www.nabble.com/Cannot-send-any-PERSISTENT-message--tp24382410p24572570.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message