watermill

watermill copied to clipboard

Allow batch reading in watermill-sql

3

The current implementation of watermill-sql does read exactly one message at the time (PostgreSQL implementation: https://github.com/ThreeDotsLabs/watermill-sql/blob/master/pkg/sql/schema_adapter_postgresql.go#L66). I assume a significant subscriber performance improvement, if the subscriber could read the messages...

breml

[watermill-sql] Nacked message stays within one consumer

1

In watermill-sql, a bad behaving consumer, which always nacks an incoming message will completely block processing of messages in the respective consumer group, because the nack does not return the...

breml

I've got a question. At the moment from the examples I can see, the events are published after some processing is done in a command handler. It may lead to...

screwyprof

PostgreSQL LISTEN/NOTIFY Subscriber

1

The same as #5, but for PostgreSQL :) This implementation should be added in https://github.com/ThreeDotsLabs/watermill-sql/ repository. It **need to be compatible with already existing SQL Subscriber**. That means, that you...

roblaszczak

Bring sql driver on par with benchmark implementation

2

In the benchmark, there have been made some changes related to the sql driver, that have never been fed back to the actual sql driver (watermill-sql). For PostgreSQL driver: *...

breml

CorrelationID does not work with CQRS Facade

1

CommandProcessor.AddHandlersToRouter uses internally AddNoPublisherHandler to add a handler to a router CorrelationID middleware does not work. Since it assumes that the handler should return a list of new messages but...

cotton-more

Dear watermill team, I think that [watermill-kafka](https://github.com/ThreeDotsLabs/watermill-kafka) should be upgraded to use sarama version 1.26.4. As stated in sarama v1.26.0 release note, we should not use this version anymore. Version...

cikupin

Sagas support

2

roblaszczak

[watermill-amqp] What is the mechanism of exception handling?

6

If my rabbmit restarts How to reestablish channel [watermill] 2020/03/13 08:59:33.510953 subscriber.go:166: level=INFO msg="Starting consuming from AMQP channel" amqp_exchange_name= amqp_queue_name=listen_result_b111ad19-e4c0-4730-805c-3a44b5b7727f topic=listen_result_b111ad19-e4c0-4730-805c-3a44b5b7727f

duolabmeng6

message subscriber BulkRead idle timeout or receive timeout

1

I've created a PR to describe what looks like an unintended side affect. What I'm proposing is to illustrate what I think is wrong. It may not be the correct...

kevpie