使用 JSForce 的 Salesforce 事件订阅

Salesforce event subscription using JSForce

我正在尝试订阅 salesforce 主题生成的事件。我能够接收事件,我的节点应用程序无法读取队列中的事件,“在我的节点应用程序启动之前生成并且 运行”。它能够接收节点 js 应用程序启动后生成的事件。

我的代码是这样的

var jsforce = require('jsforce');
var conn = new jsforce.Connection(loginUrl:sfHost);
conn.login(userId, pwd, function(err: userInfo){
  if(err){return console.log(err); }
  console.log("Connected");
  conn.streaming.topic("eventName").subscribe(function(message){
    console.log(message);
  }
}

以上代码可以获取节点应用启动后生成的数据,运行,无法读取队列中的任何数据。这是较早生成的,未使用任何应用程序读取。

感谢您为此付出的帮助和时间。

有一个读取旧事件的进程,使用回复 id...

var jsforce = require('jsforce');
var conn = new jsforce.Connection(loginUrl:sfHost);

conn.login(userId, pwd, function(err: userInfo) {
    const replayId = -2; // -2 is all retained events
    const replayExt = new jsforce.StreamingExtension.Replay(channel, replayId);
    const fayeClient = conn.streaming.createClient([ replayExt ]);

    if(err) { return console.log(err); }

    console.log("Connected");

    const subscription = fayeClient.subscribe(channel, data => {
        console.log('topic received data', data);
    });
}

更多信息请查看https://github.com/jsforce/jsforce/blob/master/build/jsforce-api-streaming.js

https://developer.salesforce.com/docs/atlas.en-us.api_streaming.meta/api_streaming/using_streaming_api_durability.htm