InitChannel(
server,
ch,
token,
create
) → RDID
SCCheckAndResolve(
server,
channel,
token,
rdid
) → innerChannel
SecureChannelPublish(
server,
subj,
rdid,
token,
data,
expireSecs
) → receipt
SecureChannelQueueSubscribe(
server,
channel,
queue,
token,
rdid,
callback
)

class HybridMCPBroker:
def route_message(
self,
from_server,
to_server,
message
):
if self.is_secure_enabled(
to_server
):
return self.secure_send(...)
else:
return self.legacy_send(...)
# Minimal integration code
broker = SecureChannelBroker(
nats_url
)
rdid = broker.register_mcp_server(
"server-1"
)
broker.subscribe(
rdid,
handle_tool_request
)
response = broker.request(
target_rdid,
tool_call,
timeout=30
)
broker.publish(target_rdid, result)