messageQueue

type Consumer func(topic string, string string, message *Message) error

type ConsumerConfigure struct {
	Id       string
	Retry    int
	Callback Consumer
}

type MemoryMessageQueue struct {
	RunMode RunMode

	Topic string
	List  *list.List

	Consumers map[string]*ConsumerConfigure

	ConsumerErrorCallback   Consumer
	ConsumerSuccessCallback Consumer
	// contains filtered or unexported fields
}

type Message struct {
	Id           any
	MessageEntry interface{}
	DisOrder     bool   //if you set this true, the message will be consumed as soon as possible but not in order
	ConsumerId   string //if not set,push to all consumer

}

type Publish struct {
	Message  *Message
	DisOrder bool
}

type RunMode uint8