You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Charles Moulliard <ch...@gmail.com> on 2013/07/10 21:19:18 UTC
Fwd: How to configure redeliveryPlugin of ActiveMQ using Spring
Hi,
Here is the java code to be used to configure redeliveryPlugin
broker = new BrokerService();
broker.setSchedulerSupport(true);
RedeliveryPlugin redeliveryPlugin = new RedeliveryPlugin();
RedeliveryPolicy brokerRedeliveryPolicy = new RedeliveryPolicy();
brokerRedeliveryPolicy.setRedeliveryDelay(redeliveryDelayMillis);
brokerRedeliveryPolicy.setInitialRedeliveryDelay(redeliveryDelayMillis);
brokerRedeliveryPolicy.setMaximumRedeliveries(maxBrokerRedeliveries);
RedeliveryPolicyMap redeliveryPolicyMap = new RedeliveryPolicyMap();
redeliveryPolicyMap.setDefaultEntry(brokerRedeliveryPolicy);
redeliveryPlugin.setRedeliveryPolicyMap(redeliveryPolicyMap);
broker.setPlugins(new BrokerPlugin[]{redeliveryPlugin});
but when I try to configure it within a spring xml file, this syntax is not
accepted
<broker xmlns="http://activemq.apache.org/schema/core"
brokerName="spb-local"
dataDirectory="activemq-spb"
persistent="true">
<persistenceAdapter>
<kahaDB directory="activemq-spb/kahadb"/>
</persistenceAdapter>
<plugins>
<redeliveryPlugin sendToDlqIfMaxRetriesExceeded="true"
redeliveryPolicyMap="">
<redeliveryPolicyMap>
<redeliveryPolicy maximumRedeliveries="4"/>
</redeliveryPolicyMap>
</redeliveryPlugin>
</plugins>`
As I haven't been able to find an example in code of activemq, what should
be the syntax to be used ?
Regards,
--
Charles Moulliard
Apache Committer / Architect @RedHat
Twitter : @cmoulliard | Blog : http://cmoulliard.blogspot.com
--
Charles Moulliard
Apache Committer / Architect @RedHat
Twitter : @cmoulliard | Blog : http://cmoulliard.blogspot.com
Re: How to configure redeliveryPlugin of ActiveMQ using Spring
Posted by Christian Posta <ch...@gmail.com>.
Charles,
try this:
<plugins>
<redeliveryPlugin sendToDlqIfMaxRetriesExceeded="true">
<redeliveryPolicyMap>
<redeliveryPolicyMap>
<defaultEntry>
<redeliveryPolicy maximumRedeliveries="4"/>
</defaultEntry>
</redeliveryPolicyMap>
</redeliveryPolicyMap>
</redeliveryPlugin>
</plugins>
can use <*redeliveryPolicyEntries>* instead of default, or beside default
as well.
Cheers
On Wed, Jul 10, 2013 at 3:19 PM, Charles Moulliard <ch...@gmail.com> wrote:
> Hi,
>
> Here is the java code to be used to configure redeliveryPlugin
>
> broker = new BrokerService();
> broker.setSchedulerSupport(true);
>
>
> RedeliveryPlugin redeliveryPlugin = new RedeliveryPlugin();
>
> RedeliveryPolicy brokerRedeliveryPolicy = new RedeliveryPolicy();
> brokerRedeliveryPolicy.setRedeliveryDelay(redeliveryDelayMillis);
>
> brokerRedeliveryPolicy.setInitialRedeliveryDelay(redeliveryDelayMillis);
>
> brokerRedeliveryPolicy.setMaximumRedeliveries(maxBrokerRedeliveries);
>
> RedeliveryPolicyMap redeliveryPolicyMap = new
> RedeliveryPolicyMap();
> redeliveryPolicyMap.setDefaultEntry(brokerRedeliveryPolicy);
> redeliveryPlugin.setRedeliveryPolicyMap(redeliveryPolicyMap);
>
> broker.setPlugins(new BrokerPlugin[]{redeliveryPlugin});
>
> but when I try to configure it within a spring xml file, this syntax is not
> accepted
>
> <broker xmlns="http://activemq.apache.org/schema/core"
> brokerName="spb-local"
> dataDirectory="activemq-spb"
> persistent="true">
>
> <persistenceAdapter>
> <kahaDB directory="activemq-spb/kahadb"/>
> </persistenceAdapter>
>
> <plugins>
> <redeliveryPlugin sendToDlqIfMaxRetriesExceeded="true"
> redeliveryPolicyMap="">
> <redeliveryPolicyMap>
> <redeliveryPolicy maximumRedeliveries="4"/>
> </redeliveryPolicyMap>
> </redeliveryPlugin>
> </plugins>`
>
> As I haven't been able to find an example in code of activemq, what should
> be the syntax to be used ?
>
> Regards,
>
> --
> Charles Moulliard
> Apache Committer / Architect @RedHat
> Twitter : @cmoulliard | Blog : http://cmoulliard.blogspot.com
>
>
>
>
> --
> Charles Moulliard
> Apache Committer / Architect @RedHat
> Twitter : @cmoulliard | Blog : http://cmoulliard.blogspot.com
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta