diff --git a/src/qamqp/amqp_exchange.cpp b/src/qamqp/amqp_exchange.cpp index 4ec0f9a..cbfd716 100644 --- a/src/qamqp/amqp_exchange.cpp +++ b/src/qamqp/amqp_exchange.cpp @@ -49,7 +49,7 @@ Exchange::~Exchange() void Exchange::onOpen() { P_D(Exchange); - if(d->deleyedDeclare) + if(d->delayedDeclare) { d->declare(); } @@ -125,7 +125,7 @@ void Exchange::publish( const QByteArray & message, const QString & key, const Q ExchangePrivate::ExchangePrivate(Exchange * q) :ChannelPrivate(q) - , deleyedDeclare(false) + , delayedDeclare(false) , declared(false) { } @@ -177,7 +177,7 @@ void ExchangePrivate::declare( ) { if(!opened) { - deleyedDeclare = true; + delayedDeclare = true; return; } @@ -197,7 +197,7 @@ void ExchangePrivate::declare( ) frame.setArguments(arguments_); sendFrame(frame); - deleyedDeclare = false; + delayedDeclare = false; } void ExchangePrivate::remove( bool ifUnused /*= true*/, bool noWait /*= true*/ ) @@ -271,6 +271,6 @@ void ExchangePrivate::_q_disconnected() { ChannelPrivate::_q_disconnected(); qDebug() << "Exchange " << name << " disconnected"; - deleyedDeclare = false; + delayedDeclare = false; declared = false; } diff --git a/src/qamqp/amqp_exchange_p.h b/src/qamqp/amqp_exchange_p.h index 71d294d..cd1eea5 100644 --- a/src/qamqp/amqp_exchange_p.h +++ b/src/qamqp/amqp_exchange_p.h @@ -33,8 +33,8 @@ namespace QAMQP bool _q_method(const QAMQP::Frame::Method & frame); void _q_disconnected(); - bool deleyedDeclare; + bool delayedDeclare; bool declared; }; -} \ No newline at end of file +} diff --git a/src/qamqp/amqp_queue.cpp b/src/qamqp/amqp_queue.cpp index 26c5ab4..2d24b01 100644 --- a/src/qamqp/amqp_queue.cpp +++ b/src/qamqp/amqp_queue.cpp @@ -48,7 +48,7 @@ Queue::~Queue() void Queue::onOpen() { P_D(Queue); - if(d->deleyedDeclare) + if(d->delayedDeclare) { d->declare(); } @@ -178,7 +178,7 @@ void Queue::ack( const MessagePtr & message ) QueuePrivate::QueuePrivate(Queue * q) :ChannelPrivate(q) - , deleyedDeclare(false) + , delayedDeclare(false) , declared(false) , noAck(true) , recievingMessage(false) @@ -296,7 +296,7 @@ void QueuePrivate::declare() { if(!opened) { - deleyedDeclare = true; + delayedDeclare = true; return; } @@ -311,7 +311,7 @@ void QueuePrivate::declare() frame.setArguments(arguments_); sendFrame(frame); - deleyedDeclare = false; + delayedDeclare = false; } diff --git a/src/qamqp/amqp_queue_p.h b/src/qamqp/amqp_queue_p.h index 17472e2..73daa53 100644 --- a/src/qamqp/amqp_queue_p.h +++ b/src/qamqp/amqp_queue_p.h @@ -53,7 +53,7 @@ namespace QAMQP bool _q_method(const QAMQP::Frame::Method & frame); - bool deleyedDeclare; + bool delayedDeclare; bool declared; bool noAck; QString consumerTag;