weed/msgqueue/message_queue.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14

package msgqueue

import (
	"github.com/golang/protobuf/proto"
	"github.com/chrislusf/seaweedfs/weed/util"
)

type MessageQueue interface {
	// GetName gets the name to locate the configuration in message_queue.toml file
	GetName() string
	// Initialize initializes the file store
	Initialize(configuration util.Configuration) error
	SendMessage(key string, message proto.Message) error
}