testrabbit

Sep 29, 2020

Changes in this version

+ const BrokerPort

+ const RabbitPassword

+ const RabbitUsername

+ const RabbitVersion

+ func AutoStartRabbit(t *testing.T, ctx context.Context) testcontainers.Container

+ func BrokerUrl(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) *url.URL

+ func CreateDurableQueue(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, ...)

+ func CreateExchange(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, ...)

+ func CreateNonDurableQueue(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container, ...)

+ func Host(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) string

+ func ManagementPort(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) int

+ func ManagementUrl(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) string

+ func TerminateContainer(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container)

+ type Binding = map[string]interface

+ func FindBindings(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Binding

+ type Exchange = map[string]interface

+ func FindOwnedExchanges(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Exchange

+ func FindQueues(t *testing.T, ctx context.Context, rabbitContainer testcontainers.Container) []Exchange

+ type Queue = map[string]interface