Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.