ThreeDotsLabs/watermill

Issues

• The publish signature does not allow for a context.Context to be passed

  #445 opened 4 days ago by advdv
  0

• Watermill tests fail on windows

  #443 opened 7 days ago by HolyKingCrusader
  0

• Only post messages after subscribing

  #442 opened 9 days ago by aimuz
  0

• Can you output the message metadata to the logs?

  #440 opened 15 days ago by ansoda
  0

• How to process a batch of received messages instead of a single piece?

  #439 opened 18 days ago by zc2638
  0

• [watermill-kafka] use github.com/IBM/sarama

  #388 opened 18 days ago by jens1205
  2

• EventGroupProcessor does only execute the first registered handler for each event type

  #402 opened 8 months ago by Darkskald
  3

• Invalid publisher name in metrics

  #436 opened a month ago by fetinin
  0

• Resume after shutdown always fetch last interrupted message again

  #437 opened a month ago by chingkamhing
  0

• Log custom fields inside message router

  #434 opened a month ago by fetinin
  0

• Is it possible to get google pubsub server generated unique message-id?

  #430 opened 2 months ago by arthurspa
  3

• SQLite driver

  #433 opened 2 months ago by dkotik
  1

• How to delete message after ack?

  #428 opened 2 months ago by yl
  1

• Data race on Publish for Google pubsub

  #432 opened 2 months ago by tsurunoyu
  0

• watermill-sql cannot run in a MariaDB

  #377 opened 2 months ago by yashen
  1

• Context not being propagated through command bus

  #429 opened 2 months ago by saikapuluru99
  2

• Does Watermill support publishing delayed (set to a a future time) messages?

  #378 opened 9 months ago by preslavrachev
  6

• Generated topic names for PubSub tests does not conform with Azure guidelines

  #424 opened 3 months ago by unjello
  0

• Log with fields on error in router

  #409 opened 7 months ago by ivaaaan
  3

• PGX Subscriber InvalidIfaceAssign

  #408 opened 7 months ago by TeddyLourson
  1

• Any plans to add support of RabbitMQ Streaming?

  #422 opened 3 months ago by Amf1k
  0

• How to subscribe to all gochannel ?

  #421 opened 4 months ago by GreyXor
  1

• Uses old Nats.

  #381 opened 9 months ago by gedw99
  6

• Publish message processing delay in metrics Middleware?

  #417 opened 5 months ago by evankanderson
  0

• nats jetstream consumer always received old ack message

  #389 opened 6 months ago by gatspy
  8

• `msg.Nack` causes infinite loop with gochannel pubsub

  #414 opened 6 months ago by Nikola-Milovic
  4

• follow-up handler will be broke while before msg handler error, what is the best practice for this situation？

  #413 opened 6 months ago by victory460
  0

• MaxOutstandingMessages doesn't seem to be working

  #412 opened 6 months ago by ATahhan
  0

• s

  #411 opened 6 months ago by germainc
  0

• Slog with `AddSource: true` is not working correctly due to wrapper in watermill

  #404 opened 7 months ago by ganeshdipdumbare
  0

• [watermill-kafka] - cannot process events concurrently without ACKing the event

  #374 opened 10 months ago by nachogiljaldo
  8

• Skip First Publisher in Router

  #399 opened 8 months ago by luabagg
  3

• Very basic publishing of Message to Apache Kafka Topic Fails

  #364 opened a year ago by Tobi696
  2

• Allow for custom labels on prometheus metrics

  #392 opened 9 months ago by matdurand
  0

• Data doesn't get removed from subscribers and subscribersByTopicLock maps (GoChannel pub/sub)

  #391 opened 9 months ago by avlajcic-axilis
  0

• [Questions] How to build modular monolith using watermill

  #368 opened 9 months ago by g41797
  0

• [watermill-nats] new jetstream API

  #373 opened 10 months ago by AlexCuse
  1

• Blocking in GoChannel `sendMessageToSubscriber`

  #382 opened 9 months ago by qiulin
  0

• [watermill-kafka] "read tcp <ip>:<port>: i/o timeout" when kafka rebalances

  #376 opened 10 months ago by zaidoon1
  2

• [watermill-nats] Calling Unsubscribe for nats.Subscriber can lead to unexpected behaviour

  #375 opened 10 months ago by zdraganov
  1

• [watermill-sql] Use TIMESTAMP WITH TIME ZONE instead of plain TIMESTAMP

  #379 opened 9 months ago by preslavrachev
  0

• [watermill-nats] smarter auto-provisioning

  #369 opened a year ago by AlexCuse
  2

• [watermill-kafka] make update_watermill failed with `sed: 1: "go.mod": extra characters at the end of g command`

  #365 opened a year ago by tjnet
  0

• Vulnerability in github.com/ThreeDotsLabs/watermill-sql

  #362 opened a year ago by guigoebel
  3

• Update examples to use nats jetstream

  #363 opened a year ago by gedw99
  0

• Multiple subscribers/handlers for a single topic?

  #361 opened a year ago by ivaaaan
  2

• Event sourcing with files

  #350 opened a year ago by gedw99
  0

• [watermill-googlecloud] Subscription configuration update support

  #360 opened a year ago by condorcet
  0

• Can you support Qstash in Upstash for serverless?

  #359 opened a year ago by phpmaple
  0

• [watermill-googlecloud] panic: close of closed channel goroutine

  #351 opened a year ago by henzai
  0