opensource/supermq
1
0
Fork 0
mirror of https://github.com/absmach/supermq.git synced 2026-06-23 07:00:25 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

NOISSUE - Fix default nats pubsub subject (#1153)

Browse Source 
* NOISSUE - Fix default nats publisher subject

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Use created timestamp inn transformer

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Use created timestamp in transformer

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* rename topic -> subject for nats

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* revert

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* revert

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Fix subscriber topic

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Fix timestamp

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Use int64 nanoseconds Created timestamp

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Typo

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Add comment to created protobuf field

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Rm gogo from scripts/ci.sh

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Fix comment

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>

* Return publisher in NewPublisher

Signed-off-by: Manuel Imperiale <manuel.imperiale@gmail.com>
This commit is contained in:
Manuel Imperiale
2020-05-04 13:14:06 +02:00
committed by GitHub
parent 0c016cd7ce
commit 2b4cf8a990
13 changed files with 496 additions and 93 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/ci.sh
-4
View File
@@ -4,8 +4,6 @@ GO_VERSION=1.13
PROTOC_VERSION=3.11.4
PROTOC_GEN_VERSION=v1.3.3
PROTOC_GOFAST_VERSION=v1.3.1
PROTOC_GOGO_VERSION=v1.3.1
GOGOPROTO_VERSION=v1.3.1
GRPC_VERSION=v1.27.1
function version_gt() { test "$(printf '%s\n' "$@" | sort -V | head -n 1)" != "$1"; }
@@ -43,9 +41,7 @@ setup_protoc() {
rm -f PROTOC_ZIP
go get -u github.com/golang/protobuf/protoc-gen-go@$PROTOC_GEN_VERSION \
github.com/gogo/protobuf/protoc-gen-gogo@$PROTOC_GOGO_VERSION \
github.com/gogo/protobuf/protoc-gen-gofast@$PROTOC_GOFAST_VERSION \
github.com/gogo/protobuf/gogoproto@$GOGOPROTO_VERSION \
google.golang.org/grpc@$GRPC_VERSION
export PATH=$PATH:/usr/local/bin/protoc