mirror of https://github.com/dapr/quickstarts.git
26 lines
699 B
JavaScript
26 lines
699 B
JavaScript
import { DaprClient } from "@dapr/dapr";
|
|
|
|
const daprHost = process.env.DAPR_HOST || "http://localhost";
|
|
const daprPort = process.env.DAPR_HTTP_PORT || "3500";
|
|
const pubSubName = "orderpubsub";
|
|
const pubSubTopic = "orders";
|
|
|
|
async function main() {
|
|
const client = new DaprClient({ daprHost, daprPort });
|
|
|
|
for (var i = 1; i <= 10; i++) {
|
|
const order = { orderId: i };
|
|
|
|
// Publish an event using Dapr pub/sub
|
|
await client.pubsub.publish(pubSubName, pubSubTopic, order);
|
|
console.log("Published data: " + JSON.stringify(order));
|
|
|
|
await sleep(1000);
|
|
}
|
|
}
|
|
async function sleep(ms) {
|
|
return new Promise(resolve => setTimeout(resolve, ms));
|
|
}
|
|
|
|
main().catch(e => console.error(e));
|