diff --git a/plugins/drng/plugin.go b/plugins/drng/plugin.go
index 66ca57be89856b1ee8f20fc7822c66a0fbaa64a1..2f5462eb6bb0fdf71fe087ff75e5a6da5ef967b9 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
 			}