mq

Documentation

Index

• func WithRemote(url string, mq MQ) actor.SystemOption
• type Cluster
  • func (c *Cluster) OnHandleMessage(sourceId, targetId actor.Id, msg interface{})
  • func (c *Cluster) OnHandleRequest(sourceId, targetId actor.Id, requestId string, msg interface{}) (respErr error)
  • func (c *Cluster) OnInit()
  • func (c *Cluster) OnStop() bool
• type MQ

Functions

func WithRemote

func WithRemote(url string, mq MQ) actor.SystemOption

Types

type Cluster

type Cluster struct {
	actor.Base
	// contains filtered or unexported fields
}

func (*Cluster) OnHandleMessage

func (c *Cluster) OnHandleMessage(sourceId, targetId actor.Id, msg interface{})

func (*Cluster) OnHandleRequest

func (c *Cluster) OnHandleRequest(sourceId, targetId actor.Id, requestId string, msg interface{}) (respErr error)

func (*Cluster) OnInit

func (c *Cluster) OnInit()

func (*Cluster) OnStop

func (c *Cluster) OnStop() bool

type MQ

type MQ interface {
	Connect(url string) error
	Close()
	Pub(subject string, data []byte) error
	Req(subject string, data []byte) ([]byte, error)
	SubASync(subject string, callback func(data []byte)) error
	UnSub(subject string, drained bool) (err error)
}