packet

Documentation

Index

• type IPacket
  • func NewPacket(message *amqp.Delivery) IPacket
• type Packet
  • func (p *Packet) Ack() error
  • func (p *Packet) GetBody() []byte
  • func (p *Packet) Nack() error
  • func (p *Packet) SetBody(body []byte)

Types

type IPacket

type IPacket interface {
	Ack() error
	Nack() error
	GetBody() []byte
	SetBody(body []byte)
}

func NewPacket

func NewPacket(message *amqp.Delivery) IPacket

type Packet

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

func (*Packet) Ack

func (p *Packet) Ack() error

func (*Packet) GetBody

func (p *Packet) GetBody() []byte

func (*Packet) Nack

func (p *Packet) Nack() error

func (*Packet) SetBody

func (p *Packet) SetBody(body []byte)