Skip to content

Commit 09255db

Browse files
committed
create empty frame if no msgs
1 parent b59cfdc commit 09255db

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

pkg/plugin/message.go

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -12,13 +12,11 @@ import (
1212

1313
func ToFrame(topic string, messages []mqtt.Message) *data.Frame {
1414
count := len(messages)
15-
if count < 1 {
16-
return nil
17-
}
18-
19-
first := messages[0].Value
20-
if strings.HasPrefix(first, "{") {
21-
return jsonMessagesToFrame(topic, messages)
15+
if count > 0 {
16+
first := messages[0].Value
17+
if strings.HasPrefix(first, "{") {
18+
return jsonMessagesToFrame(topic, messages)
19+
}
2220
}
2321

2422
// Fall through to expecting values

0 commit comments

Comments
 (0)