Skip to content
Merged
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 5 additions & 2 deletions modules/nats/nats.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ type NATSContainer struct {
// Deprecated: use Run instead
// RunContainer creates an instance of the NATS container type
func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*NATSContainer, error) {
return Run(ctx, "nats:2.9", opts...)
return Run(ctx, "nats:2.11.7", opts...)
}

// Run creates an instance of the NATS container type
Expand All @@ -33,7 +33,10 @@ func Run(ctx context.Context, img string, opts ...testcontainers.ContainerCustom
Image: img,
ExposedPorts: []string{defaultClientPort, defaultRoutingPort, defaultMonitoringPort},
Cmd: []string{"-DV", "-js"},
WaitingFor: wait.ForLog("Listening for client connections on 0.0.0.0:4222"),
WaitingFor: wait.ForAll(
wait.ForListeningPort(defaultClientPort),
wait.ForLog("Server is ready"),
),
}

genericContainerReq := testcontainers.GenericContainerRequest{
Expand Down
Loading