amqp

Documentation

Index

• Constants
• Variables
• func CreateAmqpTransporter(options AmqpOptions) transit.Transport
• type AmqpOptions
• type AmqpTransporter
  • func (t *AmqpTransporter) Connect() chan error
  • func (t *AmqpTransporter) Disconnect() chan error
  • func (t *AmqpTransporter) Publish(command, nodeID string, message nucleo.Payload)
  • func (t *AmqpTransporter) SetNodeID(nodeID string)
  • func (t *AmqpTransporter) SetPrefix(prefix string)
  • func (t *AmqpTransporter) SetSerializer(serializer serializer.Serializer)
  • func (t *AmqpTransporter) Subscribe(command, nodeID string, handler transit.TransportHandler)

Constants

const (
	DurationNotDefined = time.Duration(-1)
)

Variables

var DefaultConfig = AmqpOptions{
	Prefetch: 1,

	AutoDeleteQueues:    DurationNotDefined,
	EventTimeToLive:     DurationNotDefined,
	HeartbeatTimeToLive: DurationNotDefined,
}

Functions

func CreateAmqpTransporter

func CreateAmqpTransporter(options AmqpOptions) transit.Transport

Types

type AmqpOptions

type AmqpOptions struct {
	Url             []string
	QueueOptions    map[string]interface{}
	ExchangeOptions map[string]interface{}
	MessageOptions  map[string]interface{}
	ConsumeOptions  amqp.Table

	Logger     *log.Entry
	Serializer serializer.Serializer

	DisableReconnect    bool
	AutoDeleteQueues    time.Duration
	EventTimeToLive     time.Duration
	HeartbeatTimeToLive time.Duration
	Prefetch            int
}

type AmqpTransporter

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

func (*AmqpTransporter) Connect

func (t *AmqpTransporter) Connect() chan error

func (*AmqpTransporter) Disconnect

func (t *AmqpTransporter) Disconnect() chan error

func (*AmqpTransporter) Publish

func (t *AmqpTransporter) Publish(command, nodeID string, message nucleo.Payload)

func (*AmqpTransporter) SetNodeID

func (t *AmqpTransporter) SetNodeID(nodeID string)

func (*AmqpTransporter) SetPrefix

func (t *AmqpTransporter) SetPrefix(prefix string)

func (*AmqpTransporter) SetSerializer

func (t *AmqpTransporter) SetSerializer(serializer serializer.Serializer)

func (*AmqpTransporter) Subscribe

func (t *AmqpTransporter) Subscribe(command, nodeID string, handler transit.TransportHandler)