amqpcmds

Documentation

Index

• type AmqpCommand
  • func NewCommandInfo(user, password, host string, port int, autoACK bool, prefetch, count int, ...) AmqpCommand
• type CommandInfo
  • func (c *CommandInfo) CommandCopyMoveToQueue(srcQueue, dstQueue string) error
  • func (c *CommandInfo) CommandExport(queue string) error

Types

type AmqpCommand

type AmqpCommand interface {
	CommandExport(queue string) error
	CommandCopyMoveToQueue(srcQueue, dstQueue string) error
}

AmqpCommand general interface for the command execution

func NewCommandInfo

func NewCommandInfo(user, password, host string,
	port int,
	autoACK bool,
	prefetch, count int,
	file, formatPrefix, formatSeparator, formatPostfix string) AmqpCommand

NewCommandInfo creates a new instance that can execute the Amqp commands, with the default amqp dialer wrapper

type CommandInfo

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

CommandInfo defines a basic structure to execute amqp commands

func (*CommandInfo) CommandCopyMoveToQueue

func (c *CommandInfo) CommandCopyMoveToQueue(srcQueue, dstQueue string) error

CommandCopyMoveToQueue copy or moves messages from one queue to another one. The copy is a exact one: it propagate the meta-information of the message, not just the content.

func (*CommandInfo) CommandExport

func (c *CommandInfo) CommandExport(queue string) error

CommandExport exports the content of a queue using the queue configuration and predefined format.