service

Documentation

Index

• type IReceiveService
  • func NewReceiveService(brokerList string) (IReceiveService, error)

Types

type IReceiveService

type IReceiveService interface {
	Stop()
	Submit(req *message.ReqParams) (string, error)
	Cancel(req *message.ReqParams) bool
	AddTime(req *message.ReqParams) bool
	// contains filtered or unexported methods
}

var ReceiveService IReceiveService

func NewReceiveService

func NewReceiveService(brokerList string) (IReceiveService, error)