with this possibility to solve this
scenario.
best regards
Maximilian
Von:"Justin Bertram"
An: dev@activemq.apache.org
Datum: 06/11/2024 10:37 PM
Betreff:[Ext] Re: Re: Re: PrefixAddressTransformer for unique
event divert
Your use-case sounds exactly like what's
a prefix.
> I hope it is understandable what i mean.
>
> best regards
> Maximilian
>
>
>
> Von:"Justin Bertram"
> An:dev@activemq.apache.org
> Datum:06/07/2024 10:35 PM
> Betreff:[Ext] Re: Re: PrefixAddressTransformer for
o move the messages on
the topic also in a queue with a prefix.
I hope it is understandable what i mean.
best regards
Maximilian
Von:"Justin Bertram"
An: dev@activemq.apache.org
Datum: 06/07/2024 10:35 PM
Betreff: [Ext] Re: Re: PrefixAddressTransformer for unique even
> applications.
>
> Max
>
>
>
> Von:"Arthur Naseef"
> An:dev@activemq.apache.org
> Datum:06/06/2024 06:20 PM
> Betreff:[Ext] Re: PrefixAddressTransformer for unique event divert
> --
>
>
>
ActiveMQ, where we are using a virtualDestinationInterceptor to
redirect Event messages into a queue to be consumed by distributed
applications.
Max
Von:"Arthur Naseef"
An: dev@activemq.apache.org
Datum: 06/06/2024 06:20 PM
Betreff:[Ext] Re: PrefixAddressTransformer
If I read it correctly, the transformer together with the divert provides a
means to duplicate messages from any number of inbound destinations to a
parallel set of destinations by adding a prefix.
For example:
test.events.a.1 -> TestQ.test.events.a.1
test.events.b.2 -> TestQ.test.events.b.2
L
Generally speaking, _every_ commit which fixes a bug or adds a feature or
improvement should have a test. This ensures the bug is actually fixed or
the feature actually works and also mitigates regressions later.
Furthermore, if you want this to be something accessible to end-users then
documentat
Hello,
we are currently using a Transformer to redirect Event messages into a
queue to consume them as kind of Unique Processing by distributed
applications.
For this we use a transformer:
public class PrefixAddressTransformer implements Transformer
{
@Override
public Message transform(M
