Hi Konstantin,

can you open an Jira issue for this (ideally with the test case)?

Cheers
--
Dejan Bosanac - http://twitter.com/dejanb

Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net



On Wed, Jul 14, 2010 at 5:38 PM, Konstantin Fomin <k.fo...@gmail.com> wrote:
> Hi, Dejan,
>
> With the freshly started ActiveMQ there is no DLQ queue in the web interface.
>
> When mails are sent with consumer configured to give negative response
> with 10% probability the rejected messages are populating newly
> created DLQ. Disk usage is growing.
>
> Then ActiveMQ stops accepting new messages from producer forever.
> Manual purging of DLQ resolves the issue without restart.
>
> PS: I'm using activemq 5.3.2
>
> On Wed, Jul 14, 2010 at 5:23 PM, Dejan Bosanac <de...@nighttale.net> wrote:
>> Hi,
>>
>> do you actually see any messages being sent to DLQ or is it just created?
>>
>> Cheers
>> --
>> Dejan Bosanac - http://twitter.com/dejanb
>>
>> Open Source Integration - http://fusesource.com/
>> ActiveMQ in Action - http://www.manning.com/snyder/
>> Blog - http://www.nighttale.net
>>
>>
>>
>> On Tue, Jul 13, 2010 at 1:44 PM, Konstantin Fomin <k.fo...@gmail.com> wrote:
>>> Hello, Dejan,
>>>
>>> Thanks a lot for the reply.
>>> Could you, please, verify if the this configuration is OK for disabling DLQ?
>>> Unfortunately, when I use it, ActiveMQ.DLQ gets created:
>>>
>>>
>>>
>>>  $ cat activemq.xml
>>>
>>> <beans
>>>  xmlns="http://www.springframework.org/schema/beans";
>>>  xmlns:amq="http://activemq.apache.org/schema/core";
>>>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
>>>  xsi:schemaLocation="http://www.springframework.org/schema/beans
>>> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>>>  http://activemq.apache.org/schema/core
>>> http://activemq.apache.org/schema/core/activemq-core.xsd";>
>>>
>>>
>>>    <bean 
>>> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>>>        <property name="locations">
>>>            <value>file:${activemq.base}/conf/credentials.properties</value>
>>>        </property>
>>>    </bean>
>>>
>>>    <broker xmlns="http://activemq.apache.org/schema/core";
>>> brokerName="localhost" dataDirectory="${activemq.base}/data"
>>> destroyApplicationContextOnStop="true">
>>>
>>>        <destinations>
>>>            <queue physicalName="TESTING.EMAIL"/>
>>>        </destinations>
>>>
>>>        <destinationPolicy>
>>>            <policyMap>
>>>              <policyEntries>
>>>
>>>
>>>               <policyEntry queue=">">
>>>                <deadLetterStrategy>
>>>                  <sharedDeadLetterStrategy processExpired="false" />
>>>                </deadLetterStrategy>
>>>               </policyEntry>
>>>
>>>
>>>                <policyEntry topic=">" producerFlowControl="true"
>>> memoryLimit="5mb">
>>>                  <pendingSubscriberPolicy>
>>>                    <vmCursor />
>>>                  </pendingSubscriberPolicy>
>>>                </policyEntry>
>>>
>>>                <policyEntry queue=">" producerFlowControl="true"
>>> memoryLimit="1mb">
>>>                </policyEntry>
>>>
>>>              </policyEntries>
>>>            </policyMap>
>>>        </destinationPolicy>
>>>
>>>
>>>        <managementContext>
>>>            <managementContext createConnector="false"/>
>>>        </managementContext>
>>>
>>>        <persistenceAdapter>
>>>            <amqPersistenceAdapter syncOnWrite="false"
>>> directory="${activemq.base}/data" maxFileLength="20 mb"/>
>>>        </persistenceAdapter>
>>>
>>>        <systemUsage>
>>>            <systemUsage>
>>>                <memoryUsage>
>>>                    <memoryUsage limit="20 mb"/>
>>>                </memoryUsage>
>>>                <storeUsage>
>>>                    <storeUsage limit="500 mb"/>
>>>                </storeUsage>
>>>                <tempUsage>
>>>                    <tempUsage limit="100 mb"/>
>>>                </tempUsage>
>>>            </systemUsage>
>>>        </systemUsage>
>>>
>>>        <transportConnectors>
>>>            <transportConnector name="openwire" uri="tcp://localhost:60000"/>
>>>        </transportConnectors>
>>>
>>>    </broker>
>>>
>>>    <import resource="jetty.xml"/>
>>>
>>> </beans>
>>>
>>>
>>>
>>>
>>> On Tue, Jul 13, 2010 at 8:41 AM, Dejan Bosanac <de...@nighttale.net> wrote:
>>>> Hi,
>>>>
>>>>         <deadLetterStrategy>
>>>>           <sharedDeadLetterStrategy processExpired="false" />
>>>>         </deadLetterStrategy>
>>>>
>>>> should do the trick. Can you test it and create a test case if it doesn't?
>>>>
>>>> Cheers
>>>> --
>>>> Dejan Bosanac - http://twitter.com/dejanb
>>>>
>>>> Open Source Integration - http://fusesource.com/
>>>> ActiveMQ in Action - http://www.manning.com/snyder/
>>>> Blog - http://www.nighttale.net
>>>>
>>>>
>>>>
>>>> On Tue, Jul 13, 2010 at 12:21 AM, Konstantin Fomin <k.fo...@gmail.com> 
>>>> wrote:
>>>>> Hello, all,
>>>>>
>>>>> Can anyone share sample activemq.xml configuration with DLQ turned off?
>>>>>
>>>>> I've tried 
>>>>> http://activemq.apache.org/message-redelivery-and-dlq-handling.html
>>>>>  guides with no luck.
>>>>>
>>>>>
>>>>> --
>>>>> Sincerely yours,
>>>>> Konstantin.
>>>>>
>>>>
>>>
>>>
>>>
>>> --
>>> Sincerely yours,
>>> Konstantin.
>>>
>>
>
>
>
> --
> Sincerely yours,
> Konstantin.
>

Reply via email to