From 264c138c1da56681a17c3f9ea37f170c4617b94e Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 25 Sep 2022 19:00:34 -0700 Subject: [PATCH] minor --- weed/mq/messages/message_buffer_mover.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/weed/mq/messages/message_buffer_mover.go b/weed/mq/messages/message_buffer_mover.go index fad14056f..6c29db095 100644 --- a/weed/mq/messages/message_buffer_mover.go +++ b/weed/mq/messages/message_buffer_mover.go @@ -17,13 +17,13 @@ var _ = MessageBufferMover(&EmptyMover{}) type EmptyMover struct { } -func (e EmptyMover) Setup() { +func (e *EmptyMover) Setup() { } -func (e EmptyMover) TearDown() { +func (e *EmptyMover) TearDown() { } -func (e EmptyMover) MoveBuffer(buffer *MessageBuffer) (MessageBufferReference, error) { +func (e *EmptyMover) MoveBuffer(buffer *MessageBuffer) (MessageBufferReference, error) { println("moving", buffer.sequenceBase) return MessageBufferReference{ sequence: buffer.sequenceBase,