使用 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
我正在尝试订阅 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