From 83a4c9f70f67373587efa904a0cd3ca313e1ffc9 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Fri, 6 Jan 2023 17:17:01 +0100 Subject: [PATCH] ship_processor.go: encodeQueue should accept and redis.ChannelInterface instead of redis.Channel to make it more generic. --- ship_processor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ship_processor.go b/ship_processor.go index ddb5a3d..9647302 100644 --- a/ship_processor.go +++ b/ship_processor.go @@ -31,7 +31,7 @@ func queueMessage(channel redis.ChannelInterface, payload []byte) bool { return true } -func encodeQueue(channel redis.Channel, v interface{}) bool { +func encodeQueue(channel redis.ChannelInterface, v interface{}) bool { if payload, ok := encodeMessage(v); ok { if queueMessage(channel, payload) { return true