hub / github.com/ThreeDotsLabs/watermill-amqp

github.com/ThreeDotsLabs/watermill-amqp @v3.1.0

Chat with this repo

repository ↗ · DeepWiki ↗ · release v3.1.0 ↗ · + Follow

156 symbols 429 edges 15 files 33 documented · 21% 1 cross-repo links ● updated 55d agov3.1.0 · 2026-05-14★ 60

What it actually does AI analysis from the code graph — generated when you open this

loading…

README

Watermill AMQP Pub/Sub

This is Pub/Sub for the Watermill project.

See DEVELOPMENT.md for more information about running and testing.

Watermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling event sourcing, RPC over messages, sagas and basically whatever else comes to your mind. You can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog if that fits your use case.

All Pub/Sub implementations can be found at https://watermill.io/pubsubs/.

Documentation: https://watermill.io/

Getting started guide: https://watermill.io/docs/getting-started/

Issues: https://github.com/ThreeDotsLabs/watermill/issues

Contributing

All contributions are very much welcome. If you'd like to help with Watermill development, please see open issues and submit your pull request via GitHub.

Support

If you didn't find the answer to your question in the documentation, feel free to ask us directly!

Please join us on the #watermill channel on the Three Dots Labs Discord.

License

MIT License

Extension points exported contracts — how you extend this code

Marshaler (Interface)

Marshaler marshals Watermill's message to amqp.Publishing and unmarshals amqp.Delivery to Watermill's message. [2 implementers]

pkg/amqp/marshaler.go

TopologyBuilder (Interface)

TopologyBuilder is responsible for declaring exchange, queues and queues binding. Default TopologyBuilder is DefaultTop [1 …

pkg/amqp/topology_builder.go

ExchangeNameGenerator (FuncType)

ExchangeNameGenerator generates ExchangeName based on the topic.

pkg/amqp/config.go

QueueNameGenerator (FuncType)

QueueNameGenerator generates QueueName based on the topic.

pkg/amqp/config.go

Core symbols most depended-on inside this repo

called by 11

pkg/amqp/channelprovider.go

NewDurablePubSubConfig

pkg/amqp/marshaler.go

nackMsg

called by 6

pkg/amqp/subscriber.go

Marshal

called by 6

pkg/amqp/correlatingmarshaler.go

NewPublisher

called by 5

pkg/amqp/publisher.go

NewSubscriber

called by 5

pkg/amqp/subscriber.go

Unmarshal

called by 5

pkg/amqp/marshaler.go

Shape

Method 67

Function 62

Struct 21

Interface 4

FuncType 2

Languages

Go100%

Modules by API surface

pkg/amqp/channelprovider.go33 symbols

pkg/amqp/config.go31 symbols

pkg/amqp/pubsub_test.go18 symbols

pkg/amqp/subscriber.go15 symbols

pkg/amqp/connection.go10 symbols

pkg/amqp/publisher.go9 symbols

pkg/amqp/marshaler_test.go9 symbols

pkg/amqp/marshaler.go8 symbols

pkg/amqp/topology_builder.go7 symbols

pkg/amqp/correlatingmarshaler_test.go6 symbols

pkg/amqp/pubsub_stress_test.go3 symbols

pkg/amqp/correlatingmarshaler.go3 symbols

Used by 1 indexed graphs manifest dependencies, hub-wide

github.com/ThreeDotsLabs/watermill

For agents

$ claude mcp add watermill-amqp \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/ThreeDotsLabs/watermill-amqp @v3.1.0

Watermill AMQP Pub/Sub

Contributing

Support

License

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

Used by 1 indexed graphs manifest dependencies, hub-wide

For agents

Ask about this repo answers extend the page