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

Method reset() added to a QAmqpChannel class 

Sometimes user needs to reset the channel state, for example in case of
attempt to declare an exisiting queue.
This commit is contained in:
Sergey Platonov 2016-12-12 15:43:07 +03:00 committed by Matt Broadstone
parent 21c03b2bab
commit 175482412f
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/qamqpchannel.cpp
View File

@ -341,6 +341,12 @@ qint16 QAmqpChannel::prefetchCount() const
return d->prefetchCount; return d->prefetchCount;
} }
void QAmqpChannel::reset()
{
Q_D(QAmqpChannel);
d->resetInternalState();
}
QAMQP::Error QAmqpChannel::error() const QAMQP::Error QAmqpChannel::error() const
{ {
Q_D(const QAmqpChannel); Q_D(const QAmqpChannel);

2
src/qamqpchannel.h
View File

@ -44,6 +44,8 @@ public:
qint32 prefetchSize() const; qint32 prefetchSize() const;
qint16 prefetchCount() const; qint16 prefetchCount() const;
void reset();
// AMQP Basic // AMQP Basic
void qos(qint16 prefetchCount, qint32 prefetchSize = 0); void qos(qint16 prefetchCount, qint32 prefetchSize = 0);