Struct DmqConsumerServerPallas

pub struct DmqConsumerServerPallas { /* private fields */ }

A DMQ server implementation for messages notification from a DMQ node.

Implementations

impl DmqConsumerServerPallas

pub fn new( socket: PathBuf, network: CardanoNetwork, stop_rx: Receiver<()>, logger: Logger, ) -> Self

Creates a new instance of DmqConsumerServerPallas.

pub async fn register_receiver( &self, receiver: UnboundedReceiver<DmqMessage>, ) -> StdResult<()>

Registers the receiver for DMQ messages (only one receiver is allowed).

Trait Implementations

impl DmqConsumerServer for DmqConsumerServerPallas

fn process_message<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Processes the next message received from the DMQ network.

fn run<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Runs the DMQ consumer server.

impl Drop for DmqConsumerServerPallas

fn drop(&mut self)

Executes the destructor for this type.