Struct MessageBus 

pub struct MessageBus {
    pub trader_id: TraderId,
    pub instance_id: UUID4,
    pub name: String,
    pub has_backing: bool,
    /* private fields */
}

A generic message bus to facilitate various messaging patterns.

The bus provides both a producer and consumer API for Pub/Sub, Req/Rep, as well as direct point-to-point messaging to registered endpoints.

Pub/Sub wildcard patterns for hierarchical topics are possible:

• * asterisk represents one or more characters in a pattern.
• ? question mark represents a single character in a pattern.

Given a topic and pattern potentially containing wildcard characters, i.e. * and ?, where ? can match any single character in the topic, and * can match any number of characters including zero characters.

The asterisk in a wildcard matches any character zero or more times. For example, comp* matches anything beginning with comp which means comp, complete, and computer are all matched.

A question mark matches a single character once. For example, c?mp matches camp and comp. The question mark can also be used more than once. For example, c??p would match both of the above examples and coop.

Fields

trader_id: TraderId

The trader ID associated with the message bus.

instance_id: UUID4

The instance ID associated with the message bus.

name: String

The name for the message bus.

has_backing: bool

If the message bus is backed by a database.

Implementations

impl MessageBus

pub fn new( trader_id: TraderId, instance_id: UUID4, name: Option<String>, _config: Option<HashMap<String, Value>>, ) -> Self

Creates a new MessageBus instance.

pub fn register_message_bus(self) -> Rc<RefCell<Self>>

Registers message bus for the current thread.

pub fn router<T: 'static>(&mut self) -> &mut TopicRouter<T>

Gets or creates a typed router for custom message type T.

Panics

Panics if the stored router type doesn’t match T (internal bug).

pub fn endpoint_map<T: 'static>(&mut self) -> &mut EndpointMap<T>

Gets or creates a typed endpoint map for custom message type T.

Panics

Panics if the stored endpoint map type doesn’t match T (internal bug).

pub fn mem_address(&self) -> String

Returns the memory address of this instance as a hexadecimal string.

pub fn switchboard(&self) -> &MessagingSwitchboard

Returns a reference to the switchboard.

pub fn endpoints(&self) -> Vec<&str>

Returns the registered endpoint addresses.

pub fn patterns(&self) -> Vec<&str>

Returns actively subscribed patterns.

pub fn has_subscribers<T: AsRef<str>>(&self, topic: T) -> bool

Returns whether there are subscribers for the topic.

pub fn subscriptions_count<T: AsRef<str>>(&self, topic: T) -> usize

Returns the count of subscribers for the topic.

Panics

Returns an error if the topic is not valid.

pub fn subscriptions(&self) -> Vec<&Subscription>

Returns active subscriptions.

pub fn subscription_handler_ids(&self) -> Vec<&str>

Returns the handler IDs for actively subscribed patterns.

pub fn is_registered<T: Into<MStr<Endpoint>>>(&self, endpoint: T) -> bool

Returns whether the endpoint is registered.

Panics

Returns an error if the endpoint is not valid topic string.

pub fn is_subscribed<T: AsRef<str>>( &self, pattern: T, handler: ShareableMessageHandler, ) -> bool

Returns whether the handler is subscribed to the pattern.

pub const fn close(&self) -> Result<()>

Close the message bus which will close the sender channel and join the thread.

Errors

This function never returns an error (TBD once backing database added).

pub fn get_endpoint( &self, endpoint: MStr<Endpoint>, ) -> Option<&ShareableMessageHandler>

Returns the handler for the endpoint.

pub fn get_response_handler( &self, correlation_id: &UUID4, ) -> Option<&ShareableMessageHandler>

Returns the handler for the correlation_id.

pub fn matching_subscriptions<T: Into<MStr<Topic>>>( &mut self, topic: T, ) -> Vec<Subscription>

Finds the subscriptions which match the topic and caches the results in the patterns map.

pub fn register_response_handler( &mut self, correlation_id: &UUID4, handler: ShareableMessageHandler, ) -> Result<()>

Registers a response handler for a specific correlation ID.

Errors

Returns an error if handler is already registered for the correlation_id.

Trait Implementations

impl Debug for MessageBus

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

Formats the value using the given formatter.

impl Default for MessageBus

fn default() -> Self

Creates a new default MessageBus instance.