Struct Worker 

pub struct Worker { /* private fields */ }

The worker object that contains all the threads and runners.

Implementations

impl Worker

pub async fn new( amqp_server_url: impl Into<String>, config: WorkerConfig, ) -> Self

Create a new instance of Worker

Arguments

• amqp_server_url - A string slice that holds the url of the amqp server (e.g. amqp://localhost:5672)
• config - A WorkerConfig, containing the TLS config for now.

pub fn add_non_rpc_consumer<J: Task + 'static + Send>( &mut self, state: Arc<J::State>, listener_config: ListenerConfig, )

where <J as Task>::State: Send + Sync,

Add a Task listener to the worker object

Arguments

• state - An Arc of the state object that will be passed to the listener
• listener_config - ListenerConfig that holds the configuration for the listener

   use bunbun_worker::{Worker, ListenerConfig, WorkerConfig};
   let server = Worker::new("amqp://localhost:5672", Workerconfig::default()).await;
   server.add_non_rpc_consumer::<MyTask>(ListenerConfig::default("service-jobname").set_message_version("v2.0.0") ));
   server.start_all_listeners().await;

pub fn add_rpc_consumer<J: RPCTask + 'static + Send>( &mut self, state: Arc<J::State>, listener_config: ListenerConfig, )

where <J as RPCTask>::State: Send + Sync, <J as RPCTask>::Result: Send + Sync, <J as RPCTask>::ErroredResult: Send + Sync,

Add an rpc job listener to the worker object Make sure the type you pass in implements RPCTask

Arguments

• queue_name - A string slice that holds the name of the queue to listen to (e.g. service-serviceJobName-v1.0.0)
• state - An Arc of the state object that will be passed to the listener

Examples

   use bunbun_worker::{Worker, ListenerConfig, WorkerConfig};
   let server = Worker::new("amqp://localhost:5672", Workerconfig::default()).await;
   server.add_rpc_consumer::<MyRPCTask>(ListenerConfig::default("service-jobname").set_message_version("v2.0.0") ));
   server.start_all_listeners().await;

pub async fn start_all_listeners(&self) -> Result<(), String>

Start all the listeners added to the worker object