Hristo Karchokov
1930b9d7ad
fix ConfirmSafe race condition
3 years ago
Lane Wagner
85ee5640a7
Merge pull request #121 from felixhuettner/publisher_confirm
add option to enable publisher confirmations
3 years ago
Felix Huettner
ba9044a7f7
add option to enable publisher confirmations
this makes it easier to use `PublishWithDeferredConfirmWithContext`
without generating a custom handler that does nothing.
Add an additional example for this that also shows how to use
PublishWithDeferredConfirmWithContext.
Closes: https://github.com/wagslane/go-rabbitmq/issues/116
3 years ago
Lane Wagner
845a9c6513
Merge pull request #118 from wagslane/lw_readme
readme
3 years ago
wagslane
a1bba6c521
readme
3 years ago
Johannes Würbach
161a8184df
fix: fatal default log
3 years ago
wagslane
05646d6bbc
improve logs
3 years ago
wagslane
b36df88d6c
Merge branch 'main' of https://github.com/wagslane/go-rabbitmq
3 years ago
wagslane
115cfe70b0
rm tests
3 years ago
Lane Wagner
3a26b2c800
Merge pull request #115 from wagslane/lw_maxint
maxint
3 years ago
wagslane
a792b8fba4
maxint
3 years ago
Lane Wagner
167279b51c
Merge pull request #114 from wagslane/lw_prefetch
default prefetch
3 years ago
wagslane
23c587e2ae
default prefetch
3 years ago
Lane Wagner
ac77aaba19
Merge pull request #110 from johanneswuerbach/channel-failure
recovery from channel failure
3 years ago
Johannes Würbach
dc73f616da
recovery from channel failure
3 years ago
Lane Wagner
748d47f1e9
Merge pull request #111 from wshops/main
close publisher properly to prevent resource leaks
3 years ago
Lane Wagner
aeb45be0d3
Merge pull request #107 from julienschmidt/deps/amqp091-go_v1.7.0
Bump github.com/rabbitmq/amqp091-go to v1.7.0
3 years ago
Lane Wagner
a946ce1f0d
Merge pull request #105 from vishal-android-freak/main
update: Add manual action to consumer handler & expose function for Publishing with deferred confirmation
3 years ago
Vishal Dubey
3deb2b46c2
feat: expose function for publishing with deferred confirmation
3 years ago
Vishal Dubey
526fb50c56
Merge branch 'wagslane:main' into main
3 years ago
Julien Schmidt
9835afb563
Bump github.com/rabbitmq/amqp091-go to v1.7.0
3 years ago
Lane Wagner
5c6bcb5027
Update tests.yml
3 years ago
wagslane
919fdfb388
fix staticcheck
3 years ago
Vishal Dubey
1b2d3b05a7
update: Add manual action to consumer handler
3 years ago
wagslane
98bbc9c484
undeprecate subscriber, add test for dispatcher
3 years ago
Lane Wagner
c230e9f590
Merge pull request #93 from aaqaishtyaq/add-pub-ctx
Remove deprecated 'Publish' method
3 years ago
Aaqa Ishtyaq
e85746aa14
feat: Add PublishWithContext, deprecate Publish
- 'Publish' has been deprecared by rabbitmq/ampq091-go.
- 'PublishWithContext' has been introduced to pass context
while publishing for cancellation.
- Update examples to use PublishWithContext.
Signed-off-by: Aaqa Ishtyaq <aaqa@hackerrank.com>
3 years ago
Aaqa Ishtyaq
6b01e917aa
chore: update amqp091 to v1.5.0, remove vendor dir
- Update rabbitmq/amqp091 to v1.5.0 to use 'PublishwWithContext'.
- Remove vendored dependencies and use go.sum for reproducable
dependencies.
Signed-off-by: Aaqa Ishtyaq <aaqa@hackerrank.com>
3 years ago
Tony An
c6486ad061
🐛 close publisher properly to prevent resource leaks
3 years ago
wagslane
5b9c5a245f
docs
3 years ago
Lane Wagner
32bd696a7a
Merge pull request #98 from aaqaishtyaq/queue-quorum
add quorum queue option for the consumer
3 years ago
Lane Wagner
9f51e283aa
Merge pull request #100 from humbertovnavarro/patch-1
Update consume.go
3 years ago
Humberto Navarro
63d4c88d28
Update consume.go
3 years ago
Aaqa Ishtyaq
4739225d6f
add quorum queue option for the consumer
Signed-off-by: Aaqa Ishtyaq <aaqaishtyaq@gmail.com>
3 years ago
Lane Wagner
ebf2e16d3e
Merge pull request #95 from aaqaishtyaq/close-chan-on-exit
close channel once the consumer is stopped
3 years ago
Aaqa Ishtyaq
3589e5a6e5
close channel once the consumer is stopped
Signed-off-by: Aaqa Ishtyaq <aaqa@hackerrank.com>
3 years ago
wagslane
8a27a8f5b4
separate channel for each publisher and consumer
3 years ago
wagslane
681b7447f4
docs
3 years ago
wagslane
eea274da92
finish options updates for publisher
3 years ago
wagslane
0df88ac7e9
connection mananger
3 years ago
wagslane
a98c8d0249
docs
3 years ago
Lane Wagner
a842287596
Merge pull request #81 from prolicht-dev/simpler_bindings
Simpler bindings / Declare process | Part 1
3 years ago
Lane Wagner
25622e1f97
Update README.md
3 years ago
Lane Wagner
97747a6131
Update README.md
3 years ago
christoph.haas
2447aaa805
Merge branch 'main' into simpler_bindings
# Conflicts:
# channel.go
3 years ago
Lane Wagner
16f2cae01c
Merge pull request #83 from ldmi3i/error_on_reconnect
Error handling on channel closing while reconnecting.
3 years ago
Dmitry
4e82d8db5b
Change error forwarding to logging.
3 years ago
Dmitry
6a1168967f
Add handle errors on channel closing while reconnecting.
3 years ago
Christoph Haas
70a7350572
queue, exchange and binding declaration is now simplified and much clearer to use
3 years ago
Christoph Haas
62371e8dba
queue, exchange and binding declaration is now simplified and much clearer to use
3 years ago