Hicham Boulahboub
0f182de423
Move publish options to dedicated file to be on par with consume_options
4 years ago
Tom Brouws
6f793db5ec
feat: add consume options to disable declaring of a queue
Signed-off-by: Tom Brouws <tom@brouws.nl>
4 years ago
Lane Wagner
69f0597bf7
Update README.md
4 years ago
Lane Wagner
d5e1094ed3
Update README.md
4 years ago
Lane Wagner
bd0b845202
missed an example in docs
4 years ago
Lane Wagner
a5ddc66649
Merge pull request #44 from thde/thde/docs
docs: update
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
Demian
b6ca89c433
docs: update package name
4 years ago
Demian
80a3345d4f
docs: fix examples
4 years ago
Lane Wagner
10fb3e8bca
Merge pull request #35 from wagslane/lw_notify
notify return safety
4 years ago
Lane Wagner
7fdaafd491
Merge pull request #42 from tscheckenbach/main
Add function to add QueueArgs to consume options
4 years ago
Thorsten Scheckenbach
fd1a3feb6a
Revert "Update module path"
This reverts commit 405ffbd5f5 .
4 years ago
Thorsten Scheckenbach
405ffbd5f5
Update module path
4 years ago
Thorsten Scheckenbach
87019dc087
Add function to add QueueArgs to consume options
4 years ago
wagslane
b89627cfad
victors requests - one flag for notify return
4 years ago
wagslane
3c30293cfd
Merge branch 'main' of https://github.com/wagslane/go-rabbitmq into lw_notify
4 years ago
Lane Wagner
4d14909a3f
Merge pull request #38 from universe-venture/switch/new-upstream
Switch to rabbitmq/amqp091-go
4 years ago
Aurelien Perrier
0e6f858ac9
Add missing content of vendor
4 years ago
Aurélien Perrier
d48b36650a
Update Readme
Add comment maintenance library RMQ Team
4 years ago
Aurélien Perrier
e51929ae8e
Merge branch 'wagslane:main' into switch/new-upstream
4 years ago
Lane Wagner
37b6c4c961
Merge pull request #37 from Qiu-zzz/main
an enum for consumer return value in issues #16
4 years ago
Aurelien Perrier
67f1a8623a
New upstream
rabbitmq/amqp091-go
4 years ago
QiuzZz
08e83f54da
style
4 years ago
QiuzZz
76bb6cd419
Merge branch 'main' of https://github.com/Qiu-zzz/go-rabbitmq into main
4 years ago
QiuzZz
58fd376df4
an enum for consumer return value
4 years ago
QiuzZz
f27ea86185
an enum for consumer return value
4 years ago
wagslane
355fdf613d
notify return safety
4 years ago
Lane Wagner
b05cdbe9c5
Merge pull request #31 from ckoehn/feature/add-option-to-skip-exchange-declaration
Add option to skip exchange declaration
4 years ago
Lane Wagner
897061950a
Merge pull request #33 from iss0/main
Set channelManager config member
4 years ago
Jan Steffen
94795df83b
Set channelManager config member
4 years ago
Christian Köhn
bc434fde5c
Add option to skip exchange declaration
4 years ago
Lane Wagner
c7ae4f6482
Merge pull request #29 from victorges/fix/notify-chans-lifecycle
Fix notify channels lifecycle for publisher
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
Victor Elias
98f15aea03
Stop closing close and cancel channels
The channel takes ownership of those channels when
we call Notify*, so we should not be closing them
or a panic could happen due to double closure or
sending to a closed channel.
4 years ago
Lane Wagner
0f20affc28
Merge pull request #26 from victorct-pronto/feature/stop_consuming
Make the property AutoAcknowledge available to be changed, and added function to stop consumers.
5 years ago
Victor Castillo
e946a187e5
Added the ability to stop the consumers frmo receiving messages, but not from acknolwedging them
5 years ago
wagslane
f115a8d2c9
stylish
5 years ago
Lane Wagner
d614bb372e
Merge pull request #22 from pwli0755/fix-flow-handler
fix startNotifyFlowHandler (issue #13 )
5 years ago
Lane Wagner
b6ef3ce24c
Merge pull request #20 from brianmori/connectionConfig
add connection options and stop publish
5 years ago
Brian
e76ec2a67e
Merge branch 'wagslane:main' into connectionConfig
5 years ago
Victor Castillo
0d0b74c7e9
Add function WithConsumeOptionsConsumerAutoAck to change the auto acknowledge property, when creating a consumer
5 years ago
pwli
f7cc567281
Merge branch 'wagslane:main' into fix-flow-handler
5 years ago
wagslane
2559f048e6
lf
5 years ago
lane-c-wagner
ef822fbb59
check for nil
5 years ago
pwli
f838ee629d
fix startNotifyFlowHandler (issue #13 )
5 years ago
Brian Mori
f2a2b169a1
add connection options and stop publish
5 years ago
wagslane
98402bf376
StopConsuming
5 years ago