amqp

package

v0.0.0-...-edeb7e2 Latest Latest Go to latest Published: May 5, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	QUOROM_QUEUE           = "QUORUM"
	CLASSIC_QUEUE          = "CLASSIC"
	MAX_QUEUE_LENGTH_BYTES = 1024 * 1024 * 20 // 20MB
)

This section is empty.

This section is empty.

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

BrokerPeer implements the peer interface for AMQP brokers

func NewBrokerPeer(settings broker.MQSettings) *BrokerPeer

NewBrokerPeer creates and returns a new Peer for communicating with AMQP

func (bp *BrokerPeer) GetResults() *broker.Results

func (bp *BrokerPeer) SetupPublishers() error

func (bp *BrokerPeer) SetupSubscribers() error

func (bp *BrokerPeer) StartPublishers()

func (bp *BrokerPeer) StartSubscribers()

func (bp *BrokerPeer) Teardown()

Performs any broker-connection cleanup after test is done

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

Peer stores specific AMQP broker connection information

func (p *Peer) DoneChannel()

Done signals to the peer that message publishing has completed.

func (p *Peer) ErrorChannel() <-chan error

Errors returns the channel on which the peer sends publish errors.

func (p *Peer) ReceiveMessage() ([]byte, error)

func (p *Peer) SendChannel() chan<- []byte

Send returns a channel on which messages can be sent for publishing.

func (p *Peer) SetupPublishRoutine()

Goroutine which fetch messages from send-channel and publish them

func (p *Peer) SetupPublisherConnection(connectionURL string) error

func (p *Peer) SetupSubscriberConnection(connectionURL, queueType string) error