From e1ac1a5a431ab88e1407cf25bd2c63134deaeca7 Mon Sep 17 00:00:00 2001
From: capossele <angelocapossele@gmail.com>
Date: Tue, 21 Apr 2020 10:05:47 +0100
Subject: [PATCH] :zap: adds Type check
---
plugins/drng/plugin.go | 3 +++
1 file changed, 3 insertions(+)
diff --git a/plugins/drng/plugin.go b/plugins/drng/plugin.go
index 66ca57be..2f5462eb 100644
--- a/plugins/drng/plugin.go
+++ b/plugins/drng/plugin.go
@@ -69,6 +69,9 @@ func configureEvents() {
cachedMessageMetadata.Release()
cachedMessage.Consume(func(msg *message.Message) {
+ if msg.Payload().Type() != payload.Type {
+ return
+ }
if len(msg.Payload().Bytes()) < header.Length {
return
}
--
GitLab