channelCmdMakerImpl

Documentation

Index

• type ChannelInboundCmdMaker
  • func NewChannelInboundCmdMaker(mLoginMessage channelCommands.ILoginMessage, ...) (impl *ChannelInboundCmdMaker)
  • func (impl *ChannelInboundCmdMaker) MakeActiveCommand(Ctx service.IChannelContext) schedule.ICommand
  • func (impl *ChannelInboundCmdMaker) MakeExceptionCommand(ctx service.IChannelContext, err error) schedule.ICommand
  • func (impl *ChannelInboundCmdMaker) MakeInActiveCommand(Ctx service.IChannelContext) schedule.ICommand
  • func (impl *ChannelInboundCmdMaker) MakeMessageReceivedCommand(Ctx service.IChannelContext, Data interface{}) schedule.ICommand

Types

type ChannelInboundCmdMaker

type ChannelInboundCmdMaker struct {
	// contains filtered or unexported fields
}

func NewChannelInboundCmdMaker

func NewChannelInboundCmdMaker(mLoginMessage channelCommands.ILoginMessage, mEventMaker schedule.IRoutineInboundEventMaker) (impl *ChannelInboundCmdMaker)

func (*ChannelInboundCmdMaker) MakeActiveCommand

func (impl *ChannelInboundCmdMaker) MakeActiveCommand(Ctx service.IChannelContext) schedule.ICommand

新连接

func (*ChannelInboundCmdMaker) MakeExceptionCommand

func (impl *ChannelInboundCmdMaker) MakeExceptionCommand(ctx service.IChannelContext, err error) schedule.ICommand

触发异常

func (*ChannelInboundCmdMaker) MakeInActiveCommand

func (impl *ChannelInboundCmdMaker) MakeInActiveCommand(Ctx service.IChannelContext) schedule.ICommand

连接中断

func (*ChannelInboundCmdMaker) MakeMessageReceivedCommand

func (impl *ChannelInboundCmdMaker) MakeMessageReceivedCommand(Ctx service.IChannelContext, Data interface{}) schedule.ICommand

收到消息包