Add a way for actors to access the current message

[devedetti]

Hello. I have an Actor (function) and I need to know if it is the first or fifth execution.
(based on his retry number I must execute a complementary code)

Maybe I should use a middleware or pipeline?

Thanks for your time.

[Bogdanp]

Can you use retry_when?

def should_retry(retries_so_far, e):
  ...

@actor(retry_when=should_retry)
def some_fn():
  ...

Otherwise, you can define a middleware that exposes the current message using a thread-local variable:

class CurrentMessage(Middleware):
    STATE = local()

    @classmethod
    def get_current_message():
        return getattr(CurrentMessage.STATE, "message", None)

    def before_process_message(self, broker, message):
        setattr(self.STATE, "message", message)

    def after_process_message(self, broker, message, *, result=None, exception=None):
        delattr(self.STATE, "message")

I'll probably add something like this to one of the upcoming versions since having access to the current message can sometimes be useful.

[devedetti]

@Bogdanp I was away from the PC these days :(
I switched my code to work with callbacks (with some introduced bugs :P) but this feature is a great solution!

I'm very glad with your response. Thanks you very much.