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

NOISSUE - Add message error type to handle Writer errors (#200)

Browse Source 
* initial implementation

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* update tests

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* update postgres writer

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* fix readers tests

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* address comments

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* fix senML naming

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* remove logger from service

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* fix failing linter

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* update messaging to NACK

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* remove error wrapping

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* remove message in logging

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>

* writer add msg error

Signed-off-by: Arvindh <arvindh91@gmail.com>

* revert the postgres writer changes

Signed-off-by: Arvindh <arvindh91@gmail.com>

* dependency: update supermq version

Signed-off-by: Arvindh <arvindh91@gmail.com>

---------

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>
Signed-off-by: Arvindh <arvindh91@gmail.com>
Co-authored-by: nyagamunene <stevenyaga2014@gmail.com>
This commit is contained in:
Arvindh
2025-06-16 15:52:31 +05:30
committed by GitHub
parent dcd5ff914d
commit a2db0717b3
4 changed files with 44 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/alarms/main.go
-1
View File
@@ -170,7 +170,6 @@ func main() {
Topic: brokers.AllTopic,
DeliveryPolicy: messaging.DeliverAllPolicy,
Handler: consumer,
AckErr: true,
}
if err := pubSub.Subscribe(ctx, subCfg); err != nil {
logger.Error(fmt.Sprintf("failed to subscribe to message broker: %s", err))