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

Function resolveQueueGroup

micro/service.go:865–879  ·  view source on GitHub ↗
(customQG, parentQG string, disabled, parentDisabled bool)

Source from the content-addressed store, hash-verified

863}
864
865func resolveQueueGroup(customQG, parentQG string, disabled, parentDisabled bool) (string, bool) {
866 if disabled {
867 return "", true
868 }
869 if customQG != "" {
870 return customQG, false
871 }
872 if parentDisabled {
873 return "", true
874 }
875 if parentQG != "" {
876 return parentQG, false
877 }
878 return DefaultQueueGroup, false
879}
880
881func (g *group) AddGroup(name string, opts ...GroupOpt) Group {
882 var o groupOpts

Callers 4

AddEndpointMethod · 0.85
AddGroupMethod · 0.85
AddEndpointMethod · 0.85
AddGroupMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected