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

changed some variable names for clarity and readability

This commit is contained in:
Matt Broadstone 2014-06-19 11:04:20 -04:00
parent 27d8329065
commit 81f9437495
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tutorials/routing/emit_log_direct/main.cpp
View File

@ -22,14 +22,14 @@ public Q_SLOTS:
private Q_SLOTS:
void clientConnected() {
Exchange *exchange = m_client.createExchange("direct_logs");
connect(exchange, SIGNAL(declared()), this, SLOT(exchangeDeclared()));
exchange->declare(Exchange::Direct);
Exchange *direct_logs = m_client.createExchange("direct_logs");
connect(direct_logs, SIGNAL(declared()), this, SLOT(exchangeDeclared()));
direct_logs->declare(Exchange::Direct);
}
void exchangeDeclared() {
Exchange *exchange = qobject_cast<Exchange*>(sender());
if (!exchange)
Exchange *direct_logs = qobject_cast<Exchange*>(sender());
if (!direct_logs)
return;
QStringList args = qApp->arguments();
@ -44,7 +44,7 @@ private Q_SLOTS:
message = "Hello World!";
}
exchange->publish(message, severity);
direct_logs->publish(message, severity);
qDebug(" [x] Sent %s:%s", severity.toLatin1().constData(), message.toLatin1().constData());
m_client.disconnectFromHost();
}

6
tutorials/routing/receive_logs_direct/main.cpp
View File

@ -7,11 +7,11 @@
#include "amqp_queue.h"
using namespace QAMQP;
class LogReceiver : public QObject
class DirectLogReceiver : public QObject
{
Q_OBJECT
public:
LogReceiver(QObject *parent = 0) : QObject(parent) {}
DirectLogReceiver(QObject *parent = 0) : QObject(parent) {}
public Q_SLOTS:
void start(const QStringList &severities) {
@ -76,7 +76,7 @@ int main(int argc, char **argv)
return 1;
}
LogReceiver logReceiver;
DirectLogReceiver logReceiver;
logReceiver.start(severities);
return app.exec();
}