Asim Aslam
d438bee8bf
Go fmt and update go mod
2021-01-10 14:44:01 +03:00
a28169de2e
stan broker, fix race on subscribe
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
Asim Aslam
c55078a1c3
Update the location of data and cmd
2021-01-10 14:44:01 +03:00
09f946bd6b
stan: fix error when multiple times calling Connect method
...
dont overwrite passed options to avoid error:
impossible to use custom ConnectionLostCB and ConnectRetry(true)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-10 14:44:01 +03:00
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
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
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
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
