diff options
Diffstat (limited to 'weed/mq/messages/message_buffer_mover.go')
| -rw-r--r-- | weed/mq/messages/message_buffer_mover.go | 6 |
1 files 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, |