stomp-rs
stomp-rs copied to clipboard
zslayton
A STOMP client in Rust. Compatible with RabbitMQ, ActiveMQ.
Currently the client will always try to reconnect (every 3 seconds, looping infinitely) if the connection dies.
The buffer used to read from the connection to the server is hardcoded as 1024*64 bytes. This should be a configuration option settable on the `SessionBuilder`.
All of the OptionSetter impls live in the same module at the moment, which is a bit messy. Once #70 is done, break out the impls to live with their...
Some structs (particularly OptionSetters) live in unusual places. Some examples: - `connection::HeartBeat` => `session::HeartBeat` - `connection::Credentials` => `session::Credentials` A 'message' module would be nice for: - `header::ContentType` => `message::ContentType` etc.
In the event of an error, the read-loop thread loses contact with the main thread and a panic ensues. This is messy and looks like an error even though it's...
The API's documentation is currently limited to the examples laid out in `Readme.md`. Rustdoc support needs to be added.
Use a Condvar [1] to allow sending threads to pause and wait for all receipts to be received before proceeding. [1] http://doc.rust-lang.org/sync/struct.Condvar.html