bdular
4bf56e6808
Added method that exposes connection state; whether it is closed or not.
1 year ago
bdular
c9fe7d9aa0
Removed comment
1 year ago
bdular
3983b966b2
Added function and tests to redact password from URL
1 year ago
wagslane
e99fa510fb
update naming mux -> mu
1 year ago
Ruslan Bayandinov
5802dd2286
Add cluster support via Resolver
Signed-off-by: Ruslan Bayandinov <wazsone@ya.ru>
2 years ago
Abbas Egbeyemi
b0304e51ec
Remove tracef from logger interface
2 years ago
Hristo Karchokov
1930b9d7ad
fix ConfirmSafe race condition
3 years ago
wagslane
a792b8fba4
maxint
3 years ago
Vishal Dubey
3deb2b46c2
feat: expose function for publishing with deferred confirmation
3 years ago
wagslane
919fdfb388
fix staticcheck
3 years ago
wagslane
98bbc9c484
undeprecate subscriber, add test for dispatcher
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
wagslane
8a27a8f5b4
separate channel for each publisher and consumer
3 years ago
wagslane
eea274da92
finish options updates for publisher
3 years ago
wagslane
0df88ac7e9
connection mananger
3 years ago