mirror of https://github.com/dapr/quickstarts.git
25 lines
588 B
JavaScript
25 lines
588 B
JavaScript
import express from 'express';
|
|
import bodyParser from 'body-parser';
|
|
|
|
const APP_PORT = process.env.APP_PORT ?? '5003';
|
|
|
|
const app = express();
|
|
app.use(bodyParser.json({ type: 'application/*+json' }));
|
|
|
|
app.get('/dapr/subscribe', (_req, res) => {
|
|
res.json([
|
|
{
|
|
pubsubname: "orderpubsub",
|
|
topic: "orders",
|
|
route: "orders"
|
|
}
|
|
]);
|
|
});
|
|
|
|
// Dapr subscription routes orders topic to this route
|
|
app.post('/orders', (req, res) => {
|
|
console.log("Subscriber received:", req.body.data);
|
|
res.sendStatus(200);
|
|
});
|
|
|
|
app.listen(APP_PORT); |