the-distro/ofborg
2
0
Fork 1
Code Issues 1 Pull requests 1 Packages Projects Releases Wiki Activity

formatting fixup on easyamqp

Browse source
This commit is contained in:
Graham Christensen 2018-01-31 19:22:04 -05:00
parent 67d0a276a3
commit 310309caf3
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
1 changed files with 3 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ofborg/src/easyamqp.rs
View file

@ -84,7 +84,6 @@ pub struct BindQueueConfig {
/// queue if K = R. /// queue if K = R.
pub routing_key: Option<String>, pub routing_key: Option<String>,
/// If set, the server will not respond to the method. The client /// If set, the server will not respond to the method. The client
/// should not wait for a reply method. If the server could not /// should not wait for a reply method. If the server could not
/// complete the method it will raise a channel or connection /// complete the method it will raise a channel or connection
@ -357,8 +356,7 @@ impl TypedWrappers for amqp::Channel {
fn declare_exchange( fn declare_exchange(
&mut self, &mut self,
config: ExchangeConfig, config: ExchangeConfig,
) -> Result<amqp::protocol::exchange::DeclareOk, amqp::AMQPError> ) -> Result<amqp::protocol::exchange::DeclareOk, amqp::AMQPError> {
{
self.exchange_declare( self.exchange_declare(
config.exchange, config.exchange,
config.exchange_type.into(), config.exchange_type.into(),
@ -375,8 +373,7 @@ impl TypedWrappers for amqp::Channel {
fn declare_queue( fn declare_queue(
&mut self, &mut self,
config: QueueConfig, config: QueueConfig,
) -> Result<amqp::protocol::queue::DeclareOk, amqp::AMQPError> ) -> Result<amqp::protocol::queue::DeclareOk, amqp::AMQPError> {
{
self.queue_declare( self.queue_declare(
config.queue, config.queue,
config.passive, config.passive,
@ -391,8 +388,7 @@ impl TypedWrappers for amqp::Channel {
fn bind_queue( fn bind_queue(
&mut self, &mut self,
config: BindQueueConfig, config: BindQueueConfig,
) -> Result<amqp::protocol::queue::BindOk, amqp::AMQPError> ) -> Result<amqp::protocol::queue::BindOk, amqp::AMQPError> {
{
self.queue_bind( self.queue_bind(
config.queue, config.queue,
config.exchange, config.exchange,