- updated all manual tests to reorder publish parameters (routeKey first)

- updated all manual tests to remove queues with no name
This commit is contained in:
Matt Broadstone 2014-06-06 14:32:46 -04:00
parent bea9204824
commit bad40ac83b
5 changed files with 6 additions and 6 deletions

View File

@ -54,7 +54,7 @@ protected slots:
);
qDebug() << "EmitLog::emitlogMessage " << message;
exchange_->publish(message, "");
exchange_->publish("receive-log", message);
}
private:

View File

@ -31,7 +31,7 @@ public:
client->connectToHost(address);
// Create an exclusive queue
queue_ = client->createQueue("");
queue_ = client->createQueue("receive-log");
queue_->declare(Queue::Exclusive);
connect(queue_, SIGNAL(declared()), this, SLOT(declared()));
@ -46,7 +46,7 @@ protected slots:
void declared()
{
// Bind the queue to the "logs" exchange (declared by publisher)
queue_->bind("logs", "");
queue_->bind("logs", "receive-log");
queue_->consume(QAMQP::Queue::coNoAck);
}

View File

@ -62,7 +62,7 @@ protected slots:
qDebug() << "EmitLogDirect::emitLogMessage " << message;
// Publish
exchange_->publish(message, key);
exchange_->publish(key, message);
}
private:

View File

@ -34,7 +34,7 @@ public:
client->connectToHost(address);
// Create an exclusive queue
queue_ = client->createQueue("");
queue_ = client->createQueue("receive-log-direct");
queue_->declare(Queue::Exclusive);
connect(queue_, SIGNAL(declared()), this, SLOT(declared()));

View File

@ -61,7 +61,7 @@ protected slots:
.arg(QString('.').repeated(qrand() % 10)));
qDebug() << "NewTask::newtaskMessage " << message;
exchange_->publish(message, queue_->name(), properties);
exchange_->publish(queue_->name(), message, properties);
}
private: