message

Documentation

Index

• type Message
  • func (m *Message) GetErrorCount() uint64
  • func (m *Message) GetExchange() string
  • func (m *Message) GetId() string
  • func (m *Message) GetRoutingKey() string
  • func (m *Message) GetValue() any
  • func (m *Message) SetErrorCount(count uint64)
  • func (m *Message) SetErrorIncr()
  • func (m *Message) SetExchange(exchange string)
  • func (m *Message) SetId(id string)
  • func (m *Message) SetRoutingKey(routingKey string)
  • func (m *Message) SetValue(values any)

Types

type Message

type Message struct {
	Id         string
	RoutingKey string
	Exchange   string
	Values     any
	GroupId    string
	ErrorCount uint64
}

func (*Message) GetErrorCount

func (m *Message) GetErrorCount() uint64

func (*Message) GetExchange

func (m *Message) GetExchange() string

func (*Message) GetId

func (m *Message) GetId() string

func (*Message) GetRoutingKey

func (m *Message) GetRoutingKey() string

func (*Message) GetValue

func (m *Message) GetValue() any

func (*Message) SetErrorCount

func (m *Message) SetErrorCount(count uint64)

func (*Message) SetErrorIncr

func (m *Message) SetErrorIncr()

func (*Message) SetExchange

func (m *Message) SetExchange(exchange string)

func (*Message) SetId

func (m *Message) SetId(id string)

func (*Message) SetRoutingKey

func (m *Message) SetRoutingKey(routingKey string)

func (*Message) SetValue

func (m *Message) SetValue(values any)