Go to main page
Known importers: 603 (displaying 775 packages, including internal and invalid packages)
- bitbucket.org/lugimanf_/gocommon/mq
- bitbucket.org/napche/workbench/godog/pkg
- gitea.dwysokinski.me/twhelp/core/cmd/twhelp
- gitea.dwysokinski.me/twhelp/core/internal/port/portwatermill
- gitea.dwysokinski.me/twhelp/core/internal/watermill/watermillamqptest
- gitea.dwysokinski.me/twhelp/core/internal/watermill/watermillmsg
- gitea.dwysokinski.me/twhelp/core/internal/watermill/watermilltest
- gitea.programmerfamily.com/go/filewatcher
- github.com/0michalsokolowski0/watermill/_examples/http-to-kafka
- github.com/0michalsokolowski0/watermill/_examples/simple-app/app2
- github.com/0michalsokolowski0/watermill/message
- github.com/0michalsokolowski0/watermill/message/infrastructure/gochannel
- github.com/0michalsokolowski0/watermill/message/infrastructure/http
- github.com/0michalsokolowski0/watermill/message/infrastructure/kafka
- github.com/0michalsokolowski0/watermill/message/router/middleware
- github.com/1layar/universe/internal/account_service/server/watermill
- github.com/1layar/universe/internal/account_service/server/watermill/command
- github.com/1layar/universe/internal/account_service/server/watermill/route
- github.com/1layar/universe/internal/api_gateway/server/watermill
- github.com/1layar/universe/internal/api_gateway/server/watermill/command
- github.com/1layar/universe/internal/auth_service/server/watermill
- github.com/1layar/universe/internal/auth_service/server/watermill/command
- github.com/1layar/universe/internal/auth_service/server/watermill/route
- github.com/1layar/universe/internal/cart_service/server/watermill
- github.com/1layar/universe/internal/cart_service/server/watermill/command
- github.com/1layar/universe/internal/cart_service/server/watermill/route
- github.com/1layar/universe/internal/checkout_service/server/watermill
- github.com/1layar/universe/internal/checkout_service/server/watermill/command
- github.com/1layar/universe/internal/checkout_service/server/watermill/route
- github.com/1layar/universe/internal/email_service/server/watermill
- github.com/1layar/universe/internal/email_service/server/watermill/command
- github.com/1layar/universe/internal/email_service/server/watermill/route
- github.com/1layar/universe/internal/payment_service/server/watermill
- github.com/1layar/universe/internal/payment_service/server/watermill/command
- github.com/1layar/universe/internal/payment_service/server/watermill/route
- github.com/1layar/universe/internal/ppob_service/server/watermill
- github.com/1layar/universe/internal/ppob_service/server/watermill/command
- github.com/1layar/universe/internal/ppob_service/server/watermill/route
- github.com/1layar/universe/internal/product_catalog_service/server/watermill
- github.com/1layar/universe/internal/product_catalog_service/server/watermill/command
- github.com/1layar/universe/internal/product_catalog_service/server/watermill/route
- github.com/1layar/universe/pkg/micromill/broker
- github.com/1layar/universe/pkg/micromill/server
- github.com/AlexCuse/watermill-jetstream/pkg/jetstream
- github.com/ArkjuniorK/gofiber-boilerplate/internal/core
- github.com/Black-And-White-Club/frolf-bot-shared/eventbus
- github.com/Black-And-White-Club/frolf-bot/app
- github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/application
- github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/infrastructure/router
- github.com/Black-And-White-Club/frolf-bot/app/modules/round/application
- github.com/Black-And-White-Club/frolf-bot/app/modules/round/infrastructure/router
- github.com/Black-And-White-Club/frolf-bot/app/modules/score/application
- github.com/Black-And-White-Club/frolf-bot/app/modules/score/infrastructure/router
- github.com/Black-And-White-Club/frolf-bot/app/modules/user/application
- github.com/Black-And-White-Club/frolf-bot/app/modules/user/infrastructure/router
- github.com/Black-And-White-Club/frolf-bot/internal/test
- github.com/Brandon2255p/watermill-eventstore/eventstore
- github.com/DoNewsCode/core-pubsub
- github.com/EraldCaka/broker/pkg/kafka
- github.com/GabrielCarpr/cqrs/bus/queue/sql
- github.com/Goorsky1/dns-mgmt/common/rabbitmq
- github.com/HnH/choreographer/infrastructure
- github.com/Improwised/golang-api/pkg/watermill
- github.com/KirylJazzSax/watermill-eventstore/pkg/esdb
- github.com/MajorLettuce/go-event-bus
- github.com/NpoolPlatform/go-service-framework/pkg/pubsub
- github.com/Planxnx/message-processing-api/alarm-service/internal/router
- github.com/Planxnx/message-processing-api/alarm-service/pkg/connection/kafka
- github.com/Planxnx/message-processing-api/external-caller-service/cmd
- github.com/Planxnx/message-processing-api/external-caller-service/internal/api/messagequeue
- github.com/Planxnx/message-processing-api/external-caller-service/internal/api/messagequeue/message
- github.com/Planxnx/message-processing-api/external-caller-service/pkg/kafka
- github.com/Planxnx/message-processing-api/gateway-service/api/messagequeue
- github.com/Planxnx/message-processing-api/gateway-service/api/restful/message
- github.com/Planxnx/message-processing-api/gateway-service/internal/message
- github.com/Planxnx/message-processing-api/gateway-service/pkg/kafka
- github.com/Planxnx/message-processing-api/scheduler-service/cmd
- github.com/Planxnx/message-processing-api/scheduler-service/internal/api/messagequeue
- github.com/Planxnx/message-processing-api/scheduler-service/internal/api/messagequeue/message
- github.com/Planxnx/message-processing-api/scheduler-service/pkg/connection/kafka
- github.com/Planxnx/message-processing-api/scheduler-service/pkg/cron
- github.com/THreeDotsLabs/watermill/_examples/http-to-kafka
- github.com/THreeDotsLabs/watermill/_examples/simple-app/app2
- github.com/THreeDotsLabs/watermill/message
- github.com/THreeDotsLabs/watermill/message/infrastructure/gochannel
- github.com/THreeDotsLabs/watermill/message/infrastructure/http
- github.com/THreeDotsLabs/watermill/message/infrastructure/kafka
- github.com/THreeDotsLabs/watermill/message/router/middleware
- github.com/ThreeDotsLabs/Watermill/_examples/http-to-kafka
- github.com/ThreeDotsLabs/Watermill/_examples/simple-app/app2
- github.com/ThreeDotsLabs/Watermill/message
- github.com/ThreeDotsLabs/Watermill/message/infrastructure/gochannel
- github.com/ThreeDotsLabs/Watermill/message/infrastructure/http
- github.com/ThreeDotsLabs/Watermill/message/infrastructure/kafka
- github.com/ThreeDotsLabs/Watermill/message/router/middleware
- github.com/ThreeDotsLabs/go-event-driven/common/log
- github.com/ThreeDotsLabs/watermill-benchmark/pkg
- github.com/ThreeDotsLabs/watermill-bolt/pkg/bolt
- github.com/ThreeDotsLabs/watermill-googlecloud/pkg/googlecloud
- github.com/ThreeDotsLabs/watermill-io/pkg/io
- github.com/ThreeDotsLabs/watermill-jetstream/pkg/jetstream
- github.com/ThreeDotsLabs/watermill-redisstream/pkg/redisstream
- github.com/UnAfraid/watermill-googlecloud/pkg/googlecloud
- github.com/Unheilbar/test_kafka
- github.com/ZhanibekTau/go-sdk/pkg/rabbitmq
- github.com/Zondax/zindexer/components/connections/pub_sub
- github.com/acs-dl/auth-svc/internal/config
- github.com/acs-dl/github-module-svc/internal/config
- github.com/acs-dl/gitlab-module-svc/internal/config
- github.com/acs-dl/identity-svc/internal/config
- github.com/acs-dl/mail-module-svc/internal/config
- github.com/acs-dl/orchestrator-svc/internal/config
- github.com/acs-dl/slack-module-svc/internal/config
- github.com/acs-dl/telegram-module-svc/internal/config
- github.com/acs-dl/unverified-svc/internal/config
- github.com/aiocean/wireset/pubsub
- github.com/alexcuse/edgex-watermill/amqp
- github.com/alexcuse/edgex-watermill/nats
- github.com/alexcuse/edgex-watermill/v2/amqp
- github.com/alexcuse/edgex-watermill/v2/core
- github.com/alexcuse/edgex-watermill/v2/googlecloud
- github.com/alexcuse/edgex-watermill/v2/jetstream
- github.com/alexcuse/edgex-watermill/v2/kafka
- github.com/alexcuse/edgex-watermill/v2/nats
- github.com/alexdrl/zerowater
- github.com/alexinteam/nats/cmd
- github.com/andyollylarkin/watermill-net
- github.com/andyollylarkin/watermill-net/examples
- github.com/andyollylarkin/watermill-net/examples/retryable_client
- github.com/andyollylarkin/watermill-net/examples/retryable_server
- github.com/andyollylarkin/watermill-net/examples/tls_server
- github.com/andyollylarkin/watermill-net/pkg/connection
- github.com/apedorenkoS/watermill-amqp-demo/random-single-and-one-everything/all-consumer/internal/event
- github.com/apedorenkoS/watermill-amqp-demo/random-single-and-one-everything/producer/internal/event
- github.com/apedorenkoS/watermill-amqp-demo/specific-instance-receives-event/consumer/internal/event
- github.com/apedorenkoS/watermill-amqp-demo/specific-instance-receives-event/producer/internal/event
- github.com/apoldev/trackchecker/internal/app/track/delivery/watermill-kafka
- github.com/arashrasoulzadeh/go-game-engine/worker
- github.com/artyomturkin/appfx
- github.com/as-rabbit/go-connect/event_driven/events/water-mill
- github.com/ayinke-llc/malak/internal/pkg/queue/watermill
- github.com/baerla/go-sse-htmx
- github.com/bimalabs/framework/v4/messengers/brokers
- github.com/bmcszk/effective-monorepo/pkg/queue
- github.com/bogatyr285/watermillzlog
- github.com/boreq/watermill-bolt/pkg/bolt
- github.com/braveheart12/insolar-27-10-19/insolar/bus
- github.com/braveheart12/insolar-27-10-19/insolar/payload
- github.com/braveheart12/insolar-27-10-19/log/logwatermill
- github.com/braveheart12/insolar-27-10-19/server/internal/heavy
- github.com/braveheart12/insolar-27-10-19/server/internal/light
- github.com/braveheart12/insolar-27-10-19/server/internal/virtual
- github.com/caesar-rocks/events
- github.com/caitunai/go-blueprint/queue
- github.com/caspr-io/mu-kit/streaming
- github.com/chennqqi/watermill-nsq/pkg/nsq
- github.com/chiennguyen196/go-library/internal/catalogue
- github.com/chingkamhing/hello-watermill
- github.com/cikupin/learn-firehose/factory
- github.com/cirruslabs/core-services/pkg/commands/pubsub
- github.com/ckbball/smurfin-email
- github.com/cockroachdb/watermill-crdb/pkg/crdb
- github.com/codebind-luna/telemetry-demo/pkg/publisher/amqp
- github.com/codingDr/watermill-kafka/pkg/kafka
- github.com/coobeet/go-event-driven/03-message-broker/02-publishing-messages
- github.com/coobeet/go-event-driven/03-message-broker/03-subscribing
- github.com/coobeet/go-event-driven/03-message-broker/05-consumer-groups
- github.com/coobeet/go-event-driven/04-router/01-handlers
- github.com/coobeet/go-event-driven/04-router/02-no-publisher-handlers
- github.com/coobeet/go-event-driven/05-events/02-marshalling
- github.com/coobeet/go-event-driven/05-events/03-headers
- github.com/coobeet/go-event-driven/06-middlewares/01-add-middleware
- github.com/coobeet/go-event-driven/08-component-testing/03-writing-mocks
- github.com/crochee/lirity/async
- github.com/cunyat/watermill-mongodb/pkg/mongodb
- github.com/daniel840829/eventcore
- github.com/darjun/go-daily-lib/watermill/get-started
- github.com/darjun/go-daily-lib/watermill/middleware
- github.com/darjun/go-daily-lib/watermill/middleware/self-defined
- github.com/darjun/go-daily-lib/watermill/persistent
- github.com/darjun/go-daily-lib/watermill/rabbitmq
- github.com/darjun/go-daily-lib/watermill/router
- github.com/data233/watermill-nsq/pkg/nsq
- github.com/davideimola/watermill-pgx/pkg/sql
- github.com/denisss025/slog-watermill
- github.com/dentechse/watermill-googlecloud-http/pkg/googlecloud/http
- github.com/dloukadakis/watermill-googlecloud/pkg/googlecloud
- github.com/dmitrymomot/go-pkg/cqrs
- github.com/dobermanndotdev/dobermann/internal/common/watermill_logger
- github.com/dxps/asyncapi_playground/streetlights_go/goapp/asyncapi
- github.com/eclipse-kanto/aws-connector/routing/bus
- github.com/eclipse-kanto/aws-connector/routing/bus/internal/testing
- github.com/eclipse-kanto/aws-connector/routing/message/handlers
- github.com/eclipse-kanto/aws-connector/routing/message/handlers/passthrough
- github.com/eclipse-kanto/aws-connector/routing/message/handlers/state
- github.com/elct9620/wvs/internal/db
- github.com/fi3te/hello-go/threedotslabs-watermill
- github.com/fwidjaya20/symphonic/event
- github.com/garsue/watermillzap
- github.com/gearpoint/filepoint/pkg/watermill
- github.com/gera-cl/xk6-pubsub
- github.com/getzep/zep/pkg/tasks
- github.com/go-apis/eventsourcing/examples/users/tests
- github.com/go-go-golems/geppetto/pkg/events
- github.com/go-go-golems/pinocchio/cmd/experiments/agent/codegen
- github.com/go-quiz/go-daily-lib/watermill/get-started
- github.com/go-quiz/go-daily-lib/watermill/middleware
- github.com/go-quiz/go-daily-lib/watermill/middleware/self-defined
- github.com/go-quiz/go-daily-lib/watermill/persistent
- github.com/go-quiz/go-daily-lib/watermill/rabbitmq
- github.com/go-quiz/go-daily-lib/watermill/router
- github.com/golang-boy/watermill/components/cqrs
- github.com/golang-boy/watermill/components/fanin
- github.com/golang-boy/watermill/components/forwarder
- github.com/golang-boy/watermill/internal/publisher
- github.com/golang-boy/watermill/message
- github.com/golang-boy/watermill/message/router/middleware
- github.com/golang-boy/watermill/pubsub/gochannel
- github.com/golang-boy/watermill/pubsub/tests
- github.com/golang-tire/auth/internal/pkg/pubsub
- github.com/gothunder/thunder/internal/events/rabbitmq/outboxPublisher
- github.com/grafov/watermill-sql/pkg/sql
- github.com/gregszalay/ocpp-csms/device-service/publishing
- github.com/gregszalay/ocpp-csms/device-service/subscribing
- github.com/gregszalay/ocpp-csms/transaction-service/publishing
- github.com/gregszalay/ocpp-csms/transaction-service/subscribing
- github.com/gregszalay/ocpp-csms/user-service/publishing
- github.com/gregszalay/ocpp-csms/user-service/subscribing
- github.com/gregszalay/ocpp-csms/websocket-service/publishing
- github.com/gregszalay/ocpp-csms/websocket-service/subscribing
- github.com/growerlab/growerlab/src/backend/app/common/mq
- github.com/hendratommy/protobus
- github.com/hpcslag/watermill-otel-tracable-gochannel/gochannel
- github.com/ijidan/jsocial/internal/pkg/pubsub
- github.com/ikaiguang/go-srv-kit/data/rabbitmq
- github.com/illidaris/watermillex/kafkaex
- github.com/insolar/assured-ledger/ledger-core/instrumentation/inslogger/logwatermill
- github.com/insolar/assured-ledger/ledger-core/network/messagesender
- github.com/insolar/assured-ledger/ledger-core/rms
- github.com/insolar/assured-ledger/ledger-core/v2/insolar/payload
- github.com/insolar/assured-ledger/ledger-core/v2/instrumentation/inslogger/logwatermill
- github.com/insolar/assured-ledger/ledger-core/v2/server/internal/virtual
- github.com/ischenkx/kantoku/pkg/common/transport/broker/watermill
- github.com/jawr/whois-bi/pkg/internal/job
- github.com/joerocklin/watermilllogr
- github.com/kachvame/gayway/gateway
- github.com/kahowell/watermill-amqp10/pkg/amqp10
- github.com/kecci/go-watermill/go-channel
- github.com/kitanoyoru/kitaDriveBot/apps/service/internal/api/kafka/v0
- github.com/kkoji/nats-example/publisher
- github.com/kostaspt/go-tiny/pkg/logger
- github.com/lamhai1401/forwarder/fwd
- github.com/lejenome/lro/services/process-executor/lib/process/queues
- github.com/ma-hartma/watermill-logrus-adapter
- github.com/maheswaradevo/order-backend/internal/config
- github.com/marlongerson/watermill-amqp/v2/pkg/amqp
- github.com/matroskin13/mongosubscriber/examples/simple
- github.com/medinae/watermill-googlecloud/pkg/googlecloud
- github.com/message-board/identity-go
- github.com/mgjules/spoty/transport/messenger
- github.com/mindersec/minder/internal/events
- github.com/minghsu0107/saga-product/config
- github.com/minghsu0107/saga-product/infra/broker
- github.com/minghsu0107/saga-product/infra/broker/order
- github.com/minghsu0107/saga-product/infra/broker/payment
- github.com/minghsu0107/saga-product/infra/broker/product
- github.com/minghsu0107/saga-product/service/orchestrator
- github.com/mjjs/watermill-close-bugreport
- github.com/muktiarafi/ticketing-common
- github.com/neermitt/watermill-zeebe/pkg/zeebe
- github.com/nekizz/final-project/backend/booking/cmd
- github.com/nekizz/final-project/backend/booking/util
- github.com/nekizz/final-project/backend/orchestrator/cmd
- github.com/nekizz/final-project/backend/orchestrator/orchestrator
- github.com/nekizz/final-project/backend/payment/cmd
- github.com/nekizz/final-project/backend/payment/payment
- github.com/nekizz/final-project/backend/room/cmd
- github.com/nekizz/final-project/backend/room/room
- github.com/nkamuo/rasta-server/tests
- github.com/noodlensk/task-tracker/internal/accounting/adapters
- github.com/noodlensk/task-tracker/internal/accounting/data/publisher
- github.com/noodlensk/task-tracker/internal/common/clients/accounting/async/publisher
- github.com/noodlensk/task-tracker/internal/common/clients/accounting/cud/publisher
- github.com/noodlensk/task-tracker/internal/common/clients/tasks/cud/publisher
- github.com/noodlensk/task-tracker/internal/common/decorators
- github.com/noodlensk/task-tracker/internal/common/logs
- github.com/noodlensk/task-tracker/internal/tasks/data/publisher
- github.com/noodlensk/task-tracker/internal/users/data/publisher
- github.com/olvod/xk6-pubsub
- github.com/onyxhat/watermill-test
- github.com/opsway-io/backend/internal/event
- github.com/ormanli/rest-kafka-bridge-example
- github.com/pedropilla/xk6-pubsub
- github.com/perfect13/watermill-mqtt
- github.com/persys-dev/persys-cloud/api-gateway/pkg/watermill
- github.com/persys-dev/persys-cloud/ci-service/pkg/watermill
- github.com/persys-dev/persys-cloud/cloud-mgmt/pkg/watermill
- github.com/persys-dev/persys-cloud/events-manager/internal/eventctl
- github.com/persys-dev/persys-cloud/events-manager/pkg/watermill
- github.com/peterdev80/watercc
- github.com/protomem/chatik/internal/stream
- github.com/qiulin/watermill-kafkago/pkg/kafkago
- github.com/rakamoviz/kincirair/cmd/cqrs
- github.com/rakamoviz/kincirair/cmd/cqrskafka
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_domain
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_domain_partitioned_processor
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_domain_partitioned_publisher
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_eventdenormalizer
- github.com/rakamoviz/kincirair/cmd/cqrskafka_separated_eventdenormalizer_partitioned
- github.com/rakamoviz/kincirair/cmd/kafkapublisher
- github.com/rakamoviz/kincirair/cmd/kafkasubscriber
- github.com/rakamoviz/kincirair/cmd/pubsub
- github.com/rakamoviz/kincirair/cmd/router
- github.com/robot-nan/watermill-rocketmq-aliyun/pkg/rocketmq
- github.com/roessland/withoutings/pkg/logging
- github.com/rome314/3-commas-ws-forwarder/internal/sender
- github.com/ronen25/entro-task
- github.com/ryanyogan/watermill-basics
- github.com/sandrolain/gomsvc/pkg/mqttlib/mqttwatermill
- github.com/sanservices/kit/kafkalistener
- github.com/sftfjugg/go-daily-lib/watermill/get-started
- github.com/sftfjugg/go-daily-lib/watermill/middleware
- github.com/sftfjugg/go-daily-lib/watermill/middleware/self-defined
- github.com/sftfjugg/go-daily-lib/watermill/persistent
- github.com/sftfjugg/go-daily-lib/watermill/rabbitmq
- github.com/sftfjugg/go-daily-lib/watermill/router
- github.com/shopd/ih2024
- github.com/siangyeh8818/watermill.golang-project
- github.com/starton-io/tyrscale/gateway/pkg/consumer
- github.com/stevecallear/watermill-badger/pkg/badger
- github.com/studiobflat/tsj/redis
- github.com/suifengpiao14/cudevent
- github.com/survivorbat/go-watermill-test-logger
- github.com/sysradium/debezium-events-aggregation/service/cmd/server
- github.com/talon-sec/watermill-kafka/v2/pkg/kafka
- github.com/tehbilly/ges/cmd/demo
- github.com/thoughtnet/minds/tools
- github.com/tiandh987/CGODemo/example/rolex/ptzV3/blp
- github.com/tochamateusz/micro/modules/message-brokes/amqp
- github.com/tommynurwantoro/kafkid/internal/application/service
- github.com/tuanvumaihuynh/roboflow/internal/application
- github.com/tuihub/librarian/internal/lib/libmq
- github.com/unicod3/horreum/pkg/streamer
- github.com/uniwise/walrus
- github.com/voi-oss/protoc-gen-event/examples
- github.com/vsvp21/zerolog-watermill-adapter
- github.com/vungocson998/golang-watermill-practise
- github.com/weezqyd/ringier/internal/adapters/msb
- github.com/wyxloading/watermill-redisstream/pkg/redisstream
- github.com/x1m3/tertulia/internal/pkg/pubsub
- github.com/xyluet/letsgo/log/watermill
- github.com/xyu-io/genie/msgchan
- github.com/yangshun2005/go-daily-lib/watermill/get-started
- github.com/yangshun2005/go-daily-lib/watermill/middleware
- github.com/yangshun2005/go-daily-lib/watermill/middleware/self-defined
- github.com/yangshun2005/go-daily-lib/watermill/persistent
- github.com/yangshun2005/go-daily-lib/watermill/rabbitmq
- github.com/yangshun2005/go-daily-lib/watermill/router
- github.com/ydssx/kratos-kit/pkg/pubsub
- github.com/yflau/watermill-rocketmq/pkg/rocketmq
- github.com/ygaros/event-driven-example
- github.com/yogeshboddu/xk6-pubsub
- github.com/zappie/watermill-redisstream/pkg/redisstream
- github.com/zgunz42/servercopilot/internal/stream
- github.com/znowdev/reqbouncer/internal/server
- gitlab.com/aerilyn/service-item/internal/pkg/pubsub/rabbitmq
- gitlab.com/eemj/anime-pack/internal/pubsub
- gitlab.com/jimboylabs/music/providers/common/log
- gitlab.com/kasi-labs/watermill-amqp/pkg/amqp
- gitlab.com/nikolai.straessle/echomiddleware/v7/async
- gitlab.com/peng-golang/pubsub/rabbit-mq
- go.yym.plus/zeus/pkg/pubsub
- logur.dev/integration/watermill
- weavelab.xyz/watermill-kafka/pkg/kafka