Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-23 Thread Tim Moore 
I think your problem is the implicit sender.

When you call actor2 ! Msg1() from inside your Actor1 receiver, it sends
the Actor1 ref as the implicit sender.

Then, then Actor2 replies to the sender, it goes back to the same Actor1
instance.

When you call actor2 ! Msg1() from inside the FailedService object, you
don't have a sender in scope, so it defaults to the dead letter queue.

See https://doc.akka.io/docs/akka/2.5/actors.html#tell-fire-forget

One way you could solve that is to add the implicit sender argument to your
testSend() method:

class FailedService(actor2: ActorRef@@Actor2) {
  def testSend()(implicit sender: ActorRef) = {
actor2 ! Msg1()
  }
}




On Fri, Feb 23, 2018 at 6:29 PM, Kanwaljeet Singh 
wrote:

> In my current code u feel that it is cyclic dependency because you see
> actor1 having access to failedService bean and actor2. But in reality, I
> can just remove actor2 being injected into actor1 if I can get away by
> using failedservice bean. Even if I do that, things remain the same. I have
> my Actor1 as below now(and I think no cyclic depenency now). I still hit
> the issue
>
> class Actor1(failedService: FailedService) 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")
>   }
>
>
> On Thu, Feb 22, 2018 at 11:57 PM Konrad “ktoso” Malawski <
> konrad.malaw...@lightbend.com> wrote:
>
>> It is a macwire thing ;-)
>> It hides you made a cyclic dependency.
>>
>> how would you make this work, plain java/scala:
>>
>> val a = new A(requires B!)
>> val b = new B(a /*requires A*/)
>> Hm, A has an issue...
>>
>> val b = new B(requires B)
>> val a = new A(b /*requires B!*/)
>> Hmm, B can’t get A…
>>
>> As simple as that.
>> Don’t do cyclic dependencies like that.
>>
>> you can create both and do a `a ! HelloIAm(b)` or something similar.
>>
>> --
>> Cheers,
>> Konrad 'ktoso ' Malawski
>> Akka  @ Lightbend 
>>
>> On February 23, 2018 at 16:51:48, Kanwaljeet Singh (ksachd...@gmail.com)
>> wrote:
>>
>> 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 
>> 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 ' Malawski
 Akka  @ Lightbend 

 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?

 --
 >>

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-23 Thread Konrad “ktoso” Malawski 
This is not a 24h/7d support channel, wait a bit ;-)
Thanks.

-- 
Cheers,
Konrad 'ktoso ' Malawski
Akka  @ Lightbend 

On February 23, 2018 at 17:34:30, Kanwaljeet Singh (ksachd...@gmail.com)
wrote:

Any pointers Konrad?

On Thu, Feb 22, 2018, 11:59 PM Kanwaljeet Singh  wrote:

> In my current code u feel that it is cyclic dependency because you see
> actor1 having access to failedService bean and actor2. But in reality, I
> can just remove actor2 being injected into actor1 if I can get away by
> using failedservice bean. Even if I do that, things remain the same. I have
> my Actor1 as below now(and I think no cyclic depenency now). I still hit
> the issue
>
> class Actor1(failedService: FailedService) 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")
>   }
>
>
> On Thu, Feb 22, 2018 at 11:57 PM Konrad “ktoso” Malawski <
> konrad.malaw...@lightbend.com> wrote:
>
>> It is a macwire thing ;-)
>> It hides you made a cyclic dependency.
>>
>> how would you make this work, plain java/scala:
>>
>> val a = new A(requires B!)
>> val b = new B(a /*requires A*/)
>> Hm, A has an issue...
>>
>> val b = new B(requires B)
>> val a = new A(b /*requires B!*/)
>> Hmm, B can’t get A…
>>
>> As simple as that.
>> Don’t do cyclic dependencies like that.
>>
>> you can create both and do a `a ! HelloIAm(b)` or something similar.
>>
>> --
>> Cheers,
>> Konrad 'ktoso ' Malawski
>> Akka  @ Lightbend 
>>
>> On February 23, 2018 at 16:51:48, Kanwaljeet Singh (ksachd...@gmail.com)
>> wrote:
>>
>> 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 
>> 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 ' Malawski
 Akka  @ Lightbend 

 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

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-23 Thread Kanwaljeet Singh 
Any pointers Konrad?

On Thu, Feb 22, 2018, 11:59 PM Kanwaljeet Singh  wrote:

> In my current code u feel that it is cyclic dependency because you see
> actor1 having access to failedService bean and actor2. But in reality, I
> can just remove actor2 being injected into actor1 if I can get away by
> using failedservice bean. Even if I do that, things remain the same. I have
> my Actor1 as below now(and I think no cyclic depenency now). I still hit
> the issue
>
> class Actor1(failedService: FailedService) 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")
>   }
>
>
> On Thu, Feb 22, 2018 at 11:57 PM Konrad “ktoso” Malawski <
> konrad.malaw...@lightbend.com> wrote:
>
>> It is a macwire thing ;-)
>> It hides you made a cyclic dependency.
>>
>> how would you make this work, plain java/scala:
>>
>> val a = new A(requires B!)
>> val b = new B(a /*requires A*/)
>> Hm, A has an issue...
>>
>> val b = new B(requires B)
>> val a = new A(b /*requires B!*/)
>> Hmm, B can’t get A…
>>
>> As simple as that.
>> Don’t do cyclic dependencies like that.
>>
>> you can create both and do a `a ! HelloIAm(b)` or something similar.
>>
>> --
>> Cheers,
>> Konrad 'ktoso ' Malawski
>> Akka  @ Lightbend 
>>
>> On February 23, 2018 at 16:51:48, Kanwaljeet Singh (ksachd...@gmail.com)
>> wrote:
>>
>> 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 
>> 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 ' Malawski
 Akka  @ Lightbend 

 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

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-23 Thread Kanwaljeet Singh 
In my current code u feel that it is cyclic dependency because you see
actor1 having access to failedService bean and actor2. But in reality, I
can just remove actor2 being injected into actor1 if I can get away by
using failedservice bean. Even if I do that, things remain the same. I have
my Actor1 as below now(and I think no cyclic depenency now). I still hit
the issue

class Actor1(failedService: FailedService) 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")
  }


On Thu, Feb 22, 2018 at 11:57 PM Konrad “ktoso” Malawski <
konrad.malaw...@lightbend.com> wrote:

> It is a macwire thing ;-)
> It hides you made a cyclic dependency.
>
> how would you make this work, plain java/scala:
>
> val a = new A(requires B!)
> val b = new B(a /*requires A*/)
> Hm, A has an issue...
>
> val b = new B(requires B)
> val a = new A(b /*requires B!*/)
> Hmm, B can’t get A…
>
> As simple as that.
> Don’t do cyclic dependencies like that.
>
> you can create both and do a `a ! HelloIAm(b)` or something similar.
>
> --
> Cheers,
> Konrad 'ktoso ' Malawski
> Akka  @ Lightbend 
>
> On February 23, 2018 at 16:51:48, Kanwaljeet Singh (ksachd...@gmail.com)
> wrote:
>
> 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 
> 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 ' Malawski
>>> Akka  @ Lightbend 
>>>
>>> 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

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-22 Thread Konrad “ktoso” Malawski 
It is a macwire thing ;-)
It hides you made a cyclic dependency.

how would you make this work, plain java/scala:

val a = new A(requires B!)
val b = new B(a /*requires A*/)
Hm, A has an issue...

val b = new B(requires B)
val a = new A(b /*requires B!*/)
Hmm, B can’t get A…

As simple as that.
Don’t do cyclic dependencies like that.

you can create both and do a `a ! HelloIAm(b)` or something similar.

-- 
Cheers,
Konrad 'ktoso ' Malawski
Akka  @ Lightbend 

On February 23, 2018 at 16:51:48, Kanwaljeet Singh (ksachd...@gmail.com)
wrote:

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 
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 ' Malawski
>> Akka  @ Lightbend 
>>
>> 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.

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-22 Thread Kanwaljeet Singh 
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 
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 ' Malawski
>> Akka  @ Lightbend 
>>
>> 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.

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-22 Thread Konrad “ktoso” Malawski 
The other questions still stand, please make yourself understandable if you
need help :)

-- 
Cheers,
Konrad 'ktoso ' Malawski
Akka  @ Lightbend 

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.

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-22 Thread Kanwaljeet Singh 
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 ' Malawski
> Akka  @ Lightbend 
>
> 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.

Re: [akka-user] Akka actoreRef with macWire DI, actoreRef is not set

2018-02-22 Thread Konrad “ktoso” Malawski 
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 ' Malawski
Akka  @ Lightbend 

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.