Struct natsclient::Client

pub struct Client { /* fields omitted */ }

The main entry point for your application to consume NATS services. This client manages connections, connection retries, adjusts to new servers as they enter the cluster, and much more.

Methods

impl Client

pub fn from_options(opts: ClientOptions) -> Result<Client>

Creates a new client from a set of options, which can be created directly or through a ClientOptionsBuilder

pub fn new(url: &str) -> Result<Client>

Creates a new client using the default options and the given URL. A client created this way will attempt to establish an anonymous connection with the given NATS server

pub fn subscribe<F>(&self, subject: &str, handler: F) -> Result<()> where
    F: Fn(&Message) -> Result<()> + Sync + Send,
    F: 'static, 

Creates a subscription to a new subject. The subject can be a specfic subject or a wildcard. The handler supplied will be given a reference to delivered messages as they arrive, and can return a Result to indicate processing failure

pub fn queue_subscribe<F>(
    &self,
    subject: &str,
    queue_group: &str,
    handler: F
) -> Result<()> where
    F: Fn(&Message) -> Result<()> + Sync + Send,
    F: 'static, 

Creates a subscription for a queue group, allowing message delivery to be spread round-robin style across all clients expressing interest in that subject. For more information on how queue groups work, consult the NATS documentation.

pub fn request<T>(
    &self,
    subject: T,
    payload: &[u8],
    timeout: Duration
) -> Result<Message> where
    T: AsRef<str>, 

Perform a synchronous request by publishing a message on the given subject and waiting an expiration period indicated by the timeout parameter. If the timeout expires before a reply arrives on the inbox subject, an Err result will be returned.

pub fn unsubscribe(&self, subject: impl AsRef<str>) -> Result<()>

Unsubscribe from a subject or wildcard

pub fn publish(
    &self,
    subject: &str,
    payload: &[u8],
    reply_to: Option<&str>
) -> Result<()>

Asynchronously publish a message. This is a fire-and-forget style message and an Ok result here does not imply that interested parties have received the message, only that the message was successfully sent to NATS.

pub fn connect(&self) -> Result<()>

Connect a client to the NATS server(s) indicated by previously supplied configuration

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Client

fn default() -> Client

Creates a default client, using anonymous authentication and pointing to the localhost NATS server