seaweedfs/weed/msgqueue/message_queue.go

package msgqueue

import "github.com/golang/protobuf/proto"

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 Configuration) error
	SendMessage(key string, message proto.Message) error
}