rabbitmq

Documentation

Index

• func NewMessage() pubsub.Message
• func NewMessageFromDelivery(delivery amqp.Delivery) pubsub.Message
• type Message
  • func (m *Message) Ack() error
  • func (m *Message) AppID() string
  • func (m *Message) Body() []byte
  • func (m *Message) ContentEncoding() string
  • func (m *Message) ContentType() string
  • func (m *Message) CorrelationID() uuid.UUID
  • func (m *Message) DeliveryMode() uint8
  • func (m *Message) Expiration() time.Duration
  • func (m *Message) GetHeader(key string) interface{}
  • func (m *Message) Headers() map[string]interface{}
  • func (m *Message) ID() uuid.UUID
  • func (m *Message) Nack() error
  • func (m *Message) Priority() uint8
  • func (m *Message) Reject() error
  • func (m *Message) ReplyTo() string
  • func (m *Message) SetAppID(appID string) pubsub.Message
  • func (m *Message) SetBody(body []byte) pubsub.Message
  • func (m *Message) SetContentEncoding(v string) pubsub.Message
  • func (m *Message) SetContentType(v string) pubsub.Message
  • func (m *Message) SetCorrelationID(id uuid.UUID) pubsub.Message
  • func (m *Message) SetDeliveryModePersistent() pubsub.Message
  • func (m *Message) SetExpiration(expiration time.Duration) pubsub.Message
  • func (m *Message) SetHeader(key string, value interface{}) pubsub.Message
  • func (m *Message) SetHeaders(headers map[string]interface{}) pubsub.Message
  • func (m *Message) SetPriority(priority uint8) pubsub.Message
  • func (m *Message) SetReplyTo(v string) pubsub.Message
  • func (m *Message) SetTimestamp(timestamp time.Time) pubsub.Message
  • func (m *Message) SetType(v string) pubsub.Message
  • func (m *Message) SetUserID(useID string) pubsub.Message
  • func (m *Message) Timestamp() time.Time
  • func (m *Message) Type() string
  • func (m *Message) UserID() string

Functions

func NewMessage

func NewMessage() pubsub.Message

func NewMessageFromDelivery

func NewMessageFromDelivery(delivery amqp.Delivery) pubsub.Message

Types

type Message

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

func (*Message) Ack

func (m *Message) Ack() error

func (*Message) AppID

func (m *Message) AppID() string

func (*Message) Body

func (m *Message) Body() []byte

func (*Message) ContentEncoding

func (m *Message) ContentEncoding() string

func (*Message) ContentType

func (m *Message) ContentType() string

func (*Message) CorrelationID

func (m *Message) CorrelationID() uuid.UUID

func (*Message) DeliveryMode

func (m *Message) DeliveryMode() uint8

func (*Message) Expiration

func (m *Message) Expiration() time.Duration

func (*Message) GetHeader

func (m *Message) GetHeader(key string) interface{}

func (*Message) Headers

func (m *Message) Headers() map[string]interface{}

func (*Message) ID

func (m *Message) ID() uuid.UUID

func (*Message) Nack

func (m *Message) Nack() error

func (*Message) Priority

func (m *Message) Priority() uint8

func (*Message) Reject

func (m *Message) Reject() error

func (*Message) ReplyTo

func (m *Message) ReplyTo() string

func (*Message) SetAppID

func (m *Message) SetAppID(appID string) pubsub.Message

func (*Message) SetBody

func (m *Message) SetBody(body []byte) pubsub.Message

func (*Message) SetContentEncoding

func (m *Message) SetContentEncoding(v string) pubsub.Message

func (*Message) SetContentType

func (m *Message) SetContentType(v string) pubsub.Message

func (*Message) SetCorrelationID

func (m *Message) SetCorrelationID(id uuid.UUID) pubsub.Message

func (*Message) SetDeliveryModePersistent

func (m *Message) SetDeliveryModePersistent() pubsub.Message

func (*Message) SetExpiration

func (m *Message) SetExpiration(expiration time.Duration) pubsub.Message

func (*Message) SetHeader

func (m *Message) SetHeader(key string, value interface{}) pubsub.Message

func (*Message) SetHeaders

func (m *Message) SetHeaders(headers map[string]interface{}) pubsub.Message

func (*Message) SetPriority

func (m *Message) SetPriority(priority uint8) pubsub.Message

func (*Message) SetReplyTo

func (m *Message) SetReplyTo(v string) pubsub.Message

func (*Message) SetTimestamp

func (m *Message) SetTimestamp(timestamp time.Time) pubsub.Message

func (*Message) SetType

func (m *Message) SetType(v string) pubsub.Message

func (*Message) SetUserID

func (m *Message) SetUserID(useID string) pubsub.Message

func (*Message) Timestamp

func (m *Message) Timestamp() time.Time

func (*Message) Type

func (m *Message) Type() string

func (*Message) UserID

func (m *Message) UserID() string