  
# 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
```rust,norun
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.