in src/main/java/com/aliyun/mns/client/CloudQueue.java [70:94]
protected CloudQueue(String queueURL, ServiceClient client,
ServiceCredentials credentials, URI endpoint) {
this.serviceClient = client;
this.credentials = credentials;
this.endpoint = endpoint;
if (queueURL == null || "".equals(queueURL)) {
throw new NullPointerException(
"QueueURL parameter can not be empty.");
}
String uri = endpoint.toString();
if (queueURL.startsWith(uri)) {
this.queueURL = queueURL;
} else {
if (!uri.endsWith("/")) {
uri += "/";
}
if (queueURL != null) {
uri += MNSConstants.QUEUE_PREFIX + queueURL;
}
this.queueURL = uri;
}
}