mirror of https://github.com/dapr/quickstarts.git
17 lines
638 B
JavaScript
17 lines
638 B
JavaScript
import { DaprServer } from 'dapr-client';
|
|
|
|
const DAPR_HOST = process.env.DAPR_HOST || "http://localhost";
|
|
const DAPR_HTTP_PORT = process.env.DAPR_HTTP_PORT || "3501";
|
|
const SERVER_HOST = process.env.SERVER_HOST || "127.0.0.1";
|
|
const SERVER_PORT = process.env.SERVER_PORT || 5001;
|
|
|
|
async function main() {
|
|
const server = new DaprServer(SERVER_HOST, SERVER_PORT, DAPR_HOST, DAPR_HTTP_PORT);
|
|
|
|
// Dapr subscription routes orders topic to this route
|
|
server.pubsub.subscribe("order_pub_sub", "orders", (data) => console.log("Subscriber received: " + JSON.stringify(data)));
|
|
|
|
await server.start();
|
|
}
|
|
|
|
main().catch(e => console.error(e)); |