Skip to content

BaseHubListener

autogen.beta.network.hub.listener.BaseHubListener #

No-op base implementation. Override only the events you care about.

on_envelope_posted async #

on_envelope_posted(envelope, metadata)
Source code in autogen/beta/network/hub/listener.py
async def on_envelope_posted(self, envelope, metadata) -> None:  # noqa: ARG002
    return None

on_envelope_rejected async #

on_envelope_rejected(envelope, reason)
Source code in autogen/beta/network/hub/listener.py
async def on_envelope_rejected(self, envelope, reason) -> None:  # noqa: ARG002
    return None

on_dispatch_failed async #

on_dispatch_failed(envelope, recipient_id, reason)
Source code in autogen/beta/network/hub/listener.py
async def on_dispatch_failed(self, envelope, recipient_id, reason) -> None:  # noqa: ARG002
    return None

on_channel_event async #

on_channel_event(channel_id, kind, payload)
Source code in autogen/beta/network/hub/listener.py
async def on_channel_event(self, channel_id, kind, payload) -> None:  # noqa: ARG002
    return None

on_agent_event async #

on_agent_event(agent_id, kind, payload)
Source code in autogen/beta/network/hub/listener.py
async def on_agent_event(self, agent_id, kind, payload) -> None:  # noqa: ARG002
    return None

on_expectation_fired async #

on_expectation_fired(channel_id, expectation, violation)
Source code in autogen/beta/network/hub/listener.py
async def on_expectation_fired(self, channel_id, expectation, violation) -> None:  # noqa: ARG002
    return None

on_turn_failed async #

on_turn_failed(channel_id, agent_id, envelope_id, exc)
Source code in autogen/beta/network/hub/listener.py
async def on_turn_failed(self, channel_id, agent_id, envelope_id, exc) -> None:  # noqa: ARG002
    return None

on_task_event async #

on_task_event(task_id, kind, payload)
Source code in autogen/beta/network/hub/listener.py
async def on_task_event(self, task_id, kind, payload) -> None:  # noqa: ARG002
    return None

on_inbox_pressure async #

on_inbox_pressure(agent_id, pending, cap)
Source code in autogen/beta/network/hub/listener.py
async def on_inbox_pressure(self, agent_id, pending, cap) -> None:  # noqa: ARG002
    return None