func BuildSimpleConsumer()

in golang/utils/ClientUtils.go [121:145]

• 23 lines of code
• 3 McCabe index (conditional complexity)

func BuildSimpleConsumer(nameserver string, consumerGroup string, filterExpression string, ak string, sk string, topic string) rmq_client.SimpleConsumer {

	simpleConsumer, err := rmq_client.NewSimpleConsumer(&rmq_client.Config{
		Endpoint:      nameserver,
		ConsumerGroup: consumerGroup,
		Credentials: &credentials.SessionCredentials{
			AccessKey:    ak,
			AccessSecret: sk,
		},
	},
		rmq_client.WithAwaitDuration(awaitDuration),
		rmq_client.WithSubscriptionExpressions(map[string]*rmq_client.FilterExpression{
			topic: rmq_client.NewFilterExpression(filterExpression),
		}),
	)
	if err != nil {
		log.Fatal(err)
	}
	// start simpleConsumer
	err = simpleConsumer.Start()
	if err != nil {
		log.Fatal(err)
	}
	return simpleConsumer
}