Repository Issue Activity (beta)

#360 [watermill-googlecloud] Subscription configuration update support

#572 Pub/Sub suport for Pocketbase

#693 [watermill-amqp] Data race on ConnectionWrapper.connected between IsConnected() and handleConnectionClose()

#691 bug: ReconnectRetrySleep is ignored when group.Consume fails, causing unbounded reconnect churn

#583 can watermill kafka client support sarama.NewAsyncProducer() ?

#692 Another gochannel pubsub question

#557 MQTT PubSub Implementation

#126 PostgreSQL LISTEN/NOTIFY Subscriber

#480 Add a method which can be used to get the age of the oldest event in the queue

#522 Watermill HTTP support http2 and chi-v5

#65 amqp message rejected if header is not string

#545 Is there any way to write clean up hook after max retries?

#677 Bug: SQL logic error in MySQL Storage due to missing parentheses in WHERE clause

#645 Retry middleware skipped and message sent directly to PoisonQueue when using AddHandler

#614 watermill\_examples\real-world-examples\delayed-messages no work

#664 run.go: HTTP response body leak and potential goroutine deadlock

#676 NATS Jetstream silently fails too fast

#671 Messages duplication issue

#389 nats jetstream consumer always received old ack message

#626 Deduplication middleware backed by Redis

#666 Logger severity setup not compatible with GCP logger

#150 YugabyteDB

#646 SNS Subscription attributes that might change between version of the app causes startup failure

#641 [watermill-redisstream] proto.RedisError NOGROUP No such key

#224 [watermill-sql] Nacked message stays within one consumer