diff options
| author | chrislu <chris.lu@gmail.com> | 2022-09-25 19:00:34 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-09-25 19:00:34 -0700 |
| commit | 264c138c1da56681a17c3f9ea37f170c4617b94e (patch) | |
| tree | 9aacf4b22202a65397cfa2efa7e3ae732f3bfdfc | |
| parent | 24317a97636546db80faf66c1653eab1e1fc2b2a (diff) | |
| download | seaweedfs-264c138c1da56681a17c3f9ea37f170c4617b94e.tar.xz seaweedfs-264c138c1da56681a17c3f9ea37f170c4617b94e.zip | |
minor
| -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, |