packet

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 12, 2021 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL