Skip to content

[Feat]: Is it possible to use an external message broker for event queue management #277

@sanjeevkumar761

Description

@sanjeevkumar761

Is your feature request related to a problem? Please describe.

The currently implementation of event queue management in A2A python SDK is in-memory only. For enterprise scenarios where there needs to be long-term persistence of the event state, is it possible to use external message brokers e.g., Azure Service Bus or Kafka?

a2a-python/src/a2a/server/events
/queue_manager.py

Describe the solution you'd like

Provide a capability to extend the queue management to use external implementation of EventQueue class.

E.g., allow to extend EventQueue class with extended implementation e.g., AzureServiceBusEventQueue.

from a2a.server.events.extensions import AzureServiceBusEventQueue

Describe alternatives you've considered

Currently we have to do workarounds e.g., intercept standard events and send those to external message brokers.

Additional context

Current in-memory queue implementation is not adquate for enterprise environments.

Code of Conduct

  • I agree to follow this project's Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions