Any time, Claus.
On Tue, May 28, 2013 at 10:38 AM, Claus Ibsen wrote:
> Hi
>
> Thanks for sharing your solution.
>
> On Tue, May 28, 2013 at 9:30 AM, Okello Nelson
> wrote:
> > My Solution:
> > ==
> >
> > Guys, I managed to sort out my issue in the following manner:
> >
> > I had to co
Hi
Thanks for sharing your solution.
On Tue, May 28, 2013 at 9:30 AM, Okello Nelson wrote:
> My Solution:
> ==
>
> Guys, I managed to sort out my issue in the following manner:
>
> I had to copy my app jar into the ActiveMQ's lib directory. This was so
> that ActiveMQ can have access to
My Solution:
==
Guys, I managed to sort out my issue in the following manner:
I had to copy my app jar into the ActiveMQ's lib directory. This was so
that ActiveMQ can have access to my data transfer objects.
Next, I had to create a custom Aggregator (look at my previous post). In my
cus
Hi Guys,
I've been trying to sort this issue. I've created a custom aggregation
strategy instead of relying on the inbuilt "groupExchanges()". My
aggregation strategy is shown below:
@Service( value = "keAggregationStrategy" )
public class KEAggregationStrategy implements IKEAggregationStrategy {
Hi Guys,
I have the following Java DSL:
from(queuePrefix + fileType + "_ValidQ?concurrentConsumers=100")
.routeId(fileType + "_ValidQ-To-DB")
.onException(Exception.class).redeliveryPolicyRef("redeliverypolicy")
.to(queuePrefix + fileType + "_DBLoading_ErrorQ").end()
.aggregate(header("CRBOrigina
