message

package

Go to main page

Known importers: 796 (displaying 1,126 packages, including internal and invalid packages)

bitbucket.org/lugimanf_/gocommon/mq
bitbucket.org/napche/workbench/godog/pkg

code.vikunja.io/api/ (4)

gitea.dwysokinski.me/twhelp/ (5)

gitea.programmerfamily.com/go/ (2)

gitee.com/jerryduren/architecture/ (8)

gitee.com/wanjimao/dongli-kit/ (3)

github.com/0michalsokolowski0/watermill/ (11)

github.com/1layar/universe/ (31)

github.com/AlexCuse/watermill-jetstream/pkg/jetstream

github.com/ArkjuniorK/gofiber-boilerplate/ (2)

github.com/Black-And-White-Club/ (34)

github.com/Black-And-White-Club/frolf-bot-shared/eventbus

github.com/Black-And-White-Club/frolf-bot/ (33)

github.com/Brandon2255p/watermill-eventstore/eventstore

github.com/DIMO-Network/ (3)

github.com/DIMO-Network/devices-api/ (2)

github.com/DIMO-Network/vehicle-signal-decoding/internal/infrastructure/kafka

github.com/DoNewsCode/core-pubsub

github.com/EraldCaka/broker/ (3)

github.com/GSH-LAN/ (7)

github.com/GSH-LAN/Unwindia_MS_dotlan/src/worker
github.com/GSH-LAN/Unwindia_dotlan_forum_manager/cmd/unwindia_dotlan_forum_manager/messagequeue

github.com/GSH-LAN/Unwindia_pterodactyl/ (3)

github.com/GSH-LAN/Unwindia_tmt2/ (2)

github.com/GabrielCarpr/cqrs/bus/queue/sql
github.com/Goorsky1/dns-mgmt/common/rabbitmq

github.com/HnH/choreographer/ (3)

github.com/Homeppv2/aggregator/internal/controller

github.com/Improwised/golang-api/ (3)

github.com/Jeanhwea/baliqiao3/ (2)

github.com/KejawenLab/bima/ (5)

github.com/Kichiyaki/watermillplayground/ (3)

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/ (15)

github.com/SebastianM/watermill-liftbridge

github.com/ShmelJUJ/software-engineering/ (8)

github.com/THreeDotsLabs/watermill/ (11)

github.com/ThreeDotsLabs/ (44)

github.com/ThreeDotsLabs/Watermill/ (11)

github.com/ThreeDotsLabs/event-driven-example/ (2)

github.com/ThreeDotsLabs/go-event-driven/common/log

github.com/ThreeDotsLabs/watermill-amqp/ (3)

github.com/ThreeDotsLabs/watermill-aws/ (2)

github.com/ThreeDotsLabs/watermill-benchmark/pkg
github.com/ThreeDotsLabs/watermill-bolt/pkg/bolt

github.com/ThreeDotsLabs/watermill-firestore/ (4)

github.com/ThreeDotsLabs/watermill-googlecloud/pkg/googlecloud

github.com/ThreeDotsLabs/watermill-http/ (2)

github.com/ThreeDotsLabs/watermill-io/pkg/io

github.com/ThreeDotsLabs/watermill-jetstream/ (2)

github.com/ThreeDotsLabs/watermill-kafka/ (3)

github.com/ThreeDotsLabs/watermill-nats/ (3)

github.com/ThreeDotsLabs/watermill-redisstream/pkg/redisstream

github.com/ThreeDotsLabs/watermill-sql/ (4)

github.com/ThreeDotsLabs/watermill/ (2)

github.com/UnAfraid/watermill-googlecloud/pkg/googlecloud
github.com/Unheilbar/test_kafka

github.com/ZhanibekTau/go-sdk/ (2)

github.com/Zondax/zindexer/components/connections/pub_sub

github.com/abialemuel/ (4)

github.com/abialemuel/AI-Proxy-Service/ (2)

github.com/abialemuel/billing-engine/ (2)

github.com/achuala/go-svc-extn/ (2)

github.com/acs-dl/ (21)

github.com/acs-dl/auth-svc/ (2)

github.com/acs-dl/github-module-svc/ (3)

github.com/acs-dl/gitlab-module-svc/ (3)

github.com/acs-dl/identity-svc/internal/receiver

github.com/acs-dl/mail-module-svc/ (3)

github.com/acs-dl/orchestrator-svc/ (2)

github.com/acs-dl/slack-module-svc/ (3)

github.com/acs-dl/telegram-module-svc/ (3)

github.com/acs-dl/unverified-svc/internal/receiver

github.com/actatum/tk/log

github.com/agalue/ (2)

github.com/aiocean/wireset/ (2)

github.com/alexcuse/edgex-watermill (9)

github.com/alexinteam/nats/cmd
github.com/andrei-cloud/watermill-oraq/pkg/aq

github.com/andrestielau/web-of-hooks/ (8)

github.com/andyollylarkin/watermill-net (5)

github.com/apedorenkoS/watermill-amqp-demo/ (6)

github.com/apoldev/trackchecker/internal/app/track/delivery/watermill-kafka
github.com/arashrasoulzadeh/go-game-engine/worker

github.com/artyomturkin/ (5)

github.com/artyomturkin/appfx (2)

github.com/artyomturkin/go-from-uri/ (2)

github.com/artyomturkin/watermill-extension

github.com/as-rabbit/go-connect/event_driven/events/water-mill

github.com/asyncapi/event-gateway (6)

github.com/atropos112/gocore/pubsub
github.com/ayinke-llc/malak/internal/pkg/queue/watermill
github.com/baerla/go-sse-htmx

github.com/banzaicloud/pipeline/ (2)

github.com/baselrabia/messaging-nats-watermill (6)

github.com/belo4ya/live-streaming-service/ (2)

github.com/bimalabs/framework/ (3)

github.com/bmcszk/effective-monorepo/ (3)

github.com/bmstu-itstech/itsreg-bots/ (4)

github.com/bobyhw39/go-strapper/interfaces
github.com/boreq/watermill-bolt/pkg/bolt

github.com/braveheart12/insolar-27-10-19/ (17)

github.com/brittonhayes/staffing/ (3)

github.com/c13n-io/c13n-go/app
github.com/caesar-rocks/events

github.com/caitunai/go-blueprint/ (2)

github.com/caspr-io/mu-kit/streaming
github.com/chennqqi/watermill-nsq/pkg/nsq

github.com/chiennguyen196/go-library/ (2)

github.com/chingkamhing/hello-watermill
github.com/cikupin/learn-firehose/cmd

github.com/cirruslabs/core-services/ (3)

github.com/ckbball/smurfin-email
github.com/cockroachdb/watermill-crdb/pkg/crdb

github.com/codebind-luna/telemetry-demo/ (4)

github.com/codingDr/watermill-kafka/pkg/kafka

github.com/coobeet/go-event-driven/ (8)

github.com/crochee/lirity/ (2)

github.com/crowdeco/ (4)

github.com/crowdeco/bima/ (2)

github.com/crowdeco/chili/ (2)

github.com/cunyat/watermill-mongodb/pkg/mongodb

github.com/cybersamx/go-recipes/ (2)

github.com/czeslavo/ (7)

github.com/czeslavo/process-manager/1_voiding

github.com/czeslavo/watermill-firestore/ (5)

github.com/czeslavo/watermill-opencensus

github.com/daniel840829/eventcore

github.com/darjun/go-daily-lib/ (6)

github.com/data233/watermill-nsq/pkg/nsq

github.com/datoga/highperformancearchitecture/ (2)

github.com/davideimola/watermill-pgx/pkg/sql

github.com/davidroman0O/ (4)

github.com/davidroman0O/gronos/ (2)

github.com/davidroman0O/watermill-comfymill (2)

github.com/dbacilio88/ (2)

github.com/delaram-gholampoor-sagha/sd-studio/ (4)

github.com/demeero/ (2)

github.com/dentech-floss/ (4)

github.com/dentechse/ (2)

github.com/depocket/support/queue
github.com/dgnydn/binance-order/internal/platform/watermill
github.com/digitive/watermill-rsjm

github.com/dkotik/watermillchat (2)

github.com/dloukadakis/watermill-googlecloud/pkg/googlecloud
github.com/dmitrymomot/go-pkg/cqrs

github.com/dobermanndotdev/dobermann/ (5)

github.com/dprcoles/kafka-pubsub/ (3)

github.com/dvictor/watermill-kinesis (3)

github.com/dwlpra/ (5)

github.com/dwlpra/pubsub/ (3)

github.com/dwlpra/pubsubs/ (2)

github.com/dxps/asyncapi_playground/streetlights_go/goapp/asyncapi

github.com/eclipse-kanto/ (22)

github.com/eclipse-kanto/aws-connector/ (6)

github.com/eclipse-kanto/azure-connector/ (5)

github.com/eclipse-kanto/local-digital-twins/ (4)

github.com/eclipse-kanto/suite-bootstrapping/ (2)

github.com/eclipse-kanto/suite-connector/ (5)

github.com/eclipse-leda/leda-contrib-cloud-connector/ (2)

github.com/elaletovic/events-to-graph (3)

github.com/elct9620/wvs/ (3)

github.com/espitman/gws-chat/chat-service/internal/core/service

github.com/evertontomalok/distributed-system-go/ (4)

github.com/f1monkey/f1monkey/ (4)

github.com/faizalnurrozi/ (2)

github.com/faozimipa/event-driven/ (2)

github.com/fengzhongzhu1621/xgo/amqp/router/plugin
github.com/fi3te/hello-go/threedotslabs-watermill

github.com/flexprice/flexprice/ (2)

github.com/flowline-io/flowbot/ (2)

github.com/flux-agi/flux_go/ (2)

github.com/foomo/sesamy-go/ (3)

github.com/formancehq/ (10)

github.com/formancehq/go-libs/ (6)

github.com/formancehq/payments/cmd

github.com/formancehq/stack/ (3)

github.com/fwidjaya20/symphonic/event

github.com/gabeduke/reap/ (2)

github.com/gearpoint/filepoint/ (6)

github.com/gelleson/changescout/ (3)

github.com/gera-cl/xk6-pubsub

github.com/getzep/zep/ (2)

github.com/githubzhaoqian/ (2)

github.com/go-apis/eventsourcing/ (2)

github.com/go-baselib/ (7)

github.com/go-baselib/new-user-task-with-event-driven/ (5)

github.com/go-baselib/postgresql-cdc/ (2)

github.com/go-feast/resty-backend/ (14)

github.com/go-go-golems/ (13)

github.com/go-go-golems/geppetto/ (6)

github.com/go-go-golems/go-go-labs/ (4)

github.com/go-go-golems/pinocchio/ (3)

github.com/go-leo/ (8)

github.com/go-leo/example/ (3)

github.com/go-leo/leo (2)

github.com/go-leo/middleware/ (2)

github.com/go-leo/pubsub

github.com/go-micro-saas/nodeid-service/app/nodeid-service/internal/biz/event

github.com/go-quiz/go-daily-lib/ (6)

github.com/golang-boy/watermill/ (11)

github.com/golang-tire/auth/ (3)

github.com/goph/watermillx

github.com/gothunder/thunder/ (2)

github.com/grafov/watermill-sql/pkg/sql

github.com/gregszalay/ocpp-csms/ (8)

github.com/growerlab/growerlab/ (2)

github.com/gstones/moke-kit/ (3)

github.com/gwoodwa1/event-driven-example/ (4)

github.com/hendratommy/protobus

github.com/hpcslag/ (2)

github.com/hysios/x/ (2)

github.com/id-cheng/awesome-go-lib/ (3)

github.com/igmagollo/undine/ (2)

github.com/ijidan/jsocial/internal/pkg/pubsub
github.com/ikaiguang/go-srv-kit/data/rabbitmq
github.com/illidaris/watermillex/kafkaex

github.com/insolar/ (39)

github.com/insolar/assured-ledger/ (22)

github.com/insolar/insolar/ (17)

github.com/integer-technologies-b-v/watermill-sql/ (2)

github.com/isaquesb/url-shortener/ (3)

github.com/ischenkx/kantoku/pkg/common/transport/broker/watermill

github.com/jackgris/twitter-backend/ (6)

github.com/jackie8tao/ezjob/ (2)

github.com/javiyt/tweetgram/ (3)

github.com/jawr/whois-bi/pkg/internal/job

github.com/jeffmingup/watermill-rocketmq/ (2)

github.com/jerry-yt-chen/event-sourcing-poc/ (2)

github.com/jujili/ (6)

github.com/jujili/jili/ (2)

github.com/kachvame/gayway/ (2)

github.com/kahowell/watermill-amqp10/pkg/amqp10

github.com/kasper023/shop/ (2)

github.com/kaspermroz/go-message-backend/ (4)

github.com/kecci/go-watermill/go-channel
github.com/kitabisa/perkakas/v2/middleware

github.com/kitanoyoru/kitaDriveBot/ (2)

github.com/kkoji/nats-example/publisher

github.com/kkszysiu/watermill-aws-rm/ (2)

github.com/kucjac/cleango/ (2)

github.com/kuldeep-kg/event-manager/ (2)

github.com/lamassuiot/lamassuiot/ (10)

github.com/lamhai1401/forwarder/fwd

github.com/lcnascimento/go-kit/ (4)

github.com/lejenome/lro/services/process-executor/lib/process/queues

github.com/maheswaradevo/order-backend/ (3)

github.com/makhov/aiven-checker/ (2)

github.com/malamtime/cli/daemon

github.com/mannion007/payments-prototype (2)

github.com/marlongerson/watermill-amqp/v2/pkg/amqp

github.com/mateusmacedo/go-bff/ (3)

github.com/matroskin13/mongosubscriber (2)

github.com/medinae/watermill-googlecloud/pkg/googlecloud
github.com/message-board/identity-go

github.com/mfreeman451/dd-chatgpt-dm/ (6)

github.com/mgjules/spoty/transport/messenger

github.com/mindersec/minder/ (31)

github.com/minghsu0107/ (10)

github.com/minghsu0107/saga-product/ (6)

github.com/minghsu0107/saga-purchase/ (4)

github.com/mjjs/watermill-close-bugreport

github.com/ml4wireless/specpipe/ (2)

github.com/muktiarafi/ (4)

github.com/muktiarafi/ticketing-common (2)

github.com/muktiarafi/ticketing-payments/ (2)

github.com/myfintech/ark/src/go/lib/ark/cqrs/protocols/watermill/gochannel
github.com/neermitt/watermill-zeebe/pkg/zeebe

github.com/nekizz/final-project/ (10)

github.com/neo-classic/golang-playground/ (3)

github.com/nkamuo/rasta-server/tests

github.com/noodlensk/task-tracker/ (17)

github.com/notblessy/go-writter-backend/ (2)

github.com/numary/ledger/pkg/bus
github.com/olvod/xk6-pubsub

github.com/omran95/chat-app/ (3)

github.com/onyxhat/watermill-test
github.com/opsway-io/backend/internal/event
github.com/ormanli/rest-kafka-bridge-example

github.com/pbalogh-sa/modern-go-application/ (4)

github.com/pedropilla/xk6-pubsub

github.com/peopledata/oak/ (14)

github.com/perfect13/watermill-mqtt

github.com/persys-dev/persys-cloud/ (7)

github.com/peterdev80/watercc

github.com/piotr-rusin/playing-with-golang/ (2)

github.com/planetary-social/nos-event-service/service/adapters/gcp

github.com/pmoura-dev/esr-service/ (4)

github.com/pog7x/go-rmq-worker-tmpl/ (5)

github.com/pperaltaisern/esrcwatermill

github.com/prasetyowira/message/ (5)

github.com/program-world-labs/DDDGo/ (5)

github.com/protomem/chatik/internal/stream
github.com/purposeinplay/go-commons/pubsub/kafka

github.com/qairjar/ (3)

github.com/qiulin/watermill-kafkago/pkg/kafkago

github.com/qmstar0/BlogLite-api/ (3)

github.com/quintodown/quintodownbot/ (5)

github.com/qulaz/tg-exporter/backend/shared/events
github.com/raihansuwanto/audit-trail

github.com/rakamoviz/kincirair/ (11)

github.com/ramadani/starboost/ (2)

github.com/renevo/mcutils/ (6)

github.com/rizalgowandy/gdk/ (4)

github.com/rkaw92/schedcore

github.com/roblaszczak/room-reservation-system/ (2)

github.com/robot-nan/watermill-rocketmq-aliyun/pkg/rocketmq

github.com/roessland/withoutings/ (4)

github.com/rome314/3-commas-ws-forwarder/ (2)

github.com/ronen25/entro-task

github.com/rotationalio/ (5)

github.com/rotationalio/baleen (4)

github.com/rotationalio/watermill-ensign/pkg/ensign

github.com/runner-mei/moo/ (2)

github.com/ryanyogan/watermill-basics

github.com/sagikazarmark/ (3)

github.com/sagikazarmark/modern-go-application/ (2)

github.com/sagikazarmark/ocwatermill

github.com/sandrolain/gomsvc/pkg/mqttlib/mqttwatermill
github.com/sanservices/kit/kafkalistener
github.com/saturn4er/boilerplate-go/lib/txoutbox/txoutboxwatermill
github.com/seanb4t/mu-portal-server/internal/platform/watermill

github.com/sftfjugg/go-daily-lib/ (6)

github.com/sgeisbacher/distributed-photo-gallery/ (2)

github.com/shopd/ih2024

github.com/shumkovdenis/asyncapi-gen/ (2)

github.com/siangyeh8818/watermill.golang-project
github.com/skiprco/go-utils/v4/event

github.com/smart-edge-open/edgeservices/ (2)

github.com/starton-io/tyrscale/ (9)

github.com/stevecallear/watermill-badger/pkg/badger

github.com/stong1994/watermill-rediszset/ (3)

github.com/studiobflat/tsj/redis

github.com/subscribeddotdev/ (8)

github.com/subscribeddotdev/subscribed-backend/ (4)

github.com/subscribeddotdev/subscribed/ (4)

github.com/suifengpiao14/cudevent (2)

github.com/sunyakun/gearbox/ (2)

github.com/sysradium/ (10)

github.com/sysradium/debezium-events-aggregation/ (2)

github.com/sysradium/debezium-outbox-example/ (2)

github.com/sysradium/petproject/ (6)

github.com/talon-sec/watermill-kafka/v2/pkg/kafka
github.com/tehbilly/ges/cmd/demo

github.com/thienhaole92/vnd/ (2)

github.com/thoughtnet/minds/tools
github.com/tiandh987/CGODemo/example/rolex/ptzV3/blp

github.com/tigorlazuardi/redmage/ (2)

github.com/tochamateusz/micro/modules/message-brokes/amqp

github.com/tommynurwantoro/kafkid/ (3)

github.com/trustbloc/orb/ (18)

github.com/ttagiyeva/superstream/ (4)

github.com/tuanvumaihuynh/roboflow/ (3)

github.com/tuihub/librarian/internal/lib/libmq

github.com/turao/go-ddd/ (3)

github.com/turbot/flowpipe/ (2)

github.com/tylerauerbeck/nats-otel-example

github.com/ugabiga/swan/ (2)

github.com/unicod3/horreum/ (3)

github.com/uniwise/marshal

github.com/voi-oss/ (2)

github.com/vpascoalr/goeda/ (2)

github.com/vseinstrumentiru/lego/ (10)

github.com/vungocson998/golang-watermill-practise
github.com/walterwanderley/watermill-sqlite

github.com/weezqyd/ringier/ (3)

github.com/weflux/fluxworks/ (2)

github.com/wesen/three-dots-go-driven-training/ (3)

github.com/wudtichaikarun/watermill_101
github.com/wyxloading/watermill-redisstream/pkg/redisstream
github.com/x1m3/tertulia/internal/pkg/pubsub
github.com/xyu-io/genie/msgchan

github.com/yangshun2005/go-daily-lib/ (6)

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

github.com/zouxingyuks/snaplink/ (2)

gitlab.com/aerilyn/ (3)

gitlab.com/aerilyn/service-item/internal/pkg/pubsub/rabbitmq

gitlab.com/aerilyn/service-library/ (2)

gitlab.com/afey13/erp-lib/ (2)

gitlab.com/danilpan/arm-shared/ (2)

gitlab.com/eemj/anime-pack/ (3)

gitlab.com/jimboylabs/music/providers/common/log

gitlab.com/kasi-labs/ (3)

gitlab.com/kasi-labs/kasi-go/ (2)

gitlab.com/kasi-labs/watermill-amqp/pkg/amqp

gitlab.com/nikolai.straessle/echomiddleware/ (2)

gitlab.com/peng-golang/pubsub/rabbit-mq

gitlab.d-cos.com/fky/ (2)

gitlab.screenvend.io/foss/ (5)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL