[−][src]Crate spectacles_brokers
spectacles-brokers
Message brokers which allow for simple communication between Spectacles services.
Available Brokers
- AMQP - An interface to connect to an AMQP-compliant server.
Example AMQP Publisher
use std::env::var; use std::net::SocketAddr; use futures::future::Future; use spectacles_brokers::AmqpBroker; fn main() { let addr = var("AMQP_ADDR").expect("No AMQP server address found."); let addr: SocketAddr = addr.parse(); let connect = AmqpBroker::new(&addr, "test".to_string(), None); let result = connect.and_then(|broker| { let json = r#"{"message": "Example Publish."}"#.as_bytes(); broker.publish("HELLO", json.to_vec()) }); let success = result.map(|_| { println!("Message publish succeeded, check the other window!"); }).map_err(|err| { eprintln!("An error was encountered during publish: {}", err); }); tokio::run(success); }
More examples can be found in the examples directory on Github.
Modules
amqp | Utilities for interfacing with an AMQP-based message broker. |
Enums
Error | Details the various errors of the crate. |
Traits
MessageHandler | Event handler for receiving messages from a message brokers. |