kytos-ng / kytos

                    cls.controller.dead_letter.add_event(kytos_event)

            return result

        async def handler_context_apm(*args, apm_client=None):

            """Async handler's execution context with APM instrumentation."""

            cls, kytos_event = args[0], args[1]

            trace_parent = kytos_event.trace_parent

            tx_type = "kytos_event"

            tx = apm_client.begin_transaction(transaction_type=tx_type,

                                              trace_parent=trace_parent)

            kytos_event.trace_parent = tx.trace_parent

            tx.name = f"{kytos_event.name}@{cls.napp_id}"

            try:

                result = await handler(*args)

                tx.result = result

            except Exception as exc:

                result = None

                traceback_str = traceback.format_exc()

                LOG.error(f"alisten_to handler: {handler}, "

                          f"args: {args} traceback: {traceback_str}")

                if hasattr(cls, "controller"):

                    cls.controller.dead_letter.add_event(kytos_event)

                apm_client.capture_exception(

                    exc_info=(type(exc), exc, exc.__traceback__),

                    context={"args": args},

                    handled=False,

                )

            tx.end()

            apm_client.tracer.queue_func("transaction", tx.to_dict())

            return result

        handler_func, kwargs = handler_context, {}

        if get_apm_name() == "es":

                    cls.controller.dead_letter.add_event(kytos_event)

            return result

        def handler_context_apm(*args, apm_client=None):

            """Handler's context for ThreadPool APM instrumentation."""

            cls, kytos_event = args[0], args[1]

            trace_parent = kytos_event.trace_parent

            tx_type = "kytos_event"

            tx = apm_client.begin_transaction(transaction_type=tx_type,

                                              trace_parent=trace_parent)

            kytos_event.trace_parent = tx.trace_parent

            tx.name = f"{kytos_event.name}@{cls.napp_id}"

            try:

                result = handler(*args)

                tx.result = result

            except Exception as exc:

                result = None

                traceback_str = traceback.format_exc()

                LOG.error(f"listen_to handler: {handler}, "

                          f"args: {args} traceback: {traceback_str}")

                if hasattr(cls, "controller"):

                    cls.controller.dead_letter.add_event(kytos_event)

                apm_client.capture_exception(

                    exc_info=(type(exc), exc, exc.__traceback__),

                    context={"args": args},

                    handled=False,

                )

            tx.end()

            apm_client.tracer.queue_func("transaction", tx.to_dict())

            return result

        handler_func, kwargs = handler_context, {}

        if get_apm_name() == "es":