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

Modified based on the review comments - 1 

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

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

@ -545,6 +545,11 @@ The `/checkout` endpoint matches the `route` defined in the subscriptions and th
## Step 3: Publish a topic ## Step 3: Publish a topic
<<<<<<< HEAD
=======
To publish a topic you need to run an instance of a Dapr sidecar to use RabbitMQ component. You can use the default Redis component installed into your local environment.
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
Start an instance of Dapr with an app-id called `orderprocessing`: Start an instance of Dapr with an app-id called `orderprocessing`:
```bash ```bash
@ -567,6 +572,7 @@ Then publish a message to the `orders` topic:
```bash ```bash
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD
dapr publish --publish-app-id orderprocessing --pubsub order_pub_sub --topic orders --data '{"orderId": "100"}' dapr publish --publish-app-id orderprocessing --pubsub order_pub_sub --topic orders --data '{"orderId": "100"}'
======= =======
dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data '{"orderId": "100"}' dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data '{"orderId": "100"}'
@ -574,6 +580,12 @@ dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data '
======= =======
dapr publish --publish-app-id orderprocessing --pubsub order_pub_sub --topic orders --data '{"orderId": "100"}' dapr publish --publish-app-id orderprocessing --pubsub order_pub_sub --topic orders --data '{"orderId": "100"}'
>>>>>>> f26f475c (Fix publish a topic examples) >>>>>>> f26f475c (Fix publish a topic examples)
=======
dapr publish --publish-app-id orderprocessing --pubsub order_pub_sub --topic orders --data '{"orderId": "100"}'
=======
dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data 100
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -582,6 +594,7 @@ Then publish a message to the `orders` topic:
```bash ```bash
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD
curl -X POST http://localhost:3601/v1.0/publish/order_pub_sub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}' curl -X POST http://localhost:3601/v1.0/publish/order_pub_sub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}'
======= =======
curl -X POST http://localhost:3601/v1.0/publish/pubsub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}' curl -X POST http://localhost:3601/v1.0/publish/pubsub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}'
@ -589,6 +602,12 @@ curl -X POST http://localhost:3601/v1.0/publish/pubsub/orders -H "Content-Type:
======= =======
curl -X POST http://localhost:3601/v1.0/publish/order_pub_sub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}' curl -X POST http://localhost:3601/v1.0/publish/order_pub_sub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}'
>>>>>>> f26f475c (Fix publish a topic examples) >>>>>>> f26f475c (Fix publish a topic examples)
=======
curl -X POST http://localhost:3601/v1.0/publish/order_pub_sub/orders -H "Content-Type: application/json" -d '{"orderId": "100"}'
=======
curl -X POST http://localhost:3601/v1.0/publish/pubsub/orders -H "Content-Type: application/json" -d 100
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -597,6 +616,7 @@ Then publish a message to the `orders` topic:
```powershell ```powershell
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/order_pub_sub/orders' Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/order_pub_sub/orders'
======= =======
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/pubsub/orders' Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/pubsub/orders'
@ -604,6 +624,12 @@ Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId"
======= =======
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/order_pub_sub/orders' Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/order_pub_sub/orders'
>>>>>>> f26f475c (Fix publish a topic examples) >>>>>>> f26f475c (Fix publish a topic examples)
=======
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId": "100"}' -Uri 'http://localhost:3601/v1.0/publish/order_pub_sub/orders'
=======
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body 100 -Uri 'http://localhost:3601/v1.0/publish/pubsub/orders'
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -986,7 +1012,6 @@ 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
@ -1042,6 +1067,7 @@ 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) {
<<<<<<< HEAD
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
@ -1057,7 +1083,18 @@ async function start(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); await client.pubsub.publish("order_pub_sub", "orders", orderId);
<<<<<<< HEAD
>>>>>>> 56e9c801 (resolved merge conflicts) >>>>>>> 56e9c801 (resolved merge conflicts)
=======
=======
const PUBSUB_NAME = "order_pub_sub"
const TOPIC_NAME = "orders"
const client = new DaprClient(daprHost, process.env.DAPR_HTTP_PORT, CommunicationProtocolEnum.HTTP);
console.log("Published data:" + orderId)
//Using Dapr SDK to publish a topic
await client.pubsub.publish(PUBSUB_NAME, TOPIC_NAME, orderId);
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1)
} }
function sleep(ms) { function sleep(ms) {