Module msgbus 

Structs

RedisMessageBusDatabase

Functions

publish_messages

Publishes messages received on rx to Redis streams for the given trader_id and instance_id, using config.

stream_messages

Streams messages from Redis streams and sends them over the provided tx channel.