rabbitmq

Documentation

Index

• type MessageCenter
  • func (m *MessageCenter) Connect(channel string, attempts int, intervalSeconds int) error
  • func (m *MessageCenter) ConsumeMessage(queue string, consumer string, autoAck bool, exclusive bool, noLocal bool, ...) (<-chan amqp.Delivery, error)
  • func (m *MessageCenter) CreateQueue(name string, durable bool, deleteUnused bool, exclusive bool, noWait bool, ...) error
  • func (m *MessageCenter) PublishMessage(queue string, message []byte, exchange string, mandatory bool, immediate bool, ...) error
  • func (m *MessageCenter) ReceiveMessage(replyChannel chan string, queue string)
• type Saga
  • func (s *Saga) StartSaga(m *MessageCenter)
• type SagaStep

Types

type MessageCenter

type MessageCenter struct {
	ServerUrl  string
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

func (*MessageCenter) Connect

func (m *MessageCenter) Connect(channel string, attempts int, intervalSeconds int) error

func (*MessageCenter) ConsumeMessage

func (m *MessageCenter) ConsumeMessage(queue string, consumer string, autoAck bool, exclusive bool,
	noLocal bool, noWait bool, arguments map[string]interface{}) (<-chan amqp.Delivery, error)

func (*MessageCenter) CreateQueue

func (m *MessageCenter) CreateQueue(name string, durable bool, deleteUnused bool,
	exclusive bool, noWait bool, arguments map[string]interface{}) error

func (*MessageCenter) PublishMessage

func (m *MessageCenter) PublishMessage(queue string, message []byte, exchange string, mandatory bool, immediate bool, contentType string, correlationId string, replyTo string) error

func (*MessageCenter) ReceiveMessage

func (m *MessageCenter) ReceiveMessage(replyChannel chan string, queue string)

type Saga

type Saga struct {
	SagaName        string
	SagaDescription string
	ChannelName     string
	CorrelationId   string
	SagaSteps       []SagaStep
}

func (*Saga) StartSaga

func (s *Saga) StartSaga(m *MessageCenter)

type SagaStep

type SagaStep struct {
	StepName             string
	StepDescription      string
	StepSequence         int
	FunctionName         string
	CompensatingFunction string
	QueueName            string
	ReplyQueueName       string
	ActionType           string
	DataObject           []byte
	Results              []string
}