Struct MessageRouter 

pub struct MessageRouter { /* private fields */ }

Message router for handling WebSocket connections and message routing

Implementations

impl MessageRouter

pub fn new( ws_url: String, subscription_manager: Arc<SubscriptionManager>, listen_key_manager: Option<Arc<ListenKeyManager>>, ) -> Self

Creates a new message router

pub async fn start(&self, url_override: Option<String>) -> Result<()>

Starts the message router

pub async fn stop(&self) -> Result<()>

Stops the message router

pub async fn restart(&self) -> Result<()>

Restarts the message router

pub fn get_url(&self) -> String

Returns the configured WebSocket URL

pub fn is_connected(&self) -> bool

Returns the current connection state

pub async fn set_reconnect_config(&self, config: ReconnectConfig)

Applies a new reconnection configuration

pub async fn get_reconnect_config(&self) -> ReconnectConfig

Retrieves the current reconnection configuration

pub async fn subscribe(&self, streams: Vec<String>) -> Result<()>

Subscribes to the provided streams

pub async fn unsubscribe(&self, streams: Vec<String>) -> Result<()>

Unsubscribes from the provided streams

pub fn extract_stream_name(message: &Value) -> Result<String>

Extracts the stream name from an incoming message

Trait Implementations

impl Drop for MessageRouter

fn drop(&mut self)

Executes the destructor for this type.