Hi Héctor,
You are transforming the message from a CamelMessage to a Unit in your
method:
override def transformOutgoingMessage(msg: Any) = {
println(s"${msg.getClass}")
}
println returns Unit, when interacting with Java the Unit object becomes
BoxedUnit as Unit does not exist in Java-land.
Make sure to either remove that transform method or return the message from
it and it will work.
--
Johan
On Mon, Jul 25, 2016 at 8:28 PM, Héctor Veiga <[email protected]> wrote:
> object CamelMessageProducer {
> def props(uri: String) = Props(new CamelMessageProducer(uri))
> }
>
> class CamelMessageProducer(uri: String) extends Producer {
> def endpointUri = uri
>
> override def transformOutgoingMessage(msg: Any) = {
> println(s"${msg.getClass}")
> }
> }
>
--
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
