activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mick Knutson" <mknut...@baselogic.com>
Subject Re: issue routing Exchange to custom method in Processor
Date Mon, 29 Sep 2008 16:12:27 GMT
Can someone help me?

On Fri, Sep 26, 2008 at 3:10 PM, Mick Knutson <mknutson@baselogic.com>wrote:

> The funny thing is, when I have an error with the message coming from this
> queue, which I do because process(Exchange) does not expect my message body,
> the message gets routed to the proper deadLetter channel.
>
>
>
>
> On Fri, Sep 26, 2008 at 12:22 PM, Mick Knutson <mknutson@baselogic.com>wrote:
>
>> I have a Processor with 2 different methods:
>>
>> The standard:
>> *public void process(Exchange exchange) {
>> *
>>
>> and a custom:
>>
>>     *@MessageDriven(uri = Constants.CHANNEL_GG_CS_COMMAND_STATUS)
>>     public void onMessage(Exchange exchange) *
>>
>> Now here is my route:
>>
>>        * from(Constants.CHANNEL_GG_CS_CR_ADD)
>>                 .errorHandler(
>>
>> deadLetterChannel(Constants.CHANNEL_GG_CS_CR_ADD_ERROR)
>> //.maximumRedeliveries(2)
>>                                 //.initialRedeliveryDelay(1)
>>                                 .loggingLevel(LoggingLevel.DEBUG)
>>                 ).processRef("changeRequestController")
>>                 .to(Constants.CHANNEL_GG_CS_COMMAND_CLUSTER);
>>
>>
>>         // Route for command status updates.
>>         from(Constants.CHANNEL_GG_CS_COMMAND_STATUS)
>>                 .errorHandler(
>>
>> deadLetterChannel(Constants.CHANNEL_GG_CS_COMMAND_STATUS_ERROR).maximumRedeliveries(2)
>>                                 .initialRedeliveryDelay(1)
>>                                 .loggingLevel(LoggingLevel.INFO)
>>                 ).to("bean:changeRequestController?methodName=onMessage");
>> *
>>
>> So when I get a message on *Constants.CHANNEL_GG_CS_CR_ADD my
>> process(Exchange) method is called, and that rout is fine.
>>
>> However, I get a response message back on **Constants.CHANNEL_GG_CS_COMMAND_STATUS
>> but it is also processed by *the *process(Exchange) instead of my
>> onMessage**(Exchange)*
>>
>> I have tried @MessageDriven annotation as well as the route builder but
>> neither works.
>>
>> Am I forced to have each process in a single class?
>>
>>
>>
>> --
>> ---
>> Thank You…
>>
>> Mick Knutson
>> BASE Logic, inc.
>> (415) 354-4215
>>
>> Website: http://baselogic.com
>> Blog: http://baselogic.com/blog
>> BLiNC Magazine: http://blincmagazine.com
>> Linked IN: http://linkedin.com/in/mickknutson
>> DJ Mick: http://djmick.com
>> MySpace: http://myspace.com/mickknutson
>> Vacation Rental: http://tahoe.baselogic.com
>>
>>
>
>
> --
> ---
> Thank You…
>
> Mick Knutson
> BASE Logic, inc.
> (415) 354-4215
>
> Website: http://baselogic.com
> Blog: http://baselogic.com/blog
> BLiNC Magazine: http://blincmagazine.com
> Linked IN: http://linkedin.com/in/mickknutson
> DJ Mick: http://djmick.com
> MySpace: http://myspace.com/mickknutson
> Vacation Rental: http://tahoe.baselogic.com
>
>


-- 
---
Thank You…

Mick Knutson
BASE Logic, inc.
(415) 354-4215

Website: http://baselogic.com
Blog: http://baselogic.com/blog
BLiNC Magazine: http://blincmagazine.com
Linked IN: http://linkedin.com/in/mickknutson
DJ Mick: http://djmick.com
MySpace: http://myspace.com/mickknutson
Vacation Rental: http://tahoe.baselogic.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message