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

Added emission of heartbeat signal.

This commit is contained in:
Ernesto De Stefano 2017-02-16 16:08:37 +01:00 committed by Matt Broadstone
parent f63b294e79
commit ff81962201
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/qamqpclient.cpp
View File

@ -239,6 +239,8 @@ void QAmqpClientPrivate::_q_socketError(QAbstractSocket::SocketError error)
void QAmqpClientPrivate::_q_readyRead() void QAmqpClientPrivate::_q_readyRead()
{ {
Q_Q(QAmqpClient);
while (socket->bytesAvailable() >= QAmqpFrame::HEADER_SIZE) { while (socket->bytesAvailable() >= QAmqpFrame::HEADER_SIZE) {
unsigned char headerData[QAmqpFrame::HEADER_SIZE]; unsigned char headerData[QAmqpFrame::HEADER_SIZE];
socket->peek((char*)headerData, QAmqpFrame::HEADER_SIZE); socket->peek((char*)headerData, QAmqpFrame::HEADER_SIZE);
@ -323,6 +325,7 @@ void QAmqpClientPrivate::_q_readyRead()
} }
qAmqpDebug("AMQP: Heartbeat"); qAmqpDebug("AMQP: Heartbeat");
Q_EMIT q->heartbeat();
} }
break; break;
default: default: