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
wagslane
da13fca987
refactor
5 years ago
Lane Wagner
b813f16864
Merge pull request #18 from brianmori/shutdown
Adds the consume shutdown method
5 years ago
Brian Mori
73f54b2d6b
adds the consume shutdown
5 years ago
Lane Wagner
7e07dbfd2a
Merge pull request #7 from ajmckee/main
Adding support for publishing messages with an expiration.
5 years ago
Lane Wagner
0e1a5ed397
Merge pull request #8 from miguelb/main
declare exchange before binding
5 years ago
Miguel Bautista
ba7b786e63
declare exchange before binding
5 years ago
Miguel Bautista
3e6f1b7c78
declare exchange before binding
5 years ago
Miguel Bautista
b23ceb0d79
declare exchange before binding
5 years ago
ajmckee
ba5e59c802
Correct go fmt issue
5 years ago
Miguel Bautista
04b8c6a9e8
declare exchange before binding
5 years ago
ajmckee
ebe1fc2391
Update PR to remove redundant if’s and comments.
5 years ago
ajmckee
e4d48dbb63
Resolving conflict between my original PR and one that adds header support
5 years ago
Lane Wagner
38a273d1d3
Merge pull request #6 from doluca/main
publish: message headers added
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
2082f1141a
only close channels if they aren't already
5 years ago
lane-c-wagner
f4e9141638
naming updates
5 years ago
Lane Wagner
0f092bce0c
Merge pull request #4 from tomarus/main
Replace logger with a Logger interface to allow for custom loggers.
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
7ce11c8fa6
examples
5 years ago
lane-c-wagner
effbe2c75a
add options functions
5 years ago
lane-c-wagner
d9535c14ec
New not get
5 years ago
Lane Wagner
57afee0277
Merge pull request #2 from wagslane/lw_trig
variadic function options
5 years ago
lane-c-wagner
83cee6f306
variadic function options
5 years ago
Lane Wagner
c49bd384a0
Merge pull request #1 from wagslane/lw_trig
trigger
5 years ago
lane-c-wagner
efaaaf725e
unset goproxy
5 years ago
lane-c-wagner
1ff616bb86
staticcheck
5 years ago
lane-c-wagner
de0590c6e2
trigger
5 years ago
lane-c-wagner
a066a55587
tests
5 years ago
lane-c-wagner
b6aae91934
ref
5 years ago