//
pkg.gl
Category
github.com/ThreeDotsLabs/watermill
message
package
1.5.1
Repository:
https://github.com/threedotslabs/watermill.git
Documentation:
pkg.go.dev
Overview
Dependencies
10
Dependents
612
github.com/KejawenLab/bima/v4/messengers
github.com/KejawenLab/bima/v4/messengers/brokers
github.com/KejawenLab/bima/v4/mocks/messengers
github.com/ThreeDotsLabs/watermill-sql/v4/pkg/sql
github.com/minghsu0107/go-random-chat/pkg/match
github.com/minghsu0107/go-random-chat/pkg/infra
github.com/minghsu0107/go-random-chat/pkg/chat
github.com/minghsu0107/go-random-chat/pkg/forwarder
github.com/KejawenLab/bima/v3/messengers
github.com/integer-technologies-b-v/watermill-sql/v3/pkg/sql
github.com/ThreeDotsLabs/watermill-kafka/v3/pkg/kafka
github.com/ThreeDotsLabs/watermill-amqp/v3/pkg/amqp
github.com/lamassuiot/lamassuiot/v2/pkg/services/handlers
github.com/lamassuiot/lamassuiot/v2/pkg/eventbus
github.com/lamassuiot/lamassuiot/v2/pkg/middlewares/eventpub
github.com/KejawenLab/bima/v2/handlers
github.com/ThreeDotsLabs/watermill-http/v2/pkg/http
github.com/vseinstrumentiru/lego/v2/transport/events/eventrouter
github.com/vseinstrumentiru/lego/v2/pkg/eventtools/cloudevent
github.com/vseinstrumentiru/lego/v2/transport/events/eventrouter/metrics
github.com/ThreeDotsLabs/watermill-nats/v2/pkg/nats
github.com/ThreeDotsLabs/watermill-nats/v2/pkg/jetstream
github.com/formancehq/webhooks/pkg/worker
github.com/formancehq/ledger/internal/engine
github.com/formancehq/ledger/internal/bus
github.com/crowdeco/bima/v2/handlers
github.com/formancehq/go-libs/v2/publish
github.com/formancehq/go-libs/v2/publish/topic_mapper
github.com/formancehq/go-libs/v2/publish/circuit_breaker
github.com/ThreeDotsLabs/watermill-googlecloud/v2/pkg/googlecloud
github.com/alexcuse/edgex-watermill/v2/amqp
github.com/alexcuse/edgex-watermill/v2/kafka
github.com/alexcuse/edgex-watermill/v2/googlecloud
github.com/alexcuse/edgex-watermill/v2/jetstream
github.com/alexcuse/edgex-watermill/v2/core
github.com/alexcuse/edgex-watermill/v2/nats
github.com/DIMO-Network/devices-api/internal/services
github.com/DIMO-Network/devices-api/internal/kafka
github.com/numary/ledger/pkg/bus
github.com/crowdeco/bima/handlers
github.com/insolar/insolar/server/internal
github.com/insolar/insolar/server/internal/virtual
github.com/insolar/insolar/server/internal/light
github.com/insolar/insolar/server/internal/heavy
github.com/insolar/insolar/instrumentation/introspector/pubsubwrap
github.com/insolar/insolar/insolar/flow/dispatcher
github.com/insolar/insolar/insolar/flow/internal/thread
github.com/insolar/insolar/network/servicenetwork
github.com/insolar/insolar/insolar/flow
github.com/insolar/insolar/insolar/payload
github.com/insolar/insolar/insolar/bus
github.com/insolar/insolar/contractrequester
github.com/insolar/insolar/logicrunner
github.com/insolar/insolar/ledger/heavy/handler
github.com/insolar/insolar/ledger/light/executor
github.com/insolar/insolar/ledger/light/proc
github.com/insolar/insolar/ledger/light/handle
github.com/caitunai/go-blueprint/queue/job
github.com/caitunai/go-blueprint/queue
github.com/formancehq/go-libs/publish/topic_mapper
github.com/formancehq/go-libs/publish/circuit_breaker
github.com/formancehq/go-libs/publish
github.com/Zondax/zindexer/components/connections/pub_sub
github.com/ThreeDotsLabs/watermill/pubsub/gochannel
github.com/ThreeDotsLabs/watermill/internal/subscriber
github.com/ThreeDotsLabs/watermill/message/subscriber
github.com/ThreeDotsLabs/watermill/pubsub/tests
github.com/ThreeDotsLabs/watermill/internal/publisher
github.com/ThreeDotsLabs/watermill/message/router/plugin
github.com/ThreeDotsLabs/watermill/components/requeuer
github.com/ThreeDotsLabs/watermill/components/delay
github.com/ThreeDotsLabs/watermill/components/requestreply
github.com/ThreeDotsLabs/watermill/components/metrics
github.com/ThreeDotsLabs/watermill/components/forwarder
github.com/ThreeDotsLabs/watermill/components/fanin
github.com/ThreeDotsLabs/watermill/components/cqrs
github.com/ThreeDotsLabs/watermill/message/router/middleware
github.com/ThreeDotsLabs/watermill-redisstream/pkg/redisstream
github.com/renevo/mcutils/internal/command/minecraft/modules/ext
github.com/renevo/mcutils/internal/command/minecraft/modules/gamerules
github.com/renevo/mcutils/internal/command/minecraft/modules/discord
github.com/renevo/mcutils/pkg/minecraft
github.com/renevo/mcutils/internal/control
github.com/renevo/mcutils/internal/command/minecraft/modules/startupcommands
github.com/sanservices/kit/kafkalistener
github.com/grafov/watermill-sql/pkg/sql
github.com/crochee/lirity/async
github.com/crochee/lirity/mq
github.com/lcnascimento/go-kit/messaging/cqrs
github.com/lcnascimento/go-kit/messaging/middleware
github.com/lcnascimento/go-kit/messaging
github.com/lcnascimento/go-kit/messaging/mocks
github.com/githubzhaoqian/watermill-redislist/pkg/redislist
github.com/githubzhaoqian/watermill-rediszset/pkg/rediszset
github.com/fwidjaya20/symphonic/event
github.com/go-leo/leo
github.com/go-leo/leo/runner/task/pubsub
github.com/gabeduke/reap/pkg/reap
github.com/gabeduke/reap/pkg/mqttc
github.com/czeslavo/watermill-opencensus
github.com/ThreeDotsLabs/watermill-io/pkg/io
github.com/ThreeDotsLabs/watermill-bolt/pkg/bolt
github.com/gothunder/thunder/internal/events/rabbitmq/outboxPublisher
github.com/turbot/flowpipe/internal/service/es
github.com/turbot/flowpipe/internal/service/es/middleware
github.com/gothunder/thunder/internal/events/rabbitmq/tracing
github.com/muktiarafi/ticketing-common
github.com/muktiarafi/ticketing-common/mocks
github.com/medinae/watermill-googlecloud/pkg/googlecloud
github.com/ZhanibekTau/go-sdk/pkg/rabbitmq/structures
github.com/ZhanibekTau/go-sdk/pkg/rabbitmq
github.com/gstones/moke-kit/mq/internal/message
github.com/gstones/moke-kit/mq/internal/nats
github.com/gstones/moke-kit/mq/internal/local
github.com/vseinstrumentiru/lego/internal/lego
github.com/vseinstrumentiru/lego/internal/lego/transport/event/metrics
github.com/vseinstrumentiru/lego/pkg/eventtools/cloudevent
github.com/vseinstrumentiru/lego/internal/lego/transport/event
github.com/Homeppv2/aggregator/internal/controller
github.com/dwlpra/pubsubs/pkg/subscriber
github.com/dwlpra/pubsubs/pkg/publisher
github.com/trustbloc/orb/pkg/anchor/handler/proof
github.com/trustbloc/orb/pkg/pubsub
github.com/trustbloc/orb/pkg/mocks
github.com/trustbloc/orb/pkg/observer
github.com/trustbloc/orb/pkg/activitypub/service
github.com/trustbloc/orb/pkg/pubsub/amqp
github.com/trustbloc/orb/pkg/pubsub/mempubsub
github.com/trustbloc/orb/pkg/anchor/vcpubsub
github.com/trustbloc/orb/pkg/anchor/writer
github.com/trustbloc/orb/pkg/context/mocks
github.com/trustbloc/orb/pkg/context/opqueue
github.com/trustbloc/orb/pkg/activitypub/service/inbox
github.com/trustbloc/orb/pkg/activitypub/service/outbox
github.com/trustbloc/orb/pkg/activitypub/service/mocks
github.com/trustbloc/orb/pkg/observability/tracing/otelamqp
github.com/trustbloc/orb/pkg/observability/tracing/mocks
github.com/trustbloc/orb/pkg/activitypub/service/inbox/httpsubscriber
github.com/ThreeDotsLabs/watermill-firestore/pkg/firestore
github.com/ThreeDotsLabs/watermill-firestore/cmd/example
github.com/ThreeDotsLabs/watermill-firestore/cmd/transaction
github.com/ThreeDotsLabs/watermill-firestore/internal/inspector
github.com/mgjules/spoty/transport/messenger
github.com/eclipse-kanto/suite-connector/connector
github.com/eclipse-kanto/suite-connector/routing
github.com/eclipse-kanto/suite-connector/config
github.com/eclipse-kanto/suite-connector/cmd/connector
github.com/eclipse-kanto/suite-connector/cmd/connector/app
github.com/rizalgowandy/gdk/pkg/queue/watermillx
github.com/rizalgowandy/gdk/pkg/queue/watermillx/middleware
github.com/rizalgowandy/gdk/pkg/queue/watermillx/examples/with-amqp/job
github.com/rizalgowandy/gdk/pkg/queue/watermillx/examples/with-kafka/job
github.com/eclipse-kanto/azure-connector/routing/bus
github.com/eclipse-kanto/azure-connector/routing/message/handlers
github.com/eclipse-kanto/azure-connector/cmd/azure-connector/app
github.com/eclipse-kanto/azure-connector/routing/message/handlers/passthrough
github.com/eclipse-kanto/azure-connector/routing/bus/internal/testing
github.com/ThreeDotsLabs/watermill-aws/sqs
github.com/openmeterio/openmeter/openmeter/notification/consumer
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/robot-nan/watermill-rocketmq-aliyun/pkg/rocketmq
github.com/eclipse-kanto/aws-connector/routing/bus/internal/testing
github.com/eclipse-kanto/aws-connector/routing/message/handlers/state
github.com/eclipse-kanto/aws-connector/routing/message/handlers/passthrough
github.com/eclipse-kanto/aws-connector/cmd/aws-connector/app
github.com/eclipse-kanto/aws-connector/routing/message/handlers
github.com/eclipse-kanto/aws-connector/routing/bus
github.com/openmeterio/openmeter/openmeter/entitlement/balanceworker
github.com/omran95/chat-app/pkg/room
github.com/eclipse-kanto/local-digital-twins/internal/commands
github.com/eclipse-kanto/local-digital-twins/internal/sync
github.com/eclipse-kanto/local-digital-twins/internal/testutil
github.com/eclipse-kanto/local-digital-twins/cmd/twins
github.com/ThreeDotsLabs/watermill-aws/sns
github.com/omran95/chat-app/pkg/infrastructure
github.com/openmeterio/openmeter/cmd/balance-worker
github.com/openmeterio/openmeter/cmd/notification-service
github.com/openmeterio/openmeter/cmd/server
github.com/openmeterio/openmeter/openmeter/watermill/marshaler
github.com/openmeterio/openmeter/openmeter/watermill/eventbus
github.com/openmeterio/openmeter/openmeter/watermill/grouphandler
github.com/openmeterio/openmeter/openmeter/watermill/router
github.com/openmeterio/openmeter/openmeter/watermill/nopublisher
github.com/openmeterio/openmeter/openmeter/watermill/driver/noop
github.com/openmeterio/openmeter/openmeter/watermill/driver/kafka
github.com/gregszalay/ocpp-csms/websocket-service/publishing
github.com/gregszalay/ocpp-csms/websocket-service/subscribing
github.com/pperaltaisern/esrcwatermill
github.com/omran95/chat-app/pkg/subscriber
github.com/getzep/zep/pkg/tasks
github.com/getzep/zep/pkg/models
github.com/flowline-io/flowbot/internal/server
github.com/flowline-io/flowbot/pkg/event
github.com/DIMO-Network/vehicle-signal-decoding/internal/infrastructure/kafka
github.com/gothunder/thunder/internal/events/rabbitmq/tracing
github.com/gothunder/thunder/internal/events/rabbitmq/outboxPublisher
github.com/turbot/flowpipe/internal/service/es
github.com/rizalgowandy/gdk/pkg/queue/watermillx/middleware
github.com/rizalgowandy/gdk/pkg/queue/watermillx/examples/with-amqp/job
github.com/rizalgowandy/gdk/pkg/queue/watermillx/examples/with-kafka/job
github.com/rizalgowandy/gdk/pkg/queue/watermillx
github.com/turbot/flowpipe/internal/service/es/middleware
github.com/braveheart12/insolar-27-10-19/ledger/light/proc
github.com/braveheart12/insolar-27-10-19/ledger/light/handle
github.com/braveheart12/insolar-27-10-19/ledger/light/executor
github.com/braveheart12/insolar-27-10-19/ledger/heavy/handler
github.com/braveheart12/insolar-27-10-19/instrumentation/introspector/pubsubwrap
github.com/braveheart12/insolar-27-10-19/insolar/flow/dispatcher
github.com/braveheart12/insolar-27-10-19/server/internal
github.com/braveheart12/insolar-27-10-19/insolar/flow
github.com/braveheart12/insolar-27-10-19/network/servicenetwork
github.com/braveheart12/insolar-27-10-19/insolar/payload
github.com/braveheart12/insolar-27-10-19/server/internal/light
github.com/braveheart12/insolar-27-10-19/server/internal/heavy
github.com/braveheart12/insolar-27-10-19/logicrunner
github.com/braveheart12/insolar-27-10-19/insolar/flow/internal/thread
github.com/braveheart12/insolar-27-10-19/contractrequester
github.com/braveheart12/insolar-27-10-19/server/internal/virtual
github.com/braveheart12/insolar-27-10-19/insolar/bus
github.com/braveheart12/insolar-31-08-19/insolar/flow/internal/thread
github.com/braveheart12/insolar-31-08-19/contractrequester
github.com/braveheart12/insolar-31-08-19/logicrunner
github.com/braveheart12/insolar-31-08-19/insolar/bus
github.com/braveheart12/insolar-31-08-19/insolar/flow
github.com/braveheart12/insolar-31-08-19/insolar/payload
github.com/braveheart12/insolar-31-08-19/network/servicenetwork
github.com/braveheart12/insolar-31-08-19/server/internal
github.com/braveheart12/insolar-31-08-19/insolar/flow/dispatcher
github.com/braveheart12/insolar-31-08-19/instrumentation/introspector/pubsubwrap
github.com/braveheart12/insolar-31-08-19/ledger/heavy/handler
github.com/braveheart12/insolar-31-08-19/ledger/light/executor
github.com/braveheart12/insolar-31-08-19/ledger/light/handle
github.com/braveheart12/insolar-31-08-19/server/internal/heavy
github.com/braveheart12/insolar-31-08-19/server/internal/light
github.com/braveheart12/insolar-31-08-19/server/internal/virtual
github.com/flux-agi/flux_go/fluxmq
github.com/flux-agi/flux_go/flux
github.com/flux-agi/flux_go/fluxtest
github.com/foomo/sesamy-go/integration/loki
github.com/foomo/sesamy-go/integration/watermill/mpv2
github.com/foomo/sesamy-go/integration/watermill/gtag
github.com/rotationalio/watermill-ensign/pkg/ensign
github.com/go-go-golems/pinocchio/cmd/experiments/agent/codegen
github.com/go-go-golems/pinocchio/cmd/experiments/web-ui/client
github.com/go-go-golems/pinocchio/pkg/ui
github.com/go-apis/eventsourcing/es/providers/stream/mpub
github.com/go-apis/eventsourcing/es
github.com/acs-dl/gitlab-module-svc/internal/processor
github.com/acs-dl/gitlab-module-svc/internal/receiver
github.com/acs-dl/gitlab-module-svc/internal/sender
github.com/ikaiguang/go-srv-kit/data/rabbitmq
github.com/agalue/onms-kafka-ipc-receiver/client
github.com/zgunz42/servercopilot/internal/stream
github.com/c13n-io/c13n-go/app
github.com/subscribeddotdev/subscribed-backend/cmd/service
github.com/subscribeddotdev/subscribed-backend/internal/ports/amqp
github.com/subscribeddotdev/subscribed-backend/internal/common/messaging
github.com/subscribeddotdev/subscribed-backend/internal/adapters/events
github.com/Zondax/zindexer/components/connections/pub_sub
github.com/tuihub/librarian/internal/lib/libmq
github.com/ThreeDotsLabs/watermill-firestore/cmd/transaction
github.com/ThreeDotsLabs/watermill-firestore/internal/inspector
github.com/ThreeDotsLabs/watermill-firestore/pkg/firestore
github.com/ThreeDotsLabs/watermill-firestore/cmd/example
github.com/rotationalio/baleen/cmd/baleen
github.com/rotationalio/baleen/config
github.com/rotationalio/baleen
github.com/rotationalio/baleen/events
github.com/qmstar0/BlogLite-api/internal/common/gopubsub
github.com/qmstar0/BlogLite-api/internal/articles/adapter
github.com/qmstar0/BlogLite-api/internal/articles/service
github.com/ml4wireless/specpipe/edge
github.com/czeslavo/watermill-firestore/cmd/transaction
github.com/ml4wireless/specpipe/common
github.com/czeslavo/watermill-firestore/cmd/example
github.com/czeslavo/watermill-firestore/pkg/firestore
github.com/GabrielCarpr/cqrs/bus/queue/sql
github.com/asyncapi/event-gateway/message
github.com/asyncapi/event-gateway
github.com/asyncapi/event-gateway/asyncapi/v2
github.com/asyncapi/event-gateway/message/handler
github.com/asyncapi/event-gateway/message/test
github.com/asyncapi/event-gateway/kafka
github.com/tigorlazuardi/redmage/api
github.com/jujili/exch/backtest
github.com/tigorlazuardi/redmage/pkg/pubsub
github.com/atropos112/gocore/pubsub
github.com/malamtime/cli/daemon
github.com/voi-oss/protoc-gen-event/examples
github.com/andyollylarkin/watermill-net/examples/tls_client
github.com/andyollylarkin/watermill-net
github.com/andyollylarkin/watermill-net/internal
github.com/andyollylarkin/watermill-net/examples/client
github.com/andyollylarkin/watermill-net/examples/retryable_client
github.com/dentech-floss/publisher/pkg/publisher
github.com/trustbloc/orb/pkg/pubsub/redelivery
github.com/trustbloc/orb/pkg/activitypub/service/inbox/httpsubscriber
github.com/trustbloc/orb/pkg/anchor/vcpubsub
github.com/trustbloc/orb/pkg/pubsub/mempubsub
github.com/trustbloc/orb/pkg/pubsub/amqp
github.com/trustbloc/orb/pkg/activitypub/service
github.com/trustbloc/orb/pkg/observer
github.com/trustbloc/orb/pkg/mocks
github.com/trustbloc/orb/pkg/activitypub/service/outbox/httppublisher
github.com/trustbloc/orb/pkg/anchor/handler/proof
github.com/voi-oss/watermill-opentelemetry/pkg/opentelemetry
github.com/dmitrymomot/go-pkg/cqrs
github.com/trustbloc/orb/pkg/activitypub/service/outbox
github.com/trustbloc/orb/pkg/activitypub/service/inbox
github.com/trustbloc/orb/pkg/context/opqueue
github.com/trustbloc/orb/pkg/context/mocks
github.com/trustbloc/orb/pkg/activitypub/service/mocks
github.com/trustbloc/orb/pkg/anchor/writer
github.com/acs-dl/mail-module-svc/internal/service/receiver
github.com/dentech-floss/subscriber/pkg/subscriber
github.com/acs-dl/mail-module-svc/internal/service/sender
github.com/acs-dl/mail-module-svc/internal/service/processor
github.com/igmagollo/undine/example
github.com/igmagollo/undine/example/ent
github.com/brittonhayes/staffing/server
github.com/neermitt/watermill-zeebe/pkg/zeebe
github.com/dentech-floss/watermill-opentelemetry-go-extra/pkg/opentelemetry
github.com/dentech-floss/watermill-googlecloud-http/pkg/googlecloud/http
github.com/brittonhayes/staffing/cmd/staffd
github.com/brittonhayes/staffing/internal/protobuf
github.com/acs-dl/auth-svc/internal/sender
github.com/acs-dl/identity-svc/internal/receiver
github.com/eclipse-kanto/suite-bootstrapping/cmd/bootstrapping
github.com/eclipse-kanto/suite-bootstrapping/internal/bootstrapping
github.com/eclipse-kanto/suite-connector/cmd/connector/app
github.com/eclipse-kanto/suite-connector/cmd/connector
github.com/eclipse-kanto/suite-connector/config
github.com/eclipse-kanto/suite-connector/routing
github.com/acs-dl/github-module-svc/internal/sender
github.com/acs-dl/github-module-svc/internal/processor
github.com/acs-dl/github-module-svc/internal/receiver
github.com/eclipse-kanto/local-digital-twins/internal/testutil
github.com/eclipse-kanto/local-digital-twins/cmd/twins
github.com/gelleson/changescout/changescout/pkg/messages
github.com/eclipse-kanto/local-digital-twins/internal/commands
github.com/eclipse-kanto/local-digital-twins/internal/sync
github.com/eclipse-kanto/suite-connector/connector
github.com/gelleson/changescout/changescout/internal/app/usecases/scheduler
github.com/acs-dl/auth-svc/internal/receiver
github.com/acs-dl/telegram-module-svc/internal/processor
github.com/ramadani/starboost/internal/consumer
github.com/ramadani/starboost/internal/transport
github.com/agalue/onms-sink-syslog
github.com/DoNewsCode/core-pubsub
github.com/acs-dl/telegram-module-svc/internal/sender
github.com/acs-dl/telegram-module-svc/internal/receiver
github.com/stevecallear/watermill-badger/pkg/badger
github.com/gelleson/changescout/changescout/internal/api/broker
github.com/depocket/support/queue
github.com/caspr-io/mu-kit/streaming
github.com/mindersec/minder/internal/providers/github/webhook
github.com/mindersec/minder/internal/engine
github.com/mindersec/minder/internal/providers/github/installations
github.com/mindersec/minder/internal/reconcilers/messages
github.com/mindersec/minder/pkg/eventer/interfaces
github.com/mindersec/minder/internal/engine/entities
github.com/mindersec/minder/internal/events/nats
github.com/mindersec/minder/internal/events/stubs
github.com/mindersec/minder/internal/events/sql
github.com/mindersec/minder/internal/entities/handlers/strategies/message
github.com/mindersec/minder/internal/events/gochannel
github.com/mindersec/minder/internal/controlplane
github.com/mindersec/minder/cmd/server/app
github.com/mindersec/minder/internal/email/noop
github.com/mindersec/minder/internal/util/testqueue
github.com/mindersec/minder/internal/email
github.com/mindersec/minder/internal/eea
github.com/mindersec/minder/internal/reminder
github.com/mindersec/minder/internal/reminderprocessor
github.com/mindersec/minder/internal/events
github.com/mindersec/minder/internal/service
github.com/mindersec/minder/cmd/dev/app/testserver
github.com/mindersec/minder/pkg/eventer/interfaces/mock
github.com/mindersec/minder/internal/providers/gitlab/manager
github.com/mindersec/minder/internal/email/awsses
github.com/mindersec/minder/internal/entities/handlers/message
github.com/mindersec/minder/internal/entities/handlers
github.com/mindersec/minder/internal/entities/handlers/strategies
github.com/mindersec/minder/internal/reminder/messages
github.com/mindersec/minder/internal/logger
github.com/mindersec/minder/internal/reconcilers
github.com/Black-And-White-Club/frolf-bot-shared/errors
github.com/Black-And-White-Club/frolf-bot-shared/logger
github.com/Black-And-White-Club/frolf-bot-shared/events
github.com/Black-And-White-Club/frolf-bot-shared/observability
github.com/Black-And-White-Club/frolf-bot-shared/eventbus
github.com/Black-And-White-Club/frolf-bot-shared/utils
github.com/Black-And-White-Club/frolf-bot-shared/observability/mocks
github.com/Black-And-White-Club/frolf-bot-shared/eventbus/mocks
github.com/Black-And-White-Club/frolf-bot-shared/observability/attr
github.com/achuala/go-svc-extn/pkg/messaging
github.com/achuala/go-svc-extn/pkg/messaging/nats
github.com/thienhaole92/vnd/wsub
github.com/thienhaole92/vnd/wpub
github.com/znowdev/reqbouncer/internal/server
github.com/suifengpiao14/cudevent/cudeventimpl
github.com/suifengpiao14/cudevent
github.com/go-micro-saas/nodeid-service/app/nodeid-service/internal/biz/event
github.com/purposeinplay/go-commons/pubsub/kafka
github.com/ThreeDotsLabs/go-event-driven/common/log
github.com/studiobflat/tsj/redis
github.com/hysios/x/events
github.com/dwlpra/pubsubs/pkg/subscriber
github.com/hysios/x/events/common
github.com/dwlpra/pubsubs/pkg/publisher
github.com/go-go-golems/go-go-labs/cmd/apps/bandcamp/pkg/machinery
github.com/go-go-golems/go-go-labs/cmd/apps/bandcamp
github.com/go-go-golems/go-go-labs/cmd/experiments/textract-watermill
github.com/go-go-golems/go-go-labs/cmd/apps/bandcamp/pkg
github.com/ThreeDotsLabs/watermill-jetstream/pkg/jetstream
github.com/ThreeDotsLabs/watermill-jetstream/pkg/jetstream/wmpb
github.com/dkotik/watermillchat/history/sqlitehistory
github.com/stong1994/watermill-rediszset/pkg/rediszset
github.com/AlexCuse/watermill-jetstream/pkg/jetstream
github.com/stong1994/watermill-rediszset/example/timer_strict
github.com/stong1994/watermill-rediszset/example/timer
github.com/go-leo/leo/runner/task/pubsub
github.com/go-leo/leo
github.com/boreq/watermill-bolt/pkg/bolt
github.com/digitive/watermill-rsjm
github.com/jujili/jili/examples/binance-btcusdt-double-ma-backtest
github.com/zappie/watermill-redisstream/pkg/redisstream
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard
github.com/Black-And-White-Club/frolf-bot/app/modules/round
github.com/Black-And-White-Club/frolf-bot/app/modules/score
github.com/Black-And-White-Club/frolf-bot/app/modules/user
github.com/Black-And-White-Club/frolf-bot/app/shared/logging
github.com/Black-And-White-Club/frolf-bot/app/eventbus/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/application
github.com/Black-And-White-Club/frolf-bot/app/modules/round/application
github.com/Black-And-White-Club/frolf-bot/app/modules/score/application
github.com/Black-And-White-Club/frolf-bot/app/modules/user/application
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/infrastructure/handlers
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/infrastructure/router
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/application/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/round/infrastructure/handlers
github.com/Black-And-White-Club/frolf-bot/app/modules/round/infrastructure/router
github.com/Black-And-White-Club/frolf-bot/app/modules/round/application/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/score/infrastructure/handlers
github.com/Black-And-White-Club/frolf-bot/app/modules/score/infrastructure/router
github.com/Black-And-White-Club/frolf-bot/app/modules/user/infrastructure/handlers
github.com/Black-And-White-Club/frolf-bot/app/modules/user/infrastructure/router
github.com/Black-And-White-Club/frolf-bot/app/modules/user/application/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/infrastructure/handlers/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/leaderboard/infrastructure/router/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/round/infrastructure/handlers/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/round/infrastructure/router/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/score/infrastructure/handlers/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/score/infrastructure/router/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/user/infrastructure/handlers/mocks
github.com/Black-And-White-Club/frolf-bot/app/modules/user/infrastructure/router/mocks
github.com/ayinke-llc/malak/internal/pkg/queue/watermill
github.com/davidroman0O/gronos/extensions/watermill
github.com/davidroman0O/gronos/examples/watermill
github.com/GSH-LAN/Unwindia_tmt2/src/server
github.com/GSH-LAN/Unwindia_tmt2/src/messagequeue
github.com/Jeanhwea/baliqiao3/internal/platform/watermill
github.com/Jeanhwea/baliqiao3/internal/app/mga
github.com/Kichiyaki/watermillplayground/cmd/publisher
github.com/Brandon2255p/watermill-eventstore/eventstore
github.com/Kichiyaki/watermillplayground/cmd/processor
github.com/Kichiyaki/watermillplayground/cmd/internal
github.com/planetary-social/nos-event-service/service/adapters/gcp
github.com/mfreeman451/dd-chatgpt-dm/server/pkg/watermill
github.com/mfreeman451/dd-chatgpt-dm/server/cmd/server
github.com/mfreeman451/dd-chatgpt-dm/server/cmd/janitor
github.com/mfreeman451/dd-chatgpt-dm/server/internal/service
github.com/mfreeman451/dd-chatgpt-dm/server/internal/janitor
github.com/artyomturkin/go-from-uri/watermill
github.com/artyomturkin/go-from-uri/kafka
github.com/qairjar/watermill-elastic-plugin
github.com/artyomturkin/watermill-extension
github.com/artyomturkin/appfx
github.com/artyomturkin/appfx/example
github.com/demeero/bricks/watermillbrick
github.com/abialemuel/AI-Proxy-Service/pkg/common/amqp
github.com/abialemuel/AI-Proxy-Service/pkg/user/api/amqp
github.com/mfreeman451/dd-chatgpt-dm/server/internal/interp
github.com/ShmelJUJ/software-engineering/transaction/internal/broker/publisher
github.com/ShmelJUJ/software-engineering/transaction/internal/broker/subscriber
github.com/Shelex/parallel-specs/internal/events
github.com/saturn4er/boilerplate-go/lib/txoutbox/txoutboxwatermill
github.com/bmstu-itstech/itsreg-bots/internal/service/mocks
github.com/pmoura-dev/esr-service/internal/broker
github.com/pmoura-dev/esr-service/cmd/service
github.com/pmoura-dev/esr-service/internal/services/entity
github.com/pmoura-dev/esr-service/internal/broker/brokers/rabbitmq
github.com/bmstu-itstech/itsreg-bots/internal/ports/telegram
github.com/bmstu-itstech/itsreg-bots/internal/service
github.com/Black-And-White-Club/frolf-bot/app
github.com/Black-And-White-Club/frolf-bot/app/shared
github.com/Black-And-White-Club/frolf-bot/internal/eventutil
github.com/Black-And-White-Club/frolf-bot/internal/test
github.com/qairjar/watermill-sql-plugin
github.com/turao/go-ddd/billing/infrastructure/messaging
github.com/turao/go-ddd/ddd/kafka
github.com/turao/go-ddd/api/kafka
github.com/x1m3/tertulia/internal/pkg/pubsub
github.com/EraldCaka/broker/pkg/kafka
github.com/EraldCaka/broker/pkg/broker
github.com/EraldCaka/broker/services/users
github.com/Improwised/golang-api/pkg/watermill
github.com/Improwised/golang-api/cli/workers
github.com/Improwised/golang-api/database
github.com/ArkjuniorK/gofiber-boilerplate/internal/middleware
github.com/ArkjuniorK/gofiber-boilerplate/internal/core
github.com/Southclaws/storyden/internal/infrastructure/pubsub/queue
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/components/metrics
github.com/golang-boy/watermill/internal/publisher
github.com/golang-boy/watermill/internal/subscriber
github.com/golang-boy/watermill/message/subscriber
github.com/golang-boy/watermill/pubsub/gochannel
github.com/golang-boy/watermill/pubsub/tests
github.com/golang-boy/watermill/message/router/middleware
github.com/golang-boy/watermill/message/router/plugin
github.com/apoldev/trackchecker/internal/app/track/delivery/watermill-kafka
github.com/Southclaws/storyden/internal/infrastructure/pubsub/watermill
github.com/pog7x/go-rmq-worker-tmpl/internal/subscribers/sub
github.com/program-world-labs/DDDGo/internal/app
github.com/program-world-labs/DDDGo/pkg/message
github.com/program-world-labs/DDDGo/internal/adapter/message
github.com/program-world-labs/DDDGo/internal/adapter/message/role
github.com/program-world-labs/DDDGo/internal/adapter/message/user
github.com/flexprice/flexprice/internal/kafka
github.com/flexprice/flexprice/internal/pubsub
github.com/flexprice/flexprice/internal/testutil
github.com/flexprice/flexprice/internal/pubsub/router
github.com/flexprice/flexprice/internal/pubsub/memory
github.com/flexprice/flexprice/internal/pubsub/kafka
github.com/flexprice/flexprice/internal/webhook/publisher
github.com/flexprice/flexprice/internal/webhook/handler
github.com/pog7x/go-rmq-worker-tmpl/internal/publishers/pub
github.com/opsway-io/backend/internal/event
github.com/pog7x/go-rmq-worker-tmpl/internal/marshalers
github.com/pog7x/go-rmq-worker-tmpl/internal/middleware
github.com/pog7x/go-rmq-worker-tmpl/internal/app
github.com/roessland/withoutings/pkg/withoutings/app/command
github.com/chingkamhing/hello-watermill
github.com/roessland/withoutings/pkg/withoutings/port
github.com/roessland/withoutings/pkg/withoutings/app
github.com/roessland/withoutings/pkg/worker
github.com/GSH-LAN/Unwindia_MS_dotlan/src/worker
github.com/KirylJazzSax/watermill-eventstore/pkg/esdb
github.com/ShmelJUJ/software-engineering/pkg/kafka
github.com/ShmelJUJ/software-engineering/pkg/kafka/mocks
github.com/ShmelJUJ/software-engineering/monitor/internal/broker/publisher
github.com/ShmelJUJ/software-engineering/monitor/internal/broker/subscriber
github.com/ShmelJUJ/software-engineering/payment_gateway/internal/broker/publisher
github.com/ShmelJUJ/software-engineering/payment_gateway/internal/broker/subscriber
github.com/dbacilio88/golang-grpc-email-microservice/internal/event/broker
github.com/cunyat/watermill-mongodb/pkg/mongodb
github.com/darjun/go-daily-lib/watermill/middleware/self-defined
github.com/darjun/go-daily-lib/watermill/router
github.com/darjun/go-daily-lib/watermill/rabbitmq
github.com/darjun/go-daily-lib/watermill/persistent
github.com/darjun/go-daily-lib/watermill/middleware
github.com/darjun/go-daily-lib/watermill/get-started
github.com/quintodown/quintodownbot/internal/handlers/games
github.com/quintodown/quintodownbot/internal/games
github.com/fengzhongzhu1621/xgo/amqp/router/plugin
github.com/quintodown/quintodownbot/internal/handlers
github.com/quintodown/quintodownbot/internal/bot
github.com/quintodown/quintodownbot/internal/pubsub
github.com/elct9620/wvs/internal/subscriber
github.com/elct9620/wvs/internal/db
github.com/elct9620/wvs/internal/app
github.com/NpoolPlatform/go-service-framework/pkg/pubsub
github.com/sandrolain/gomsvc/pkg/mqttlib/mqttwatermill
github.com/golang-tire/auth/internal/pkg/pubsub
github.com/golang-tire/auth/internal/auth
github.com/golang-tire/auth/internal/entity
github.com/go-quiz/go-daily-lib/watermill/middleware/self-defined
github.com/go-quiz/go-daily-lib/watermill/router
github.com/go-quiz/go-daily-lib/watermill/rabbitmq
github.com/go-quiz/go-daily-lib/watermill/persistent
github.com/go-quiz/go-daily-lib/watermill/middleware
github.com/go-quiz/go-daily-lib/watermill/get-started
github.com/smart-edge-open/edgeservices/pkg/mock
github.com/smart-edge-open/edgeservices/pkg/eaa
github.com/neo-classic/golang-playground/events/watermill/pub_sub/subscriber2
github.com/neo-classic/golang-playground/events/watermill/pub_sub/subscriber
github.com/neo-classic/golang-playground/events/watermill/pub_sub/publisher
github.com/javiyt/tweetgram/internal/handlers
github.com/javiyt/tweetgram/internal/bot
github.com/javiyt/tweetgram/internal/pubsub
github.com/ThreeDotsLabs/watermill-benchmark/pkg
github.com/sagikazarmark/modern-go-application/internal/app/mga
github.com/sagikazarmark/modern-go-application/internal/platform/watermill
github.com/ThreeDotsLabs/event-driven-example/pkg
github.com/wudtichaikarun/watermill_101
github.com/ThreeDotsLabs/event-driven-example/cmd
github.com/andrei-cloud/watermill-oraq/pkg/aq
github.com/bmstu-itstech/itsreg-bots/internal/infra
github.com/jujili/double-EWMA-backtest-demo
github.com/codingDr/watermill-kafka/pkg/kafka
github.com/davidroman0O/watermill-comfymill
github.com/sysradium/debezium-outbox-example/users-service/internal/outbox/basic
github.com/sysradium/debezium-outbox-example/notifications-service/internal/handlers
github.com/weflux/fluxworks/messaging