watermill

watermill copied to clipboard

channel: when the production is much larger than the consumption, it will cause the goroutine to grow infinitely?

2

When the production is much larger than the consumption, it will cause the goroutine to grow infinitely? ```go func (g *GoChannel) sendMessage(topic string, message *message.Message) (

zc2638

AWS Kinesis Pub/Sub implementation

1

Implementing Pubblisher and Subscriber for A[WS Kinesis](https://aws.amazon.com/kinesis/). It is like Kafka but managed. We can use [Go SDK](https://docs.aws.amazon.com/sdk-for-go/api/service/kinesis/).

theShadow89

GoChannel pub/sub shouldn't force retry at sendMessageToSubscriber

5

Due to the underlying processing logic, GoChannel pub/sub will never stop resending NACK messages, at a crazy speed. It shouldn't do retry work here. It's better to handle on the...

woostundy

http router webhooks haven't protection and not returns error to http client.

IgorDePaula

How to subscribe to all gochannel ?

6

Hi, I'd like to subscribe/listen to anything in a gochannel. It's possible ? Something like ```golang s.Channel.Subscribe(context.Background(), "*") // To subscribe to `everything` ``` thanks

GreyXor

Bump oklog/ulid from v1.3.1 to v2.1.0

2

gaiaz-iusipov

Uses old Nats.

6

https://github.com/ThreeDotsLabs/watermill/tree/master/_examples/real-world-examples/server-sent-events Needs upgrading to new nats jetstream public api: https://github.com/nats-io/nats.go/tree/main/jetstream I have not checked what other examples use the old nats streaming yet

gedw99

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

2

The go.mod still says: `require github.com/Shopify/sarama v1.38.0` The sarama lib is now available under https://github.com/IBM/sarama, this should be reflected in the go.mod (although there is some forwarding from https://github.com/shopify/sarama to...

jens1205

For Example: ```go package main import ( "context" "github.com/ThreeDotsLabs/watermill" "github.com/ThreeDotsLabs/watermill/manager" "github.com/ThreeDotsLabs/watermill/message" "github.com/ThreeDotsLabs/watermill/pubsub/gochannel" ) func main() { m := manager.New(gochannel.NewGoChannel( gochannel.Config{}, watermill.NewStdLogger(false, false), )) m.Register("another", gochannel.NewGoChannel( gochannel.Config{}, watermill.NewStdLogger(false, false), )) //...

flc1125

While trying to figure out how to use watermill-sql, it occurred that the newest version is v3, and the examples use v2. This updates all occurrences of watermill-sql/v2 in the...

thpk