I need to reused the existing camel processor.
I can create typedactor accordingly to the existing camel processors.
for example:
final Processor akkaProcessor =
TypedActor.get(system).typedActorOf(
new TypedProps<AkkaProcessor>(Processor.class, BusinessProcessor));
Processor is camel api interface and BusinessProcessor implements the
Processor.
And in BusinessProcessor it implements the below method, apparently there
is a parameter exchange.
public void process(final Exchange exchange) throws Exception
So if I want to reuse the processor code in akka, I need to change the
CamelMessage to Exchange
On Friday, June 13, 2014 2:56:07 PM UTC+8, Patrik Nordwall wrote:
>
> Why do you need to convert it? Can't you send to a camel endpoint from a
> akka.camel.Producer and then if you need do camel specific things in the
> camel endpoint?
>
> /Patrik
>
>
> On Thu, Jun 12, 2014 at 4:23 AM, <[email protected] <javascript:>> wrote:
>
>> sorry , it's akka-camel.
>>
>>
>> On Wednesday, June 11, 2014 6:45:27 PM UTC+8, Patrik Nordwall wrote:
>>
>>> akka-spring? You mean akka-camel?
>>>
>>> /Patrik
>>>
>>>
>>> On Wed, Jun 11, 2014 at 5:50 AM, <[email protected]> wrote:
>>>
>>>> Hello All,
>>>>
>>>> In akka-spring module, all camel msg's type is CamelMessage. But in
>>>> camel, it uses Exchange to pass message.
>>>>
>>>> Do you know how to change CamelMessage to Exchange?
>>>>
>>>> --
>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/
>>>> current/additional/faq.html
>>>> >>>>>>>>>> Search the archives: https://groups.google.com/
>>>> group/akka-user
>>>> ---
>>>> You received this message because you are subscribed to the Google
>>>> Groups "Akka User List" group.
>>>> To unsubscribe from this group and stop receiving emails from it, send
>>>> an email to [email protected].
>>>> To post to this group, send email to [email protected].
>>>>
>>>> Visit this group at http://groups.google.com/group/akka-user.
>>>> For more options, visit https://groups.google.com/d/optout.
>>>>
>>>
>>>
>>>
>>> --
>>>
>>> Patrik Nordwall
>>> Typesafe <http://typesafe.com/> - Reactive apps on the JVM
>>> Twitter: @patriknw
>>>
>>> <http://www.scaladays.org/>
>>>
>>> --
>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>> >>>>>>>>>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
>> ---
>> You received this message because you are subscribed to the Google Groups
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an
>> email to [email protected] <javascript:>.
>> To post to this group, send email to [email protected]
>> <javascript:>.
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> --
>
> Patrik Nordwall
> Typesafe <http://typesafe.com/> - Reactive apps on the JVM
> Twitter: @patriknw
>
> <http://www.scaladays.org/>
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
