serverasync

Documentation

Index

• func InjectServerAsync(s *ServerAsync)
• func LoadServerAsync() baseiface.ISingleton
• type ServerAsync
  • func FindBeanServerAsync() *ServerAsync
  • func NewServerAsync() *ServerAsync
  • func (self *ServerAsync) HandleMessageDefault(msg *nats.Msg)
  • func (self *ServerAsync) StartServer() (*nats.Conn, error)
  • func (self *ServerAsync) Subscribe(Topic string) (*nats.Conn, error)

Functions

func InjectServerAsync

func InjectServerAsync(s *ServerAsync)

func LoadServerAsync

func LoadServerAsync() baseiface.ISingleton

Types

type ServerAsync

type ServerAsync struct {
	basedto.BaseEntitySingle
	*goproxy.GonatsProxy
	TotalMsg int
}

func FindBeanServerAsync

func FindBeanServerAsync() *ServerAsync

FindBeanServerAsync

func NewServerAsync

func NewServerAsync() *ServerAsync

func (*ServerAsync) HandleMessageDefault

func (self *ServerAsync) HandleMessageDefault(msg *nats.Msg)

func (*ServerAsync) StartServer

func (self *ServerAsync) StartServer() (*nats.Conn, error)

func (*ServerAsync) Subscribe

func (self *ServerAsync) Subscribe(Topic string) (*nats.Conn, error)

subscribe