nodeEventStore 发布两次

Question

我是事件源的新手，我正在使用nodeEventStore。

所以我写了以下简单的测试控制台应用程序，我发现该事件会发布两次，谁能帮我弄清楚为什么？谢谢。

var eventstore = require('eventstore');
var storage = require('eventstore.mongoDb');
var async = require('async');

publisher = {
    publish: function(evt) {
        console.log('publishing: ');
        console.log(evt);
    }
}

var es = eventstore.createStore();

var store = storage.createStorage({
    host: 'localhost',
    port: 27017,
    db: 'es'
});

es.configure(function() {
    es.use(store);
    es.use(publisher);
}).start();

async.series([
    function(cb) {store.connect(function(){cb(null);})},
    function(cb) {
        es.getEventStream('1', 0, function(err, stream) {
            stream.addEvent({id: '1', event:'add', payload:{}});
            stream.commit();
            cb(null);
        });
    }
]);

上面的输出是预期的两倍：

publishing:
{ id: '1', event: 'add', payload: {} }
publishing:
{ id: '1', event: 'add', payload: {} }

顺便说一句，如果我在下面的 createStorage 中连接，它就可以正常工作：

var eventstore = require('eventstore');
var storage = require('eventstore.mongoDb');
var async = require('async');

publisher = {
    publish: function(evt) {
        console.log('publishing: ');
        console.log(evt);
    }
}

var es = eventstore.createStore();

async.series([
    function(cb) {
        storage.createStorage({
            host: 'localhost',
            port: 27017,
            dbName: 'es'
        }, function(err, store) {
            es.configure(function() {
                es.use(store);
                es.use(publisher);
            });
            es.start();
            cb(null);
        });
    },
    function(cb) {
        es.getEventStream('1', 0, function(err, stream) {
            stream.addEvent({id: '1', event:'add', payload:{}});
            stream.commit();
            cb(null);
        });
    }
]);

Answer 1

你不需要调用 connect...

而不是调用：

store.connect(function(){cb(null);})

我会打电话给：

es.start(function(){cb(null);})

配置后不调用 es.start。