关闭回显消息(Echo)
// 关闭回显
nc, err := nats.Connect("demo.nats.io", nats.Name("API NoEcho Example"), nats.NoEcho())
if err != nil {
log.Fatal(err)
}
defer nc.Close()
// 使用连接做点事情Options options = new Options.Builder()
.server("nats://demo.nats.io:4222")
.noEcho() // 关闭回显
.build();
Connection nc = Nats.connect(options);
// 使用连接做点事情
nc.close();const nc = await connect({
servers: ["demo.nats.io"],
noEcho: true,
});
const sub = nc.subscribe(subj, { callback: (_err, _msg) => {} });
nc.publish(subj);
await sub.drain();
// 我们不会收到自己的消息
t.is(sub.getProcessed(), 0);最后更新于