Skip to content

Add pluggable transport layer with RabbitMQ backend#28

Draft
mikelangmayr wants to merge 11 commits intopgupta/protocolfrom
mikelangmayr/transport
Draft

Add pluggable transport layer with RabbitMQ backend#28
mikelangmayr wants to merge 11 commits intopgupta/protocolfrom
mikelangmayr/transport

Conversation

@mikelangmayr
Copy link
Collaborator

@mikelangmayr mikelangmayr commented Feb 12, 2026

Issue 17

  • extract shared session logic (RequestSession, RequestServer, PublishSession, SubscribeSession) into transport/session.py
  • simplify ZMQ transport to use the shared session layer and protocol.wire codec
  • add RabbitMQ transport (transport/rabbitmq/) implementing the same interfaces via pika
  • backend selection via MKTL_TRANSPORT env var (default: zmq)
  • pika is an optional dependency: pip install mKTL[rabbitmq]

@klanclos
Copy link
Contributor

I've only done a quick read, but it looks like there are some 'import zmq' references being removed by this pull request-- those should already be eliminated by #24. Is this out of sync with the main branch?

@prkrtg
Copy link
Collaborator

prkrtg commented Feb 12, 2026

We're off by a few commits, but a rebase will address that. The focus of this PR is the transport change.

@prkrtg prkrtg linked an issue Feb 12, 2026 that may be closed by this pull request
@jmader jmader requested review from 2ahunter and mkb0517 and removed request for prkrtg, scizen9 and tylertucker202 February 13, 2026 17:52
@jmader jmader marked this pull request as draft February 18, 2026 16:50
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Make the use of the protocol transport agnostic

3 participants