search

sclasen / akka-kafka

185 stars 62 forks source link

Question about state on the stream #27

Closed richiesgr closed 9 years ago

richiesgr commented 9 years ago

Hi

Could you give me some help regarding the state that need to be used for the sync between my actor and yours.

StreamFSM.Processed = I've finished to process this message and must be sended back for each message.

But I can't use it because I receive the message in actor A process it in Actor B so could I use the StreamFSM.StartProcessing in A and send StreamFSM.Processed in B ?

Or is there other states that are relevant ? Thanks

kuhnen commented 9 years ago

I believe what you need is from inside ActorA

ActorB forward ! message

then ActorB will have the Stream sender as the sender()

2015-01-14 9:16 GMT-02:00 richiesgr notifications@github.com:

Hi

Could you give me some help regarding the state that need to be used for the sync between my actor and yours.

StreamFSM.Processed = I've finished to process this message and must be sended back for each message.

But I can't use it because I receive the message in actor A process it in Actor B so could I use the StreamFSM.StartProcessing in A and send StreamFSM.Processed in B ?

Or is there other states that are relevant ? Thanks

— Reply to this email directly or view it on GitHub https://github.com/sclasen/akka-kafka/issues/27.

sclasen commented 9 years ago

@kuhnen you are correct, except no ! needed just ActorB forward message

Thanks!

sclasen commented 9 years ago

pls reopen if any further questions/issues