watermill

watermill copied to clipboard

Have you seen yubabyte db. Its 100% open equivalent to Cockroach. https://github.com/yugabyte/yugabyte-db It uses a Postresql api have redis api and cassandra api too but its all done with the...

winwisely99

Add CloudEvents integration

5

[CloudEvents](https://cloudevents.io/) is a specification for sending events in the cloud native environment. They also provide SDKs. It might be a good addition to the project to support CloudEvents. Although it's...

sagikazarmark

Replace kafka-console-consumer with Mill in examples

1

Basically, we don't need to have kafka-console-consumer, we have mill instead: https://github.com/ThreeDotsLabs/watermill/tree/master/tools/mill It would be nice to replace it in all examples.

roblaszczak

amqp message rejected if header is not string

11

I've got message with header that is not string, and it gets rejected by watermill: `[watermill] 2019/04/17 15:48:14.371452 subscriber.go:245: level=ERROR msg="Processing message failed, sending nack" amqp_exchange_name=x amqp_queue_name=y err="metadata x-death is...

danielllek

Better integration with opentracing

2

Jaeger is kind of multilanguage standard for opentracing -> https://www.jaegertracing.io/ The **required** header name ``` const MessageUUIDHeaderKey = "_watermill_message_uuid" ``` Is Watermill specific, but messages produced/consumed by this library can...

bkielbasa

Integration with go cloud development toolkit pubsub

2

Hey guys. First of all compliments on the project! Recently i came across the pubsub abstraction in the google cloud development toolkit: https://gocloud.dev/pages/pubsub. I think it would be a great...

Bouwdie

WIP: Add shorthand functions for topic name and subscriber generators

1

As always: suggestions for better names are welcome.

sagikazarmark

Fix #275 and add gochannel concurreny control

1

Removed the sending lock, and replaced it with a channel to control concurrency.

woostundy

Router persists in running state after closing it

3

**What happened**: Running `router.Run` after `router.Close` returns an error `router is already running`. Apparently the router's [internal state](https://github.com/ThreeDotsLabs/watermill/blob/master/message/router.go#L338) `router.isRunning` persists in `true` state even after the call to `router.Close`. This...

mjjs

Does watermill supports request reply pattern using NATS ?

2

I could not find any docs for the request reply pattern using watermill

khanakia