here is my code
class Actor1(failedService: FailedService, actor2: ActorRef @@ Actor2)
extends Actor{
override def receive: Receive = {
case TriggerActor1() =>
println("Actor1 triggered from REST controller. Send msg to actor 2")
failedService.testSend()
//actor2 ! Msg1()
case Msg2() => println("got msg2 from actor 1")
}
class Actor2 extends Actor {
override def receive: Receive = {
case Msg1() => {
println("send without future")
val origsender = sender()
origsender ! Msg2()
}
}
class FailedService(actor2: ActorRef@@Actor2) {
def testSend() = {
actor2 ! Msg1()
}
}
With my current code as shared above, Actor1 is able to send Msg1 to Actor2
and actor2 responds with Msg2 but Msg2 goes to deadletter. I get the below error
akka.actor.DeadLetterActorRef - Message [backup.failedakka.Msg2] from
Actor[akka://application/user/actor2#-662746578] to
Actor[akka://application/deadLetters] was not delivered. [1] dead
letters encountered.
However, if insted of using the line "failedService.testSend()" in my
Actor1, I uncomment the line below it
and use that to communicate, things work fine.
Is the Q clear now? I am injecting dependencies with MacWire
On Thu, Feb 22, 2018 at 11:07 PM Kanwaljeet Singh <ksachd...@gmail.com>
wrote:
> this is nto a macwire question I think.
>
> On Thu, Feb 22, 2018 at 11:06 PM Konrad “ktoso” Malawski <
> konrad.malaw...@lightbend.com> wrote:
>
>> I don’t understand what’s going where or how ;-)
>> Could you share code?
>>
>> Also, isn’t this a macwire question? Better to ask on
>> https://github.com/adamw/macwire/issues ?
>>
>> --
>> Cheers,
>> Konrad 'ktoso <http://kto.so>' Malawski
>> Akka <http://akka.io/> @ Lightbend <http://lightbend.com/>
>>
>> On February 23, 2018 at 16:05:22, ksachd...@gmail.com (
>> ksachd...@gmail.com) wrote:
>>
>>
>> 1.
>>
>> Scenario 1 - Working scenario
>> - Actor1 -->MyMsg1-->Actor2
>> - Actor2 MyMsgHandler - Processes message(with Future), does
>> pipeTo to sender with MyMsg2. Works fine, Actor1 recvs MyMsg2
>>
>>
>>
>> 1.
>>
>> Scenario2 - Failing scenario
>> - Actor1 has a bean injected via MacWire - myBean.
>> - myBean has Actor2 injected as a bean and sends MyMsg1 to Actor2
>> - Actor2 MyMsgHandler processes message(with Future), does pipeTo
>> to sender and tries sending MyMsg2 - Goes to deadLetter. The actor
>> Ref for sender is never set.
>>
>> How do I fix scenario2?
>>
>> --
>> >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
>> To post to this group, send email to akka-user@googlegroups.com.
>> Visit this group at https://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>>
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
