archive-gh-me/log4js-node
1
0
Fork 0
mirror of https://github.com/log4js-node/log4js-node.git synced 2025-12-08 19:26:01 +00:00
Code Issues Projects Releases Wiki Activity

update rabbitmqAppender test

Browse Source
This commit is contained in:
Anteoy 2018-01-16 23:20:56 +08:00
parent c5eff80e2a
commit c4bd2cb81f
2 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/appenders/rabbitmq.js
View File

@ -27,7 +27,7 @@ function rabbitmqAppender(config, layout) {
durable: durable,
};
const clientconn = amqplib.connect(con);
clientconn.publish = (client, message) => {
clientconn.publish = amqplib.connect(con).publish ? amqplib.connect(con).publish : (client, message) => {
client.then((conn) => {
const rn = conn.createChannel().then((ch) => {
const ok = ch.assertExchange(exchange, type, { durable: durable });

17
test/tap/rabbitmqAppender-test.js
View File

@ -15,12 +15,11 @@ function setupLogging(category, options) {
this.exchange = conn.exchange;
this.mq_type = conn.mq_type;
this.durable = conn.durable;
const rn = new Promise(() => {
});
rn.publish = (client, message) => {
fakeRabbitmq.msgs.push(message);
return {
publish: function (client, message) {
fakeRabbitmq.msgs.push(message);
}
};
return rn;
}
};
@ -80,8 +79,8 @@ test('log4js rabbitmqAppender', (batch) => {
assert.equal(result.fakeRabbitmq.exchange, 'exchange_logs');
assert.equal(result.fakeRabbitmq.mq_type, 'direct');
assert.equal(result.fakeRabbitmq.durable, true);
// assert.equal(result.fakeRabbitmq.msgs.length, 1, 'should be one message only');
// assert.equal(result.fakeRabbitmq.msgs[0], 'cheese Log event #1');
assert.equal(result.fakeRabbitmq.msgs.length, 1, 'should be one message only');
assert.equal(result.fakeRabbitmq.msgs[0], 'cheese Log event #1');
assert.end();
});
@ -108,8 +107,8 @@ test('log4js rabbitmqAppender', (batch) => {
});
t.test('should use message pass through layout', (assert) => {
// assert.equal(setup.fakeRabbitmq.msgs.length, 1);
// assert.equal(setup.fakeRabbitmq.msgs[0], 'just testing');
assert.equal(setup.fakeRabbitmq.msgs.length, 1);
assert.equal(setup.fakeRabbitmq.msgs[0], 'just testing');
assert.end();
});