in queue_manager.go [218:242]
func (p *MNSQueueManager) SetQueueAttributes(queueName string, delaySeconds int32, maxMessageSize int32, messageRetentionPeriod int32, visibilityTimeout int32, pollingWaitSeconds int32, slices int32) (err error) {
queueName = strings.TrimSpace(queueName)
if err = checkQueueName(queueName); err != nil {
return
}
if err = checkAttributes(delaySeconds,
messageRetentionPeriod,
visibilityTimeout,
pollingWaitSeconds); err != nil {
return
}
message := CreateQueueRequest{
DelaySeconds: delaySeconds,
MaxMessageSize: maxMessageSize,
MessageRetentionPeriod: messageRetentionPeriod,
VisibilityTimeout: visibilityTimeout,
PollingWaitSeconds: pollingWaitSeconds,
}
_, err = send(p.cli, p.decoder, PUT, nil, &message, fmt.Sprintf("queues/%s?metaoverride=true", queueName), nil)
return
}