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,