Skip to content

Commit

Permalink
Updated queues swagger (#22620)
Browse files Browse the repository at this point in the history
  • Loading branch information
gapra-msft authored Jul 7, 2021
1 parent 8c7ee20 commit 879f63e
Show file tree
Hide file tree
Showing 5 changed files with 12 additions and 124 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,8 @@ Mono<MessagesEnqueueResponse> enqueue(
@UnexpectedResponseExceptionType(com.azure.storage.queue.models.QueueStorageException.class)
Mono<MessagesPeekResponse> peek(
@HostParam("url") String url,
@QueryParam("peekonly") String peekonly,
@PathParam("queueName") String queueName,
@QueryParam("peekonly") String peekonly,
@QueryParam("numofmessages") Integer numberOfMessages,
@QueryParam("timeout") Integer timeout,
@HeaderParam("x-ms-version") String version,
Expand Down Expand Up @@ -252,8 +252,8 @@ public Mono<MessagesPeekResponse> peekWithResponseAsync(
final String accept = "application/xml";
return service.peek(
this.client.getUrl(),
peekonly,
queueName,
peekonly,
numberOfMessages,
timeout,
this.client.getVersion(),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,8 +87,8 @@ Mono<QueuesDeleteResponse> delete(
@UnexpectedResponseExceptionType(com.azure.storage.queue.models.QueueStorageException.class)
Mono<QueuesGetPropertiesResponse> getProperties(
@HostParam("url") String url,
@QueryParam("comp") String comp,
@PathParam("queueName") String queueName,
@QueryParam("comp") String comp,
@QueryParam("timeout") Integer timeout,
@HeaderParam("x-ms-version") String version,
@HeaderParam("x-ms-client-request-id") String requestId,
Expand All @@ -100,8 +100,8 @@ Mono<QueuesGetPropertiesResponse> getProperties(
@UnexpectedResponseExceptionType(com.azure.storage.queue.models.QueueStorageException.class)
Mono<QueuesSetMetadataResponse> setMetadata(
@HostParam("url") String url,
@QueryParam("comp") String comp,
@PathParam("queueName") String queueName,
@QueryParam("comp") String comp,
@QueryParam("timeout") Integer timeout,
@HeaderParam("x-ms-meta-") Map<String, String> metadata,
@HeaderParam("x-ms-version") String version,
Expand All @@ -114,8 +114,8 @@ Mono<QueuesSetMetadataResponse> setMetadata(
@UnexpectedResponseExceptionType(com.azure.storage.queue.models.QueueStorageException.class)
Mono<QueuesGetAccessPolicyResponse> getAccessPolicy(
@HostParam("url") String url,
@QueryParam("comp") String comp,
@PathParam("queueName") String queueName,
@QueryParam("comp") String comp,
@QueryParam("timeout") Integer timeout,
@HeaderParam("x-ms-version") String version,
@HeaderParam("x-ms-client-request-id") String requestId,
Expand All @@ -127,8 +127,8 @@ Mono<QueuesGetAccessPolicyResponse> getAccessPolicy(
@UnexpectedResponseExceptionType(com.azure.storage.queue.models.QueueStorageException.class)
Mono<QueuesSetAccessPolicyResponse> setAccessPolicy(
@HostParam("url") String url,
@QueryParam("comp") String comp,
@PathParam("queueName") String queueName,
@QueryParam("comp") String comp,
@QueryParam("timeout") Integer timeout,
@HeaderParam("x-ms-version") String version,
@HeaderParam("x-ms-client-request-id") String requestId,
Expand Down Expand Up @@ -216,7 +216,7 @@ public Mono<QueuesGetPropertiesResponse> getPropertiesWithResponseAsync(
final String comp = "metadata";
final String accept = "application/xml";
return service.getProperties(
this.client.getUrl(), comp, queueName, timeout, this.client.getVersion(), requestId, accept, context);
this.client.getUrl(), queueName, comp, timeout, this.client.getVersion(), requestId, accept, context);
}

/**
Expand Down Expand Up @@ -245,8 +245,8 @@ public Mono<QueuesSetMetadataResponse> setMetadataWithResponseAsync(
final String accept = "application/xml";
return service.setMetadata(
this.client.getUrl(),
comp,
queueName,
comp,
timeout,
metadata,
this.client.getVersion(),
Expand Down Expand Up @@ -277,7 +277,7 @@ public Mono<QueuesGetAccessPolicyResponse> getAccessPolicyWithResponseAsync(
final String comp = "acl";
final String accept = "application/xml";
return service.getAccessPolicy(
this.client.getUrl(), comp, queueName, timeout, this.client.getVersion(), requestId, accept, context);
this.client.getUrl(), queueName, comp, timeout, this.client.getVersion(), requestId, accept, context);
}

/**
Expand Down Expand Up @@ -308,8 +308,8 @@ public Mono<QueuesSetAccessPolicyResponse> setAccessPolicyWithResponseAsync(
SignedIdentifiersWrapper queueAclConverted = new SignedIdentifiersWrapper(queueAcl);
return service.setAccessPolicy(
this.client.getUrl(),
comp,
queueName,
comp,
timeout,
this.client.getVersion(),
requestId,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,7 @@ public Mono<ServicesGetStatisticsResponse> getStatisticsWithResponseAsync(
* operation crosses a partition boundary, then the service will return a continuation token for retrieving the
* remainder of the results. For this reason, it is possible that the service will return fewer results than
* specified by maxresults, or than the default of 5000.
* @param include Include this parameter to specify that the queues's metadata be returned as part of the response
* @param include Include this parameter to specify that the queues' metadata be returned as part of the response
* body.
* @param timeout The The timeout parameter is expressed in seconds. For more information, see &lt;a
* href="https://docs.microsoft.com/en-us/rest/api/storageservices/setting-timeouts-for-queue-service-operations&gt;Setting
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlRootElement;

/** The QueueMetrics model. */
/** a summary of request statistics grouped by API in hour or minute aggregates for queues. */
@JacksonXmlRootElement(localName = "Metrics")
@Fluent
public final class QueueMetrics {
Expand Down
112 changes: 0 additions & 112 deletions sdk/storage/azure-storage-queue/swagger/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -33,118 +33,6 @@ customization-jar-path: target/azure-storage-queue-customization-1.0.0-beta.1.ja
customization-class: com.azure.storage.queue.customization.QueueStorageCustomization
```
### /{queueName}
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}"]
transform: >
let param = $.put.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const path = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
$.put.parameters.splice(0, 0, { "$ref": path });
$.delete.parameters.splice(0, 0, { "$ref": path });
}
```
### /{queueName}?comp=metadata
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}?comp=metadata"]
transform: >
let param = $.put.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const path = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
$.put.parameters.splice(0, 0, { "$ref": path });
$.get.parameters.splice(0, 0, { "$ref": path });
}
```
### /{queueName}?comp=acl
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}?comp=acl"]
transform: >
let param = $.put.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const path = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
$.put.parameters.splice(0, 0, { "$ref": path });
$.get.parameters.splice(0, 0, { "$ref": path });
}
```
### /{queueName}/messages
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}/messages"]
transform: >
let param = $.get.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const path = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
$.get.parameters.splice(0, 0, { "$ref": path });
$.delete.parameters.splice(0, 0, { "$ref": path });
}
```
### /{queueName}/messages?visibilitytimeout={visibilityTimeout}&messagettl={messageTimeToLive}
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}/messages?visibilitytimeout={visibilityTimeout}&messagettl={messageTimeToLive}"]
transform: >
let param = $.post.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const path = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
$.post.parameters.splice(0, 0, { "$ref": path });
}
```
### /{queueName}/messages?peekonly=true
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}/messages?peekonly=true"]
transform: >
let param = $.get.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const path = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
$.get.parameters.splice(0, 0, { "$ref": path });
}
```
### /{queueName}/messages/{messageid}?popreceipt={popReceipt}&visibilitytimeout={visibilityTimeout}
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}/messages/{messageid}?popreceipt={popReceipt}&visibilitytimeout={visibilityTimeout}"]
transform: >
let param = $.put.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const queueNamePath = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
const messageIdPath = param["$ref"].replace(/[#].*$/, "#/parameters/MessageId");
$.put.parameters.splice(0, 0, { "$ref": queueNamePath });
$.put.parameters.splice(1, 0, { "$ref": messageIdPath });
}
```
### /{queueName}/messages/{messageid}?popreceipt={popReceipt}
``` yaml
directive:
- from: swagger-document
where: $["x-ms-paths"]["/{queueName}/messages/{messageid}?popreceipt={popReceipt}"]
transform: >
let param = $.delete.parameters[0];
if (!param["$ref"].endsWith("QueueName")) {
const queueNamePath = param["$ref"].replace(/[#].*$/, "#/parameters/QueueName");
const messageIdPath = param["$ref"].replace(/[#].*$/, "#/parameters/MessageId");
$.delete.parameters.splice(0, 0, { "$ref": queueNamePath });
$.delete.parameters.splice(1, 0, { "$ref": messageIdPath });
}
```
### Rename MessageItems
``` yaml
directive:
Expand Down

0 comments on commit 879f63e

Please sign in to comment.