dapr
/
docs
mirror of https://github.com/dapr/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

resolved merge conflicts 

Signed-off-by: Amulya Varote <amulyavarote@Amulyas-MacBook-Pro.local>
This commit is contained in:
Amulya Varote 2021-12-08 22:35:22 -08:00
parent bd6d5e75af
commit 099ea6e99d
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
daprdocs/content/en/developing-applications/building-blocks/pubsub/howto-publish-subscribe.md
View File

@ -986,6 +986,7 @@ dapr run --app-id orderprocessing --app-port 6001 --dapr-http-port 3601 --dapr-g
//dependencies //dependencies
import { DaprServer, DaprClient, CommunicationProtocolEnum } from 'dapr-client'; import { DaprServer, DaprClient, CommunicationProtocolEnum } from 'dapr-client';
//code
const daprHost = "127.0.0.1"; const daprHost = "127.0.0.1";
<<<<<<< HEAD <<<<<<< HEAD
@ -1041,11 +1042,10 @@ var main = function() {
>>>>>>> 0008ac3b (Modified based on the review comments - 1) >>>>>>> 0008ac3b (Modified based on the review comments - 1)
async function start(orderId) { async function start(orderId) {
const PUBSUB_NAME = "order_pub_sub"
const TOPIC_NAME = "orders"
const client = new DaprClient(daprHost, process.env.DAPR_HTTP_PORT, CommunicationProtocolEnum.HTTP); const client = new DaprClient(daprHost, process.env.DAPR_HTTP_PORT, CommunicationProtocolEnum.HTTP);
console.log("Published data:" + orderId) console.log("Published data:" + orderId)
//Using Dapr SDK to publish a topic //Using Dapr SDK to publish a topic
<<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
await server.pubsub.subscribe(PUBSUB_NAME, TOPIC_NAME, async (orderId) => { await server.pubsub.subscribe(PUBSUB_NAME, TOPIC_NAME, async (orderId) => {
console.log(`Subscriber received: ${JSON.stringify(orderId)}`) console.log(`Subscriber received: ${JSON.stringify(orderId)}`)
@ -1055,6 +1055,9 @@ async function start(orderId) {
======= =======
await client.pubsub.publish(PUBSUB_NAME, TOPIC_NAME, orderId); await client.pubsub.publish(PUBSUB_NAME, TOPIC_NAME, orderId);
>>>>>>> 0008ac3b (Modified based on the review comments - 1) >>>>>>> 0008ac3b (Modified based on the review comments - 1)
=======
await client.pubsub.publish("order_pub_sub", "orders", orderId);
>>>>>>> 56e9c801 (resolved merge conflicts)
} }
function sleep(ms) { function sleep(ms) {