test(helloworld): enable autoReconnect in test to show off feature
This commit is contained in:
parent
a7f9a3a837
commit
b746f45af5
|
|
@ -9,7 +9,9 @@ class Receiver : public QObject
|
||||||
{
|
{
|
||||||
Q_OBJECT
|
Q_OBJECT
|
||||||
public:
|
public:
|
||||||
Receiver(QObject *parent = 0) : QObject(parent) {}
|
Receiver(QObject *parent = 0) : QObject(parent) {
|
||||||
|
m_client.setAutoReconnect(true);
|
||||||
|
}
|
||||||
|
|
||||||
public Q_SLOTS:
|
public Q_SLOTS:
|
||||||
void start() {
|
void start() {
|
||||||
|
|
@ -20,6 +22,7 @@ public Q_SLOTS:
|
||||||
private Q_SLOTS:
|
private Q_SLOTS:
|
||||||
void clientConnected() {
|
void clientConnected() {
|
||||||
QAmqpQueue *queue = m_client.createQueue("hello");
|
QAmqpQueue *queue = m_client.createQueue("hello");
|
||||||
|
disconnect(queue, 0, 0, 0); // in case this is a reconnect
|
||||||
connect(queue, SIGNAL(declared()), this, SLOT(queueDeclared()));
|
connect(queue, SIGNAL(declared()), this, SLOT(queueDeclared()));
|
||||||
queue->declare();
|
queue->declare();
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue