You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Geoffrey Arnold <ge...@geoffreyarnold.com> on 2013/05/09 18:04:57 UTC
Changing message persistence on messages forwarded using composite queue?
Hello,
We have a composite queue defined as follows:
<amq:virtualDestinations>
<amq:compositeQueue name="DataQueue"
forwardOnly="false">
<amq:forwardTo>
<amq:queue physicalName="StatisticsQueue"/>
</amq:forwardTo>
</amq:compositeQueue>
...
</amq:virtualDestinations>
When producers send persistent messages to the `DataQueue`, those messages
are also forwarded to the `StatisticsQueue`. This is working perfectly.
What we would like to do now is apply transformations to the messages being
forwarded to the `StatisticsQueue`, specifically to make them
non-persistent and add a TTL. Is this possible via configuration?
Thanks in advance,
Geoff.
Re: Changing message persistence on messages forwarded using
composite queue?
Posted by Geoffrey Arnold <ge...@gmail.com>.
Awesome, thanks for the pointer Christian!
On Thu, May 9, 2013 at 3:34 PM, Christian Posta
<ch...@gmail.com>wrote:
> Using Camel (http://camel.apache.org/) would be easy... or if want to do
> completely within activemq, there is a plugin you could start with
> (ForcePersistencyModeBrokerPlugin) and add some more logic to apply to only
> certain destinations.
>
>
> On Thu, May 9, 2013 at 9:04 AM, Geoffrey Arnold <
> geoffrey@geoffreyarnold.com
> > wrote:
>
> > Hello,
> >
> > We have a composite queue defined as follows:
> >
> > <amq:virtualDestinations>
> > <amq:compositeQueue name="DataQueue"
> > forwardOnly="false">
> > <amq:forwardTo>
> > <amq:queue physicalName="StatisticsQueue"/>
> > </amq:forwardTo>
> > </amq:compositeQueue>
> > ...
> > </amq:virtualDestinations>
> >
> > When producers send persistent messages to the `DataQueue`, those
> messages
> > are also forwarded to the `StatisticsQueue`. This is working perfectly.
> >
> > What we would like to do now is apply transformations to the messages
> being
> > forwarded to the `StatisticsQueue`, specifically to make them
> > non-persistent and add a TTL. Is this possible via configuration?
> >
> > Thanks in advance,
> > Geoff.
> >
>
>
>
> --
> *Christian Posta*
> http://www.christianposta.com/blog
> twitter: @christianposta
>
Re: Changing message persistence on messages forwarded using
composite queue?
Posted by Christian Posta <ch...@gmail.com>.
Using Camel (http://camel.apache.org/) would be easy... or if want to do
completely within activemq, there is a plugin you could start with
(ForcePersistencyModeBrokerPlugin) and add some more logic to apply to only
certain destinations.
On Thu, May 9, 2013 at 9:04 AM, Geoffrey Arnold <geoffrey@geoffreyarnold.com
> wrote:
> Hello,
>
> We have a composite queue defined as follows:
>
> <amq:virtualDestinations>
> <amq:compositeQueue name="DataQueue"
> forwardOnly="false">
> <amq:forwardTo>
> <amq:queue physicalName="StatisticsQueue"/>
> </amq:forwardTo>
> </amq:compositeQueue>
> ...
> </amq:virtualDestinations>
>
> When producers send persistent messages to the `DataQueue`, those messages
> are also forwarded to the `StatisticsQueue`. This is working perfectly.
>
> What we would like to do now is apply transformations to the messages being
> forwarded to the `StatisticsQueue`, specifically to make them
> non-persistent and add a TTL. Is this possible via configuration?
>
> Thanks in advance,
> Geoff.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta