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

Labels

No labels
No labels

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions