|
|
44de02e879
|
stan: fix data race in Connect()
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-10 14:44:01 +03:00 |
|
Asim Aslam
|
7d84f2005b
|
gofmt
|
2021-01-10 14:44:01 +03:00 |
|
Asim Aslam
|
2fcc1dbf5d
|
change logger
|
2021-01-10 14:44:01 +03:00 |
|
fztcjjl
|
1291ceb68c
|
use new NATS streaming client repo path
|
2021-01-10 14:44:01 +03:00 |
|
fztcjjl
|
54a1eae3e2
|
durable subscriptions for nats streaming
|
2021-01-10 14:44:01 +03:00 |
|
LocTD
|
de6f824e4a
|
Provide a way to set native SubscriptionOption for stan broker through server.SubscriberOption
|
2021-01-10 14:44:01 +03:00 |
|
|
|
e545f8cbc4
|
broker stan: fix data race
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-10 14:44:01 +03:00 |
|
Yumin Wu
|
bf0aecf4f6
|
fix go-nats-streaming clientID
|
2021-01-10 14:44:01 +03:00 |
|
Yumin Wu
|
5e260a4cfa
|
go-nats-streaming clientID
|
2021-01-10 14:44:01 +03:00 |
|
|
|
8d0a3fba24
|
broker: [stan] rework option naming, fix messages
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-10 14:44:01 +03:00 |
|
|
|
c37100b7e2
|
broker: stan add Reconnect and Timeout
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-10 14:44:01 +03:00 |
|
Asim Aslam
|
d2ea46c139
|
update comment
|
2021-01-10 14:44:01 +03:00 |
|
Asim Aslam
|
31d9c7f289
|
Rename SuccessAutoAck to AckOnSuccess
|
2021-01-10 14:44:01 +03:00 |
|
Asim Aslam
|
6eb8ae50d5
|
simplify stan handler error handling
|
2021-01-10 14:44:01 +03:00 |
|
|
|
6c04d1a29b
|
propagate context and SuccessAutoAck option other brokers
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-10 14:44:01 +03:00 |
|
|
|
c5fc37933f
|
initial import of stan - nats streaming broker
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2021-01-10 14:44:01 +03:00 |
|
