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

[*] fix reconnect

This commit is contained in:
fuCtor 2012-05-30 02:09:03 -07:00
parent 1f2aaec772
commit f2f34c1d40
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/qamqp/amqp.cpp
View File

@ -160,7 +160,6 @@ Queue * ClientPrivate::createQueue(int channelNumber, const QString &name )
void ClientPrivate::disconnect() void ClientPrivate::disconnect()
{ {
P_Q(QAMQP::Client); P_Q(QAMQP::Client);
//connection_->close();
if(network_->state() != QAbstractSocket::UnconnectedState) if(network_->state() != QAbstractSocket::UnconnectedState)
{ {
network_->QAMQP::Network::disconnect(); network_->QAMQP::Network::disconnect();

11
src/qamqp/amqp_network.cpp
View File

@ -73,16 +73,17 @@ void QAMQP::Network::error( QAbstractSocket::SocketError socketError )
case QAbstractSocket::ProxyConnectionClosedError: case QAbstractSocket::ProxyConnectionClosedError:
case QAbstractSocket::ProxyConnectionRefusedError: case QAbstractSocket::ProxyConnectionRefusedError:
case QAbstractSocket::ProxyConnectionTimeoutError: case QAbstractSocket::ProxyConnectionTimeoutError:
if( autoReconnect_ && connect_ )
{
QTimer::singleShot(timeOut_, this, SLOT(connectTo()));
}
break;
default: default:
qWarning() << "AMQP Socket Error: " << socket_->errorString(); qWarning() << "AMQP Socket Error: " << socket_->errorString();
break; break;
} }
if( autoReconnect_ && connect_ )
{
QTimer::singleShot(timeOut_, this, SLOT(connectTo()));
}
} }
void QAMQP::Network::readyRead() void QAMQP::Network::readyRead()