mirror of
https://github.com/absmach/supermq.git
synced 2026-06-23 07:30:25 +00:00
NOISSUE - Fix pub subtopic in RE
Signed-off-by: Dusan Borovcanin <borovcanindusan1@gmail.com>
This commit is contained in:
@@ -327,6 +327,7 @@ func (re *re) process(ctx context.Context, r Rule, msg interface{}) error {
|
||||
Created: time.Now().Unix(),
|
||||
Payload: []byte(result.String()),
|
||||
Channel: r.OutputChannel,
|
||||
Subtopic: r.OutputTopic,
|
||||
}
|
||||
return re.pubSub.Publish(ctx, m.Channel, m)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user