in src/main/java/com/aliyun/mns/client/CloudQueue.java [119:145]
public String create(QueueMeta queueMeta) throws ServiceException,
ClientException {
CreateQueueAction action = new CreateQueueAction(serviceClient,
credentials, endpoint);
String queueName = drillQueueName();
CreateQueueRequest request = new CreateQueueRequest();
if (queueMeta == null || queueMeta.getQueueName() == null) {
queueMeta = new QueueMeta();
queueMeta.setQueueName(queueName);
} else {
if (queueMeta.getQueueName() == null
|| queueMeta.getQueueName().isEmpty()) {
queueMeta.setQueueName(queueName);
} else {
if (!queueName.equals(queueMeta.getQueueName())) {
throw new ClientException(
"QueueName conflict between meta queue name and queue url offered.",
action.getUserRequestId());
}
}
}
request.setRequestPath(MNSConstants.QUEUE_PREFIX + queueMeta.getQueueName());
request.setQueueMeta(queueMeta);
return action.executeWithCustomHeaders(request, customHeaders);
}