MCPcopy
hub / github.com/nats-io/nats.go / WithEndpointQueueGroup

Function WithEndpointQueueGroup

micro/service.go:968–973  ·  view source on GitHub ↗
(queueGroup string)

Source from the content-addressed store, hash-verified

966}
967
968func WithEndpointQueueGroup(queueGroup string) EndpointOpt {
969 return func(e *endpointOpts) error {
970 e.queueGroup = queueGroup
971 return nil
972 }
973}
974
975func WithEndpointQueueGroupDisabled() EndpointOpt {
976 return func(e *endpointOpts) error {

Callers 3

TestCustomQueueGroupFunction · 0.92
AddServiceFunction · 0.85

Calls

no outgoing calls

Tested by 2

TestCustomQueueGroupFunction · 0.74