Browse Source

#61 fixed subscriptionDropped being called only once

Added subscribe-all-from-events sample to test
master
Nicolas Dextraze 4 years ago
parent
commit
c1f17a7d99
  1. 50
      samples/subscribe-all-from-events.js
  2. 2
      src/eventStoreCatchUpSubscription.js

50
samples/subscribe-all-from-events.js

@ -0,0 +1,50 @@
const client = require('../src/client');
//const client = require("node-eventstore-client");
const resolveLinkTos = true;
function resumeEvent(event) {
return [
event.originalEvent.eventType,
[event.originalEventNumber.toNumber(), event.originalStreamId].join('@'),
event.originalPosition
].join(" ")
}
const eventAppeared = (subscription, event) => console.log("Event received", resumeEvent(event));
const subscriptionDropped = (subscription, reason, error) => console.log("Subscription dropped", reason, error);
const libeProcessingStarted = () => console.log("Live processing started.");
const credentials = new client.UserCredentials("admin", "changeit");
const settings = {};
const endpoint = "tcp://localhost:1113";
const connection = client.createConnection(settings, endpoint);
connection.connect().catch(err => console.log("Connection failed", err));
connection.on('heartbeatInfo', heartbeatInfo =>
console.log('Heartbeat latency', heartbeatInfo.responseReceivedAt - heartbeatInfo.requestSentAt, 'ms')
);
connection.once("connected", tcpEndPoint => {
console.log(`Connected to eventstore at ${tcpEndPoint.host}:${tcpEndPoint.port}`);
connection.subscribeToAllFrom(
null,
resolveLinkTos,
eventAppeared,
libeProcessingStarted,
subscriptionDropped,
credentials
);
});
connection.on("error", error =>
console.log(`Error occurred on connection: ${error}`)
)
connection.on("closed", reason =>
console.log(`Connection closed, reason: ${reason}`)
)

2
src/eventStoreCatchUpSubscription.js

@ -127,6 +127,8 @@ EventStoreCatchUpSubscription.prototype._runSubscription = function() {
var self = this;
this._stopped = false;
this._isDropped = false;
this._dropData = null;
if (this._verbose) this._log.debug("Catch-up Subscription to %s: pulling events...", logStreamName);
this._readEventsTill(this._connection, this._resolveLinkTos, this._userCredentials, null, null)
.then(function() {

Loading…
Cancel
Save