makasim/amqpextra issues and pull requests

#70 - Cancel consumer before closing channel

Pull Request - State: closed - Opened by makasim over 1 year ago

#69 - Consumer pool. In-process consumer autoscaling.

Pull Request - State: closed - Opened by makasim over 1 year ago

#68 - use publish with context

Pull Request - State: closed - Opened by makasim over 1 year ago

#67 - Update packages

Pull Request - State: closed - Opened by makasim over 1 year ago

#66 - notify ready state returns more details

Pull Request - State: closed - Opened by makasim over 1 year ago

#65 - add passive queue declaration support

Issue - State: open - Opened by Sauci almost 3 years ago

#64 - add WithTLS option

Pull Request - State: closed - Opened by Sauci over 3 years ago

#63 - Added WithRetryPeriodFunc option

Pull Request - State: closed - Opened by mahlunar over 3 years ago - 4 comments

#62 - WithRetryPeriod overload to enable custom retry strategies

Issue - State: closed - Opened by mahlunar over 3 years ago - 4 comments

#61 - Expand logger interface

Pull Request - State: closed - Opened by artezh over 3 years ago - 4 comments

#60 - Confirmation buffer on shutdown

Issue - State: open - Opened by Crevil over 3 years ago - 5 comments

#59 - publisher: notify state

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#58 - fix consumer states: amqp.ErrClosed notify into connectionState()

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#57 - dialer: notify state

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#56 - fix pr #54

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#55 - [dialer] Remove connection NotifyClose method.

Pull Request - State: closed - Opened by makasim almost 4 years ago

#54 - Fix consumer notify states

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#53 - Fix consumer notify states

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#52 - Fix consumer source exclusive flag

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#51 - Add WithQos options

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#50 - Dialer pool.

Pull Request - State: open - Opened by makasim almost 4 years ago

#49 - what is the right way to set channel.QOS for consumers

Issue - State: closed - Opened by shubhang93 almost 4 years ago - 1 comment

#48 - Dialer pool

Issue - State: open - Opened by makasim almost 4 years ago

#47 - Consume from exchange e2e

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#46 - Consumer from exchange

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#45 - Consumer from exchange

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago - 1 comment

#44 - Publisher confirms

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#43 - publisher confirm

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago - 2 comments

#42 - New fix ready unready dialer

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#41 - New consumer.Notify() method

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#40 - Notify() for the dialer connection

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#39 - fix ready/unready notifications for publisher

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#38 - Add comments to dialer

Pull Request - State: closed - Opened by makasim almost 4 years ago

#37 - fix ready/unready notification into consumer

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#36 - Fix ready/unready notifications for dialer/connection.go

Pull Request - State: closed - Opened by cat-in-vacuum almost 4 years ago

#35 - Add simple examples in readme

Issue - State: closed - Opened by BarthV almost 4 years ago - 3 comments

#34 - Consumer should return queue on NotifyReady

Issue - State: closed - Opened by makasim almost 4 years ago

#33 - Consume from exchange.

Issue - State: closed - Opened by makasim almost 4 years ago

#32 - new consumer return err, remove consumer.Run()

Pull Request - State: closed - Opened by makasim almost 4 years ago

#31 - Move toward Connection interface

Pull Request - State: closed - Opened by makasim almost 4 years ago

#30 - consumer, publisher: Add Notify prefix to notify methods

Pull Request - State: closed - Opened by makasim almost 4 years ago

#29 - Publisher publish and go

Pull Request - State: closed - Opened by makasim almost 4 years ago

#28 - Introduce connection interface.

Pull Request - State: closed - Opened by makasim about 4 years ago

#27 - Move logrus to standalone repo

Pull Request - State: closed - Opened by makasim about 4 years ago

#26 - Cancel consumption (if queue deleted)

Pull Request - State: closed - Opened by makasim about 4 years ago

#25 - publisher: implement flow control

Pull Request - State: closed - Opened by makasim about 4 years ago

#24 - open new channel when it was closed

Pull Request - State: closed - Opened by ASKozienko about 4 years ago

#23 - Publisher\Consumer V2

Pull Request - State: closed - Opened by makasim about 4 years ago

#22 - Add context to publishing struct

Pull Request - State: closed - Opened by makasim over 4 years ago

#21 - Add declare queue heplers

Pull Request - State: closed - Opened by makasim over 4 years ago

#20 - Add AckNack middleware

Pull Request - State: closed - Opened by makasim over 4 years ago

#19 - Skip sending error to already populated close channel

Pull Request - State: closed - Opened by makasim over 4 years ago

#18 - do not panic if empty urls

Pull Request - State: closed - Opened by ASKozienko over 4 years ago

#17 - Middleware logger logrus

Pull Request - State: closed - Opened by makasim over 4 years ago

#16 - Add goleak

Pull Request - State: closed - Opened by makasim over 4 years ago

#15 - Has correlation_id, has reply_to, recover middlewares

Pull Request - State: closed - Opened by makasim over 4 years ago

#14 - rename Get() to ConnCh(), add get Conn method

Pull Request - State: closed - Opened by makasim over 4 years ago

#13 - go lint fixes

Pull Request - State: closed - Opened by makasim over 4 years ago

#12 - Pool publisher

Pull Request - State: closed - Opened by makasim over 4 years ago - 1 comment

#11 - Create LICENSE

Pull Request - State: closed - Opened by makasim over 4 years ago

#10 - Consumer should be able finish its stuff before connection is closed.

Issue - State: closed - Opened by makasim over 4 years ago - 1 comment

#9 - Publish confirm return support

Issue - State: closed - Opened by makasim over 4 years ago - 1 comment

#8 - lighten conn New func. Add optional setters

Pull Request - State: closed - Opened by makasim almost 5 years ago

#7 - Handle queue deleted while consumption

Pull Request - State: closed - Opened by makasim almost 5 years ago

#6 - Break out of loop if msgCh is closed

Pull Request - State: closed - Opened by neufeldtech almost 5 years ago - 2 comments

#5 - Questiong about handling queue deletion

Issue - State: closed - Opened by neufeldtech almost 5 years ago - 3 comments

#4 - default init, log functions.

Issue - State: closed - Opened by makasim almost 5 years ago

#3 - Publisher confirms support

Issue - State: closed - Opened by makasim almost 5 years ago - 4 comments

#2 - Restart consumer worker on panic or return

Issue - State: open - Opened by makasim almost 5 years ago - 1 comment

#1 - add consumer

Pull Request - State: closed - Opened by makasim almost 5 years ago

GitHub / makasim/amqpextra issues and pull requests