rabbitmq

Documentation

Index

• type Configuration
• type Event
  • func (e *Event) GetBody() []byte
  • func (e *Event) GetContentType() string
  • func (e *Event) GetHeaderByteSlice(key string) []byte

Types

type Configuration

type Configuration struct {
	eventsource.Configuration
	BrokerURL          string
	BrokerExchangeName string
	BrokerQueueName    string
}

type Event

type Event struct {
	processor.AbstractSync
	// contains filtered or unexported fields
}

allows accessing an amqp.Delivery

func (*Event) GetBody

func (e *Event) GetBody() []byte

func (*Event) GetContentType

func (e *Event) GetContentType() string

func (*Event) GetHeaderByteSlice

func (e *Event) GetHeaderByteSlice(key string) []byte