messages

Documentation

Index

• func NewBasicMessage() runtime.MessageIFace
• func NewBasicTypedMessage(crtFunc runtime.InnerObjCreateFunc) runtime.MessageIFace
• func NewBinaryTypedMessage(crtFunc runtime.InnerObjCreateFunc) runtime.MessageIFace
• type BasicMessage
  • func (bm *BasicMessage) Get() interface{}
  • func (bm *BasicMessage) GetAsMap() map[string]interface{}
  • func (bm *BasicMessage) GetBody() []byte
  • func (bm *BasicMessage) GetDeliveryTime() time.Time
  • func (bm *BasicMessage) GetSentTime() time.Time
  • func (bm *BasicMessage) GetType() runtime.MessageType
  • func (bm *BasicMessage) IsTyped() bool
  • func (bm *BasicMessage) Put(data interface{})
  • func (bm *BasicMessage) PutAsMap(data map[string]interface{})
  • func (bm *BasicMessage) SetBody(body []byte)
  • func (bm *BasicMessage) SetDeliveryTime(dt time.Time)
  • func (bm *BasicMessage) SetSentTime(st time.Time)
  • func (bm *BasicMessage) SetType(mType runtime.MessageType)
• type BasicTypedMessage
  • func (btm *BasicTypedMessage) Get() interface{}
  • func (btm *BasicTypedMessage) GetAsMap() map[string]interface{}
  • func (btm *BasicTypedMessage) GetBody() []byte
  • func (btm *BasicTypedMessage) GetCreateFunc() runtime.InnerObjCreateFunc
  • func (btm *BasicTypedMessage) IsTyped() bool
  • func (btm *BasicTypedMessage) Put(data interface{})
  • func (btm *BasicTypedMessage) PutAsMap(data map[string]interface{})
  • func (btm *BasicTypedMessage) SetBody(body []byte)
  • func (btm *BasicTypedMessage) SetCreateFunc(crtFunc runtime.InnerObjCreateFunc)
• type BinaryTypedMessage
  • func (bintm *BinaryTypedMessage) Get() interface{}
  • func (bintm *BinaryTypedMessage) GetAsMap() map[string]interface{}
  • func (bintm *BinaryTypedMessage) GetBody() []byte
  • func (bintm *BinaryTypedMessage) GetCreateFunc() runtime.InnerObjCreateFunc
  • func (bintm *BinaryTypedMessage) IsTyped() bool
  • func (bintm *BinaryTypedMessage) Put(data interface{})
  • func (bintm *BinaryTypedMessage) PutAsMap(data map[string]interface{})
  • func (bintm *BinaryTypedMessage) SetBody(body []byte)
  • func (bintm *BinaryTypedMessage) SetCreateFunc(crtFunc runtime.InnerObjCreateFunc)
• type SharedMessage
  • func (sm *SharedMessage) Get() interface{}
  • func (sm *SharedMessage) Put(data interface{})

Functions

func NewBasicMessage

func NewBasicMessage() runtime.MessageIFace

func NewBasicTypedMessage

func NewBasicTypedMessage(crtFunc runtime.InnerObjCreateFunc) runtime.MessageIFace

func NewBinaryTypedMessage

func NewBinaryTypedMessage(crtFunc runtime.InnerObjCreateFunc) runtime.MessageIFace

Types

type BasicMessage

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

func (*BasicMessage) Get

func (bm *BasicMessage) Get() interface{}

func (*BasicMessage) GetAsMap

func (bm *BasicMessage) GetAsMap() map[string]interface{}

func (*BasicMessage) GetBody

func (bm *BasicMessage) GetBody() []byte

func (*BasicMessage) GetDeliveryTime

func (bm *BasicMessage) GetDeliveryTime() time.Time

func (*BasicMessage) GetSentTime

func (bm *BasicMessage) GetSentTime() time.Time

func (*BasicMessage) GetType

func (bm *BasicMessage) GetType() runtime.MessageType

func (*BasicMessage) IsTyped

func (bm *BasicMessage) IsTyped() bool

func (*BasicMessage) Put

func (bm *BasicMessage) Put(data interface{})

func (*BasicMessage) PutAsMap

func (bm *BasicMessage) PutAsMap(data map[string]interface{})

func (*BasicMessage) SetBody

func (bm *BasicMessage) SetBody(body []byte)

func (*BasicMessage) SetDeliveryTime

func (bm *BasicMessage) SetDeliveryTime(dt time.Time)

func (*BasicMessage) SetSentTime

func (bm *BasicMessage) SetSentTime(st time.Time)

func (*BasicMessage) SetType

func (bm *BasicMessage) SetType(mType runtime.MessageType)

type BasicTypedMessage

type BasicTypedMessage struct {
	BasicMessage
	// contains filtered or unexported fields
}

func (*BasicTypedMessage) Get

func (btm *BasicTypedMessage) Get() interface{}

func (*BasicTypedMessage) GetAsMap

func (btm *BasicTypedMessage) GetAsMap() map[string]interface{}

func (*BasicTypedMessage) GetBody

func (btm *BasicTypedMessage) GetBody() []byte

func (*BasicTypedMessage) GetCreateFunc

func (btm *BasicTypedMessage) GetCreateFunc() runtime.InnerObjCreateFunc

func (*BasicTypedMessage) IsTyped

func (btm *BasicTypedMessage) IsTyped() bool

func (*BasicTypedMessage) Put

func (btm *BasicTypedMessage) Put(data interface{})

func (*BasicTypedMessage) PutAsMap

func (btm *BasicTypedMessage) PutAsMap(data map[string]interface{})

func (*BasicTypedMessage) SetBody

func (btm *BasicTypedMessage) SetBody(body []byte)

func (*BasicTypedMessage) SetCreateFunc

func (btm *BasicTypedMessage) SetCreateFunc(crtFunc runtime.InnerObjCreateFunc)

type BinaryTypedMessage

type BinaryTypedMessage struct {
	BasicMessage
	// contains filtered or unexported fields
}

func (*BinaryTypedMessage) Get

func (bintm *BinaryTypedMessage) Get() interface{}

func (*BinaryTypedMessage) GetAsMap

func (bintm *BinaryTypedMessage) GetAsMap() map[string]interface{}

func (*BinaryTypedMessage) GetBody

func (bintm *BinaryTypedMessage) GetBody() []byte

func (*BinaryTypedMessage) GetCreateFunc

func (bintm *BinaryTypedMessage) GetCreateFunc() runtime.InnerObjCreateFunc

func (*BinaryTypedMessage) IsTyped

func (bintm *BinaryTypedMessage) IsTyped() bool

func (*BinaryTypedMessage) Put

func (bintm *BinaryTypedMessage) Put(data interface{})

func (*BinaryTypedMessage) PutAsMap

func (bintm *BinaryTypedMessage) PutAsMap(data map[string]interface{})

func (*BinaryTypedMessage) SetBody

func (bintm *BinaryTypedMessage) SetBody(body []byte)

func (*BinaryTypedMessage) SetCreateFunc

func (bintm *BinaryTypedMessage) SetCreateFunc(crtFunc runtime.InnerObjCreateFunc)

type SharedMessage

type SharedMessage struct {
	BasicMessage
	// contains filtered or unexported fields
}

func (*SharedMessage) Get

func (sm *SharedMessage) Get() interface{}

func (*SharedMessage) Put

func (sm *SharedMessage) Put(data interface{})