Struct RedisMessageBusBacking 

pub struct RedisMessageBusBacking {
    pub trader_id: TraderId,
    pub instance_id: UUID4,
    /* private fields */
}

Fields

trader_id: TraderId

The trader ID for this message bus backing.

instance_id: UUID4

The instance ID for this message bus backing.

Implementations

impl RedisMessageBusBacking

pub fn new( trader_id: TraderId, instance_id: UUID4, config: MessageBusConfig, backing: RedisMessageBusConfig, ) -> Result<Self>

Creates a new RedisMessageBusBacking instance for the given trader_id, instance_id, and config.

Errors

Returns an error if the heartbeat interval is configured as zero seconds.

impl RedisMessageBusBacking

pub fn get_stream_receiver(&mut self) -> Result<Receiver<BusMessage>>

Retrieves the Redis stream receiver for this message bus instance.

Errors

Returns an error if the stream receiver has already been taken.

pub fn stream( stream_rx: Receiver<BusMessage>, ) -> impl Stream<Item = BusMessage> + 'static

Streams messages arriving on the stream receiver channel.

pub async fn close_async(&mut self)

Trait Implementations

impl Debug for RedisMessageBusBacking

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MessageBusBacking for RedisMessageBusBacking

fn is_closed(&self) -> bool

Returns whether the message bus backing publishing channel is closed.

fn publish(&self, message: BusMessage)

Queues a serialized bus message for external publication.

fn close(&mut self)

Closes the message bus backing.

fn take_receiver(&mut self) -> Result<Receiver<BusMessage>>

Takes the inbound message receiver for live bridge consumption.