2 lines
16 KiB
Plaintext
2 lines
16 KiB
Plaintext
|
||
"smart_sources:000-inbox/clippings/2024/07/Getting started.md": {"path":"000-inbox/clippings/2024/07/Getting started.md","last_embed":{"hash":null},"embeddings":{},"last_read":{"hash":"16pzyk3","at":1766986878407},"class_name":"SmartSource","last_import":{"mtime":1720452816000,"size":33929,"at":1766986878957,"hash":"16pzyk3"},"blocks":{"#---frontmatter---":[1,5],"#":[7,24],"##{1}":[11,11],"##{2}":[12,12],"##{3}":[13,13],"##{4}":[14,14],"##{5}":[15,15],"##{6}":[16,16],"##{7}":[17,17],"##{8}":[18,18],"##{9}":[19,19],"##{10}":[20,20],"##{11}":[21,21],"##{12}":[22,22],"##{13}":[23,24],"###What is Watermill?":[25,32],"###What is Watermill?#{1}":[27,32],"###Why use Watermill?":[33,40],"###Why use Watermill?#{1}":[35,40],"###Install":[41,46],"###Install#{1}":[43,46],"###One Minute Background":[47,66],"###One Minute Background#{1}":[49,66],"###Subscribing for Messages":[67,613],"###Subscribing for Messages#{1}":[69,84],"###Subscribing for Messages#{2}":[85,85],"###Subscribing for Messages#{3}":[86,86],"###Subscribing for Messages#{4}":[87,87],"###Subscribing for Messages#{5}":[88,88],"###Subscribing for Messages#{6}":[89,89],"###Subscribing for Messages#{7}":[90,91],"###Subscribing for Messages#{8}":[92,137],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#docker)":[138,245],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#docker)#{1}":[140,245],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#nats-streaming-docker)":[246,339],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#nats-streaming-docker)#{1}":[248,339],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#gcloud-streaming-docker)":[340,432],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#gcloud-streaming-docker)#{1}":[342,432],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#amqp-docker)":[433,519],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#amqp-docker)#{1}":[435,519],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#sql-docker)":[520,613],"###Subscribing for Messages#[Running in Docker ▾](https://watermill.io/docs/getting-started/#sql-docker)#{1}":[522,613],"###Creating Messages":[614,623],"###Creating Messages#{1}":[616,623],"###Publishing Messages":[624,836],"###Publishing Messages#{1}":[626,634],"###Publishing Messages#{2}":[635,635],"###Publishing Messages#{3}":[636,636],"###Publishing Messages#{4}":[637,637],"###Publishing Messages#{5}":[638,638],"###Publishing Messages#{6}":[639,639],"###Publishing Messages#{7}":[640,641],"###Publishing Messages#{8}":[642,836],"###Using *Message Router*":[837,844],"###Using *Message Router*#{1}":[839,844],"###Example application of *Message Router*":[845,1029],"###Example application of *Message Router*#{1}":[847,848],"###Example application of *Message Router*#{2}":[849,849],"###Example application of *Message Router*#{3}":[850,850],"###Example application of *Message Router*#{4}":[851,851],"###Example application of *Message Router*#{5}":[852,853],"###Example application of *Message Router*#Router configuration":[854,965],"###Example application of *Message Router*#Router configuration#{1}":[856,965],"###Example application of *Message Router*#Incoming messages":[966,990],"###Example application of *Message Router*#Incoming messages#{1}":[968,990],"###Example application of *Message Router*#Handlers":[991,1023],"###Example application of *Message Router*#Handlers#{1}":[993,994],"###Example application of *Message Router*#Handlers#{2}":[995,995],"###Example application of *Message Router*#Handlers#{3}":[996,997],"###Example application of *Message Router*#Handlers#{4}":[998,1023],"###Example application of *Message Router*#Done!":[1024,1029],"###Example application of *Message Router*#Done!#{1}":[1026,1029],"###Logging":[1030,1033],"###Logging#{1}":[1032,1033],"###Testing":[1034,1037],"###Testing#{1}":[1036,1037],"###Deployment":[1038,1041],"###Deployment#{1}":[1040,1041],"###What’s next?":[1042,1060],"###What’s next?#{1}":[1044,1045],"###What’s next?#Examples":[1046,1057],"###What’s next?#Examples#{1}":[1048,1057],"###What’s next?#Support":[1058,1060],"###What’s next?#Support#{1}":[1060,1060]},"outlinks":[{"title":"What is Watermill?","target":"https://watermill.io/docs/getting-started/#what-is-watermill","line":11},{"title":"Why use Watermill?","target":"https://watermill.io/docs/getting-started/#why-use-watermill","line":12},{"title":"Install","target":"https://watermill.io/docs/getting-started/#install","line":13},{"title":"One Minute Background","target":"https://watermill.io/docs/getting-started/#one-minute-background","line":14},{"title":"Subscribing for Messages","target":"https://watermill.io/docs/getting-started/#subscribing-for-messages","line":15},{"title":"Creating Messages","target":"https://watermill.io/docs/getting-started/#creating-messages","line":16},{"title":"Publishing Messages","target":"https://watermill.io/docs/getting-started/#publishing-messages","line":17},{"title":"Using Message Router","target":"https://watermill.io/docs/getting-started/#using-message-router","line":18},{"title":"Example application of Message Router","target":"https://watermill.io/docs/getting-started/#example-application-of-message-router","line":19},{"title":"Logging","target":"https://watermill.io/docs/getting-started/#logging","line":20},{"title":"Testing","target":"https://watermill.io/docs/getting-started/#testing","line":21},{"title":"Deployment","target":"https://watermill.io/docs/getting-started/#deployment","line":22},{"title":"What’s next?","target":"https://watermill.io/docs/getting-started/#whats-next","line":23},{"title":"publishers and subscribers","target":"https://watermill.io/pubsubs/","line":49},{"title":"*Message*","target":"https://watermill.io/docs/message/","line":51},{"title":"Go Channel","target":"https://watermill.io/docs/getting-started/#subscribing_go-channel","line":85},{"title":"Kafka","target":"https://watermill.io/docs/getting-started/#subscribing_kafka","line":86},{"title":"NATS Streaming","target":"https://watermill.io/docs/getting-started/#subscribing_nats-streaming","line":87},{"title":"Google Cloud Pub/Sub","target":"https://watermill.io/docs/getting-started/#subscribing_gcloud","line":88},{"title":"RabbitMQ (AMQP)","target":"https://watermill.io/docs/getting-started/#subscribing_amqp","line":89},{"title":"SQL","target":"https://watermill.io/docs/getting-started/#subscribing_sql","line":90},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/go-channel/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/go-channel/main.go#L2","line":92},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/go-channel/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/go-channel/main.go#L42","line":123},{"title":"Running in Docker ▾","target":"https://watermill.io/docs/getting-started/#docker","line":138},{"title":"\\_examples/pubsubs/kafka/docker-compose.yml","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/kafka/docker-compose.yml","line":142},{"title":"*Go Docker dev environment* article","target":"https://threedots.tech/post/go-docker-dev-environment-with-go-modules-and-live-code-reloading/","line":184},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/kafka/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/kafka/main.go#L2","line":186},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/kafka/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/kafka/main.go#L67","line":231},{"title":"Running in Docker ▾","target":"https://watermill.io/docs/getting-started/#nats-streaming-docker","line":246},{"title":"\\_examples/pubsubs/nats-streaming/docker-compose.yml","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/nats-streaming/docker-compose.yml","line":250},{"title":"*Go Docker dev environment* article","target":"https://threedots.tech/post/go-docker-dev-environment-with-go-modules-and-live-code-reloading/","line":275},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/nats-streaming/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/nats-streaming/main.go#L2","line":277},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/nats-streaming/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/nats-streaming/main.go#L74","line":325},{"title":"Running in Docker ▾","target":"https://watermill.io/docs/getting-started/#gcloud-streaming-docker","line":340},{"title":"\\_examples/pubsubs/googlecloud/docker-compose.yml","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/googlecloud/docker-compose.yml","line":344},{"title":"*Go Docker dev environment* article","target":"https://threedots.tech/post/go-docker-dev-environment-with-go-modules-and-live-code-reloading/","line":373},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/googlecloud/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/googlecloud/main.go#L2","line":375},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/googlecloud/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/googlecloud/main.go#L61","line":418},{"title":"Running in Docker ▾","target":"https://watermill.io/docs/getting-started/#amqp-docker","line":433},{"title":"\\_examples/pubsubs/amqp/docker-compose.yml","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/amqp/docker-compose.yml","line":435},{"title":"*Go Docker dev environment* article","target":"https://threedots.tech/post/go-docker-dev-environment-with-go-modules-and-live-code-reloading/","line":460},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/amqp/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/amqp/main.go#L2","line":462},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/amqp/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/amqp/main.go#L59","line":505},{"title":"Running in Docker ▾","target":"https://watermill.io/docs/getting-started/#sql-docker","line":520},{"title":"\\_examples/pubsubs/sql/docker-compose.yml","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/sql/docker-compose.yml","line":522},{"title":"*Go Docker dev environment* article","target":"https://threedots.tech/post/go-docker-dev-environment-with-go-modules-and-live-code-reloading/","line":552},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/sql/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/sql/main.go#L2","line":554},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/sql/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/sql/main.go#L87","line":599},{"title":"Go Channel","target":"https://watermill.io/docs/getting-started/#publishing_go-channel","line":635},{"title":"Kafka","target":"https://watermill.io/docs/getting-started/#publishing_kafka","line":636},{"title":"NATS Streaming","target":"https://watermill.io/docs/getting-started/#publishing_nats-streaming","line":637},{"title":"Google Cloud Pub/Sub","target":"https://watermill.io/docs/getting-started/#publishing_gcloud","line":638},{"title":"RabbitMQ (AMQP)","target":"https://watermill.io/docs/getting-started/#publishing_amqp","line":639},{"title":"SQL","target":"https://watermill.io/docs/getting-started/#publishing_sql","line":640},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/go-channel/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/go-channel/main.go#L25","line":642},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/kafka/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/kafka/main.go#L39","line":663},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/nats-streaming/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/nats-streaming/main.go#L42","line":695},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/googlecloud/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/googlecloud/main.go#L37","line":731},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/amqp/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/amqp/main.go#L37","line":759},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/pubsubs/sql/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/pubsubs/sql/main.go#L39","line":785},{"title":"correlation, metrics, poison queue, retrying, throttling, etc.","target":"https://watermill.io/docs/messages-router/#middleware","line":839},{"title":"*Publishers and subscribers*","target":"https://watermill.io/docs/pub-sub/","line":839},{"title":"*Router*","target":"https://watermill.io/docs/messages-router/","line":843},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/basic/3-router/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/basic/3-router/main.go#L2","line":858},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/basic/3-router/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/basic/3-router/main.go#L103","line":970},{"title":"github.com/ThreeDotsLabs/watermill/\\_examples/basic/3-router/main.go","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/basic/3-router/main.go#L118","line":1000},{"title":"/\\_examples/basic/3-router/main.go","target":"https://github.com/ThreeDotsLabs/watermill/blob/master/_examples/basic/3-router/main.go","line":1028},{"title":"LoggerAdapter","target":"https://github.com/ThreeDotsLabs/watermill/blob/master/log.go","line":1032},{"title":"a set of test scenarios","target":"https://github.com/ThreeDotsLabs/watermill/blob/master/pubsub/tests/test_pubsub.go","line":1036},{"title":"documentation topics","target":"https://watermill.io/docs/","line":1044},{"title":"examples","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples","line":1048},{"title":"Your first Watermill application","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/basic/1-your-first-app","line":1050},{"title":"Realtime feed","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/basic/2-realtime-feed","line":1052},{"title":"receiving-webhooks","target":"https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/real-world-examples/receiving-webhooks","line":1054},{"title":"README","target":"https://github.com/ThreeDotsLabs/watermill#examples","line":1056},{"title":"support channels","target":"https://watermill.io/support/","line":1060}],"metadata":{"page-title":"Getting started","url":"https://watermill.io/docs/getting-started/#subscribing_nats-streaming","date":"2024-07-08 23:33:34"},"task_lines":[],"tasks":{},"codeblock_ranges":[[43,45],[55,65],[71,81],[94,121],[125,136],[144,178],[188,229],[233,244],[252,269],[279,323],[327,338],[346,367],[377,416],[420,431],[437,454],[464,503],[507,518],[524,546],[556,597],[601,612],[620,622],[628,633],[644,661],[665,693],[697,729],[733,757],[761,783],[787,835],[860,964],[972,989],[1002,1022]]}, |