diff --git a/tutorials/routing/emit_log_direct/main.cpp b/tutorials/routing/emit_log_direct/main.cpp index 07b30ed..8df666d 100644 --- a/tutorials/routing/emit_log_direct/main.cpp +++ b/tutorials/routing/emit_log_direct/main.cpp @@ -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(sender()); - if (!exchange) + Exchange *direct_logs = qobject_cast(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(); } diff --git a/tutorials/routing/receive_logs_direct/main.cpp b/tutorials/routing/receive_logs_direct/main.cpp index 8fedab6..71977e5 100644 --- a/tutorials/routing/receive_logs_direct/main.cpp +++ b/tutorials/routing/receive_logs_direct/main.cpp @@ -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(); }