cliasync

Documentation

Index

• func InjectCliAsync(s *CliAsync)
• func LoadCliAsync() baseiface.ISingleton
• type CliAsync
  • func FindBeanCliAsync() *CliAsync
  • func NewCliAsync() *CliAsync
  • func (this *CliAsync) Publish(msg *gomsg.GonatsMsg) error
  • func (this *CliAsync) PublishNats(msg *gomsg.GonatsMsg) error

Functions

func InjectCliAsync

func InjectCliAsync(s *CliAsync)

func LoadCliAsync

func LoadCliAsync() baseiface.ISingleton

Types

type CliAsync

type CliAsync struct {
	*goproxy.GonatsProxy
	basedto.BaseEntitySingle
}

CliAsync 是一个实现异步客户端功能的结构体， 继承自 goproxy.GonatsProxy 以使用 NATS 连接功能， 并集成 basedto.BaseEntitySingle 以使用基础实体单例功

func FindBeanCliAsync

func FindBeanCliAsync() *CliAsync

FindBeanCliAsync

func NewCliAsync

func NewCliAsync() *CliAsync

func (*CliAsync) Publish

func (this *CliAsync) Publish(msg *gomsg.GonatsMsg) error

Publish 将指定的消息发布到NATS服务器。 参数 msg 为要发布的消息体，类型为 *gomsg.GonatsMsg。 返回值为执行过程中可能出现的错误。

func (*CliAsync) PublishNats

func (this *CliAsync) PublishNats(msg *gomsg.GonatsMsg) error

this is now nats msg std