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 efbf2e0ebb
commit caf849f973
1 changed files with 36 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -576,6 +576,7 @@ The `/checkout` endpoint matches the `route` defined in the subscriptions and th
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD
======= =======
======= =======
>>>>>>> e4e78805 (Modified based on the review comments - 1) >>>>>>> e4e78805 (Modified based on the review comments - 1)
@ -584,6 +585,10 @@ To publish a topic you need to run an instance of a Dapr sidecar to use RabbitMQ
>>>>>>> e67fd5fd (Modified based on the review comments - 1) >>>>>>> e67fd5fd (Modified based on the review comments - 1)
======= =======
>>>>>>> 1e8d79ce (Removed a line) >>>>>>> 1e8d79ce (Removed a line)
=======
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
@ -607,6 +612,7 @@ Then publish a message to the `orders` topic:
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< 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"}'
@ -620,6 +626,9 @@ dapr publish --publish-app-id orderprocessing --pubsub order_pub_sub --topic ord
dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data 100 dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data 100
>>>>>>> e67fd5fd (Modified based on the review comments - 1) >>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1) >>>>>>> 91002c8f (Modified based on the review comments - 1)
=======
dapr publish --publish-app-id testpubsub --pubsub pubsub --topic orders --data 100
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -629,6 +638,7 @@ Then publish a message to the `orders` topic:
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< 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"}'
@ -642,6 +652,9 @@ curl -X POST http://localhost:3601/v1.0/publish/order_pub_sub/orders -H "Content
curl -X POST http://localhost:3601/v1.0/publish/pubsub/orders -H "Content-Type: application/json" -d 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) >>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1) >>>>>>> 91002c8f (Modified based on the review comments - 1)
=======
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)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -651,6 +664,7 @@ Then publish a message to the `orders` topic:
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< 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'
@ -664,6 +678,9 @@ Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '{"orderId"
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body 100 -Uri 'http://localhost:3601/v1.0/publish/pubsub/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) >>>>>>> e67fd5fd (Modified based on the review comments - 1)
>>>>>>> 91002c8f (Modified based on the review comments - 1) >>>>>>> 91002c8f (Modified based on the review comments - 1)
=======
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)
``` ```
{{% /codetab %}} {{% /codetab %}}
@ -1196,17 +1213,16 @@ dapr run --app-id orderprocessing --app-port 6001 --dapr-http-port 3601 --dapr-g
```javascript ```javascript
//dependencies //dependencies
import { DaprServer, CommunicationProtocolEnum } from 'dapr-client'; import { DaprServer, DaprClient, CommunicationProtocolEnum } from 'dapr-client';
const daprHost = "127.0.0.1"; const daprHost = "127.0.0.1";
const serverHost = "127.0.0.1";
const serverPort = "6002";
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD
var main = function() { var main = function() {
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD <<<<<<< HEAD
@ -1247,6 +1263,8 @@ start().catch((e) => {
======= =======
======= =======
>>>>>>> e4e78805 (Modified based on the review comments - 1) >>>>>>> e4e78805 (Modified based on the review comments - 1)
=======
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
var main = function() { var main = function() {
for(var i=0;i<10;i++) { for(var i=0;i<10;i++) {
sleep(5000); sleep(5000);
@ -1258,6 +1276,7 @@ var main = function() {
} }
} }
<<<<<<< HEAD <<<<<<< HEAD
<<<<<<< HEAD
>>>>>>> 0008ac3b (Modified based on the review comments - 1) >>>>>>> 0008ac3b (Modified based on the review comments - 1)
async function start(orderId) { async function start(orderId) {
@ -1288,18 +1307,16 @@ start().catch((e) => {
console.error(e); console.error(e);
process.exit(1); process.exit(1);
}); });
=======
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
async function start(orderId) { async function start(orderId) {
const PUBSUB_NAME = "order_pub_sub" const PUBSUB_NAME = "order_pub_sub"
const TOPIC_NAME = "orders" const TOPIC_NAME = "orders"
const server = new DaprServer( const client = new DaprClient(daprHost, process.env.DAPR_HTTP_PORT, CommunicationProtocolEnum.HTTP);
serverHost, console.log("Published data:" + orderId)
serverPort,
daprHost,
process.env.DAPR_HTTP_PORT,
CommunicationProtocolEnum.HTTP
);
//Using Dapr SDK to publish a topic //Using Dapr SDK to publish a topic
<<<<<<< HEAD
>>>>>>> 08f856a0 (Added full code snippets of pub sub) >>>>>>> 08f856a0 (Added full code snippets of pub sub)
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)}`)
@ -1339,15 +1356,23 @@ main();
await client.pubsub.publish(PUBSUB_NAME, TOPIC_NAME, orderId); await client.pubsub.publish(PUBSUB_NAME, TOPIC_NAME, orderId);
} }
=======
await client.pubsub.publish(PUBSUB_NAME, TOPIC_NAME, orderId);
}
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
function sleep(ms) { function sleep(ms) {
return new Promise(resolve => setTimeout(resolve, ms)); return new Promise(resolve => setTimeout(resolve, ms));
} }
main(); main();
<<<<<<< HEAD
>>>>>>> e4e78805 (Modified based on the review comments - 1) >>>>>>> e4e78805 (Modified based on the review comments - 1)
======= =======
} }
>>>>>>> 08f856a0 (Added full code snippets of pub sub) >>>>>>> 08f856a0 (Added full code snippets of pub sub)
=======
>>>>>>> e67fd5fd (Modified based on the review comments - 1)
``` ```
Navigate to the directory containing the above code, then run the following command to launch a Dapr sidecar and run the application: Navigate to the directory containing the above code, then run the following command to launch a Dapr sidecar and run the application: