wagslane
751df3fe63
lowercase f
4 years ago
wagslane
3bc827fdab
notify blocked
4 years ago
wagslane
9d2ba192df
logger
4 years ago
wagslane
6540e6b99a
add blocking support
4 years ago
wagslane
444180b142
reconnectionCount
4 years ago
wagslane
ea9be35725
fixing reconnect issues and updating close API
4 years ago
wagslane
733878b751
fix race
4 years ago
Fedor Ortyanov
2a6d6f207e
WithPublisherOptionsReconnectInterval fix
4 years ago
wagslane
479ee9eaa6
missed publisher
4 years ago
wagslane
6ef45c80f6
betting logging for closures
4 years ago
wagslane
26cc90b71a
fix publishing confirms
4 years ago
wagslane
c6417fde99
allow publishing with confirms
4 years ago
Hicham Boulahboub
0f182de423
Move publish options to dedicated file to be on par with consume_options
4 years ago
Hicham Boulahboub
cf61683c79
Add all amqp.Publishing options for internal PublishOptions
This enables to fully utilize the given options by the amqp library.
4 years ago
wagslane
b89627cfad
victors requests - one flag for notify return
4 years ago
Aurelien Perrier
67f1a8623a
New upstream
rabbitmq/amqp091-go
4 years ago
wagslane
355fdf613d
notify return safety
4 years ago
Victor Elias
eafe892371
Make sure we enable flow for new connections
4 years ago
Victor Elias
306c6bb34b
Make notifyReturnChan a property from publisher
It's the channel that never changes so we might
as well keep a copy of it (even to consider closing
it when the publisher is closed as well).
Also add another little buffer.
4 years ago
Victor Elias
f8fddc8191
Move channel setup to a separate startNotify helper
Also add a very small buffer to the NotifyReturn channel
in case no one is listening on the other side.
I event thought about actually having a timeout when sending
to that channel, but it felt it could lead to loss of
events on non problematic situations, so let's see how this
works instead.
4 years ago
Victor Elias
19266cfffc
Re-configure notify handlers after reconnection
We were probably missing those updates after a
reconnection happens, since we stayed subscribed
to the previous channel notifications instead.
4 years ago
pwli
f838ee629d
fix startNotifyFlowHandler (issue #13 )
5 years ago
Brian Mori
f2a2b169a1
add connection options and stop publish
5 years ago
ajmckee
ba5e59c802
Correct go fmt issue
5 years ago
ajmckee
ebe1fc2391
Update PR to remove redundant if’s and comments.
5 years ago
AJ McKee
22a1e16e0e
Adding support for publishing messages with an expiration.
- Added WithPublishOptionsExpiration which permits message expiry when the TTL has been reached
- Introduced new message var to permit the confidiontal injection of amp.Publishing options in the future.
5 years ago
doluca
2854d5a061
publish: message headers added
5 years ago
lane-c-wagner
f4e9141638
naming updates
5 years ago
Tommy van Leeuwen
4e2687264a
Fix some linter warnings.
5 years ago
Tommy van Leeuwen
fa1267bc6e
Replace logger with a Logger interface to allow for custom loggers.
5 years ago
lane-c-wagner
effbe2c75a
add options functions
5 years ago
lane-c-wagner
d9535c14ec
New not get
5 years ago
lane-c-wagner
83cee6f306
variadic function options
5 years ago
lane-c-wagner
8ac1940b87
first
5 years ago