jessequ
/
qamqp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Typo: deley -> delay

This commit is contained in:
Michel D'HOOGE 2013-02-19 11:51:42 +01:00
parent e2c77e13d8
commit 6b5ed036ad
4 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/qamqp/amqp_exchange.cpp
View File

@ -49,7 +49,7 @@ Exchange::~Exchange()
void Exchange::onOpen() void Exchange::onOpen()
{ {
P_D(Exchange); P_D(Exchange);
if(d->deleyedDeclare) if(d->delayedDeclare)
{ {
d->declare(); d->declare();
} }
@ -125,7 +125,7 @@ void Exchange::publish( const QByteArray & message, const QString & key, const Q
ExchangePrivate::ExchangePrivate(Exchange * q) ExchangePrivate::ExchangePrivate(Exchange * q)
:ChannelPrivate(q) :ChannelPrivate(q)
, deleyedDeclare(false) , delayedDeclare(false)
, declared(false) , declared(false)
{ {
} }
@ -177,7 +177,7 @@ void ExchangePrivate::declare( )
{ {
if(!opened) if(!opened)
{ {
deleyedDeclare = true; delayedDeclare = true;
return; return;
} }
@ -197,7 +197,7 @@ void ExchangePrivate::declare( )
frame.setArguments(arguments_); frame.setArguments(arguments_);
sendFrame(frame); sendFrame(frame);
deleyedDeclare = false; delayedDeclare = false;
} }
void ExchangePrivate::remove( bool ifUnused /*= true*/, bool noWait /*= true*/ ) void ExchangePrivate::remove( bool ifUnused /*= true*/, bool noWait /*= true*/ )
@ -271,6 +271,6 @@ void ExchangePrivate::_q_disconnected()
{ {
ChannelPrivate::_q_disconnected(); ChannelPrivate::_q_disconnected();
qDebug() << "Exchange " << name << " disconnected"; qDebug() << "Exchange " << name << " disconnected";
deleyedDeclare = false; delayedDeclare = false;
declared = false; declared = false;
} }

4
src/qamqp/amqp_exchange_p.h
View File

@ -33,8 +33,8 @@ namespace QAMQP
bool _q_method(const QAMQP::Frame::Method & frame); bool _q_method(const QAMQP::Frame::Method & frame);
void _q_disconnected(); void _q_disconnected();
bool deleyedDeclare; bool delayedDeclare;
bool declared; bool declared;
}; };
} }

8
src/qamqp/amqp_queue.cpp
View File

@ -48,7 +48,7 @@ Queue::~Queue()
void Queue::onOpen() void Queue::onOpen()
{ {
P_D(Queue); P_D(Queue);
if(d->deleyedDeclare) if(d->delayedDeclare)
{ {
d->declare(); d->declare();
} }
@ -178,7 +178,7 @@ void Queue::ack( const MessagePtr & message )
QueuePrivate::QueuePrivate(Queue * q) QueuePrivate::QueuePrivate(Queue * q)
:ChannelPrivate(q) :ChannelPrivate(q)
, deleyedDeclare(false) , delayedDeclare(false)
, declared(false) , declared(false)
, noAck(true) , noAck(true)
, recievingMessage(false) , recievingMessage(false)
@ -296,7 +296,7 @@ void QueuePrivate::declare()
{ {
if(!opened) if(!opened)
{ {
deleyedDeclare = true; delayedDeclare = true;
return; return;
} }
@ -311,7 +311,7 @@ void QueuePrivate::declare()
frame.setArguments(arguments_); frame.setArguments(arguments_);
sendFrame(frame); sendFrame(frame);
deleyedDeclare = false; delayedDeclare = false;
} }

2
src/qamqp/amqp_queue_p.h
View File

@ -53,7 +53,7 @@ namespace QAMQP
bool _q_method(const QAMQP::Frame::Method & frame); bool _q_method(const QAMQP::Frame::Method & frame);
bool deleyedDeclare; bool delayedDeclare;
bool declared; bool declared;
bool noAck; bool noAck;
QString consumerTag; QString consumerTag;