message

Documentation

Index

• type MessengerImpl
  • func (m *MessengerImpl) GetResponse(callID int32, response proto.Message) error
  • func (m *MessengerImpl) SendMessage(service string, method string, request proto.Message, response proto.Message) error

Types

type MessengerImpl

type MessengerImpl struct {
	Session *session.Session
}

func (*MessengerImpl) GetResponse

func (m *MessengerImpl) GetResponse(callID int32, response proto.Message) error

func (*MessengerImpl) SendMessage

func (m *MessengerImpl) SendMessage(service string, method string, request proto.Message, response proto.Message) error

TODO: Needs to copy the buffer to the connection TODO: Needs extensive tests TODO: This should actually be implemented as a message queue