From ff81962201e4ae183e2b433e094eef1814999667 Mon Sep 17 00:00:00 2001 From: Ernesto De Stefano Date: Thu, 16 Feb 2017 16:08:37 +0100 Subject: [PATCH] Added emission of heartbeat signal. --- src/qamqpclient.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/qamqpclient.cpp b/src/qamqpclient.cpp index 4035c12..41a0a17 100644 --- a/src/qamqpclient.cpp +++ b/src/qamqpclient.cpp @@ -239,6 +239,8 @@ void QAmqpClientPrivate::_q_socketError(QAbstractSocket::SocketError error) void QAmqpClientPrivate::_q_readyRead() { + Q_Q(QAmqpClient); + while (socket->bytesAvailable() >= QAmqpFrame::HEADER_SIZE) { unsigned char headerData[QAmqpFrame::HEADER_SIZE]; socket->peek((char*)headerData, QAmqpFrame::HEADER_SIZE); @@ -323,6 +325,7 @@ void QAmqpClientPrivate::_q_readyRead() } qAmqpDebug("AMQP: Heartbeat"); + Q_EMIT q->heartbeat(); } break; default: