- * Header Parameters - *
+ *Header Parameters
*| Name | - *Type | - *Required | - *Description | - *
|---|---|---|---|
| If-Match | - *String | - *No | - *The request should only proceed if an entity matches this string. | - *
| If-Unmodified-Since | - *OffsetDateTime | - *No | - *The request should only proceed if the entity was not modified after this time. | - *
| Name | Type | Required | Description |
| If-Match | String | No | The request should only proceed if an entity matches this string. |
| If-Unmodified-Since | OffsetDateTime | No | The request should only proceed if the entity was not modified after this time. |
- * Request Body Schema - *
+ *Request Body Schema
*{@code
* {
* etag: String (Required)
@@ -100,15 +81,14 @@ public final class JobRouterAdministrationAsyncClient {
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
* }
* }
* }
- * - * Response Body Schema - *
+ *Response Body Schema
*{@code
* {
* etag: String (Required)
@@ -116,6 +96,7 @@ public final class JobRouterAdministrationAsyncClient {
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -130,15 +111,13 @@ public final class JobRouterAdministrationAsyncClient {
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion
- * of {@link Mono}.
+ * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> upsertDistributionPolicyWithResponse(String distributionPolicyId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertDistributionPolicy' is 'application/merge-patch+json'
- // and stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertDistributionPolicy' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertDistributionPolicyWithResponseAsync(distributionPolicyId, resource,
requestOptions);
}
@@ -334,9 +313,7 @@ public Mono updateDistributionPolicy(String distributionPolicyId, Bi
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -344,6 +321,7 @@ public Mono updateDistributionPolicy(String distributionPolicyId, Bi
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -357,8 +335,7 @@ public Mono updateDistributionPolicy(String distributionPolicyId, Bi
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion
- * of {@link Mono}.
+ * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -369,28 +346,14 @@ public Mono> getDistributionPolicyWithResponse(String distr
/**
* Retrieves existing distribution policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -398,6 +361,7 @@ public Mono> getDistributionPolicyWithResponse(String distr
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -438,34 +402,15 @@ public Mono> deleteDistributionPolicyWithResponse(String distribu
/**
* Creates or updates a classification policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -474,19 +419,20 @@ public Mono> deleteDistributionPolicyWithResponse(String distribu
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -495,12 +441,15 @@ public Mono> deleteDistributionPolicyWithResponse(String distribu
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -513,15 +462,13 @@ public Mono> deleteDistributionPolicyWithResponse(String distribu
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful
- * completion of {@link Mono}.
+ * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> upsertClassificationPolicyWithResponse(String classificationPolicyId,
BinaryData resource, RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertClassificationPolicy' is 'application/merge-patch+json'
- // and stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertClassificationPolicy' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertClassificationPolicyWithResponseAsync(classificationPolicyId, resource,
requestOptions);
}
@@ -740,9 +687,7 @@ public Mono updateClassificationPolicy(String classificationPolicyId
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -751,12 +696,15 @@ public Mono updateClassificationPolicy(String classificationPolicyId
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -768,8 +716,7 @@ public Mono updateClassificationPolicy(String classificationPolicyId
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful
- * completion of {@link Mono}.
+ * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -780,28 +727,14 @@ public Mono> getClassificationPolicyWithResponse(String cla
/**
* Retrieves existing classification policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -810,12 +743,15 @@ public Mono> getClassificationPolicyWithResponse(String cla
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -854,34 +790,15 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
/**
* Creates or updates a exception policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -891,9 +808,11 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -901,9 +820,7 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -913,9 +830,11 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -931,15 +850,13 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a policy that defines actions to execute when exception are triggered along with {@link Response} on
- * successful completion of {@link Mono}.
+ * @return a policy that defines actions to execute when exception are triggered along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> upsertExceptionPolicyWithResponse(String exceptionPolicyId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertExceptionPolicy' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertExceptionPolicy' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertExceptionPolicyWithResponseAsync(exceptionPolicyId, resource, requestOptions);
}
@@ -1261,34 +1178,15 @@ public Mono> deleteExceptionPolicyWithResponse(String exceptionPo
/**
* Creates or updates a queue.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1301,9 +1199,7 @@ public Mono> deleteExceptionPolicyWithResponse(String exceptionPo
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1324,15 +1220,13 @@ public Mono> deleteExceptionPolicyWithResponse(String exceptionPo
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of
- * {@link Mono}.
+ * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> upsertQueueWithResponse(String queueId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertQueue' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertQueue' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertQueueWithResponseAsync(queueId, resource, requestOptions);
}
@@ -1522,9 +1416,7 @@ public Mono createQueue(CreateQueueOptions createQueueOptions) {
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1544,8 +1436,7 @@ public Mono createQueue(CreateQueueOptions createQueueOptions) {
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of
- * {@link Mono}.
+ * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -1555,28 +1446,14 @@ public Mono> getQueueWithResponse(String queueId, RequestOp
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1656,11 +1533,13 @@ public PagedFlux listDistributionPolicies() {
RequestOptions requestOptions = new RequestOptions();
PagedFlux pagedFluxResponse = listDistributionPolicies(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(DistributionPolicy.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
@@ -1723,12 +1602,14 @@ public PagedFlux listClassificationPolicies() {
RequestOptions requestOptions = new RequestOptions();
PagedFlux pagedFluxResponse = listClassificationPolicies(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux
.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(ClassificationPolicy.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
@@ -1792,11 +1673,13 @@ public PagedFlux listExceptionPolicies() {
RequestOptions requestOptions = new RequestOptions();
PagedFlux pagedFluxResponse = listExceptionPolicies(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(ExceptionPolicy.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
@@ -1859,11 +1742,13 @@ public PagedFlux listQueues() {
RequestOptions requestOptions = new RequestOptions();
PagedFlux pagedFluxResponse = listQueues(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(RouterQueue.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
diff --git a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClient.java b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClient.java
index 441aed1278c5..e8a9a26a556e 100644
--- a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClient.java
+++ b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClient.java
@@ -4,26 +4,10 @@
package com.azure.communication.jobrouter;
import com.azure.communication.jobrouter.implementation.JobRouterAdministrationClientImpl;
-import com.azure.communication.jobrouter.implementation.accesshelpers.ClassificationPolicyConstructorProxy;
-import com.azure.communication.jobrouter.implementation.accesshelpers.DistributionPolicyConstructorProxy;
-import com.azure.communication.jobrouter.implementation.accesshelpers.ExceptionPolicyConstructorProxy;
-import com.azure.communication.jobrouter.implementation.accesshelpers.RouterQueueConstructorProxy;
-import com.azure.communication.jobrouter.implementation.converters.ClassificationPolicyAdapter;
-import com.azure.communication.jobrouter.implementation.converters.DistributionPolicyAdapter;
-import com.azure.communication.jobrouter.implementation.converters.ExceptionPolicyAdapter;
-import com.azure.communication.jobrouter.implementation.converters.QueueAdapter;
import com.azure.communication.jobrouter.implementation.models.ClassificationPolicyInternal;
import com.azure.communication.jobrouter.implementation.models.DistributionPolicyInternal;
import com.azure.communication.jobrouter.implementation.models.ExceptionPolicyInternal;
import com.azure.communication.jobrouter.implementation.models.RouterQueueInternal;
-import com.azure.communication.jobrouter.models.ClassificationPolicy;
-import com.azure.communication.jobrouter.models.CreateClassificationPolicyOptions;
-import com.azure.communication.jobrouter.models.CreateDistributionPolicyOptions;
-import com.azure.communication.jobrouter.models.CreateExceptionPolicyOptions;
-import com.azure.communication.jobrouter.models.CreateQueueOptions;
-import com.azure.communication.jobrouter.models.DistributionPolicy;
-import com.azure.communication.jobrouter.models.ExceptionPolicy;
-import com.azure.communication.jobrouter.models.RouterQueue;
import com.azure.core.annotation.Generated;
import com.azure.core.annotation.ReturnType;
import com.azure.core.annotation.ServiceClient;
@@ -37,6 +21,22 @@
import com.azure.core.http.rest.Response;
import com.azure.core.http.rest.SimpleResponse;
import com.azure.core.util.BinaryData;
+import com.azure.communication.jobrouter.implementation.accesshelpers.ClassificationPolicyConstructorProxy;
+import com.azure.communication.jobrouter.implementation.accesshelpers.DistributionPolicyConstructorProxy;
+import com.azure.communication.jobrouter.implementation.accesshelpers.ExceptionPolicyConstructorProxy;
+import com.azure.communication.jobrouter.implementation.accesshelpers.RouterQueueConstructorProxy;
+import com.azure.communication.jobrouter.implementation.converters.ClassificationPolicyAdapter;
+import com.azure.communication.jobrouter.implementation.converters.DistributionPolicyAdapter;
+import com.azure.communication.jobrouter.implementation.converters.ExceptionPolicyAdapter;
+import com.azure.communication.jobrouter.implementation.converters.QueueAdapter;
+import com.azure.communication.jobrouter.models.ClassificationPolicy;
+import com.azure.communication.jobrouter.models.CreateClassificationPolicyOptions;
+import com.azure.communication.jobrouter.models.CreateDistributionPolicyOptions;
+import com.azure.communication.jobrouter.models.CreateExceptionPolicyOptions;
+import com.azure.communication.jobrouter.models.CreateQueueOptions;
+import com.azure.communication.jobrouter.models.DistributionPolicy;
+import com.azure.communication.jobrouter.models.ExceptionPolicy;
+import com.azure.communication.jobrouter.models.RouterQueue;
/**
* Initializes a new instance of the synchronous JobRouterAdministrationClient type.
@@ -59,34 +59,15 @@ public final class JobRouterAdministrationClient {
/**
* Creates or updates a distribution policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -94,15 +75,14 @@ public final class JobRouterAdministrationClient {
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
* }
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -110,6 +90,7 @@ public final class JobRouterAdministrationClient {
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -130,8 +111,7 @@ public final class JobRouterAdministrationClient {
@ServiceMethod(returns = ReturnType.SINGLE)
Response upsertDistributionPolicyWithResponse(String distributionPolicyId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertDistributionPolicy' is 'application/merge-patch+json'
- // and stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertDistributionPolicy' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertDistributionPolicyWithResponse(distributionPolicyId, resource, requestOptions);
}
@@ -326,9 +306,7 @@ public Response createDistributionPolicyWithResponse(
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -336,6 +314,7 @@ public Response createDistributionPolicyWithResponse(
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -360,28 +339,14 @@ public Response getDistributionPolicyWithResponse(String distributio
/**
* Retrieves existing distribution policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -389,6 +354,7 @@ public Response getDistributionPolicyWithResponse(String distributio
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -429,34 +395,15 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
/**
* Creates or updates a classification policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -465,19 +412,20 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -486,12 +434,15 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -510,8 +461,7 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
@ServiceMethod(returns = ReturnType.SINGLE)
Response upsertClassificationPolicyWithResponse(String classificationPolicyId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertClassificationPolicy' is 'application/merge-patch+json'
- // and stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertClassificationPolicy' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertClassificationPolicyWithResponse(classificationPolicyId, resource,
requestOptions);
}
@@ -729,9 +679,7 @@ public Response createClassificationPolicyWithResponse(
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -740,12 +688,15 @@ public Response createClassificationPolicyWithResponse(
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -768,28 +719,14 @@ public Response getClassificationPolicyWithResponse(String classific
/**
* Retrieves existing classification policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -798,12 +735,15 @@ public Response getClassificationPolicyWithResponse(String classific
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -842,34 +782,15 @@ public Response deleteClassificationPolicyWithResponse(String classificati
/**
* Creates or updates a exception policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -879,9 +800,11 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -889,9 +812,7 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -901,9 +822,11 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -925,8 +848,7 @@ public Response deleteClassificationPolicyWithResponse(String classificati
@ServiceMethod(returns = ReturnType.SINGLE)
Response upsertExceptionPolicyWithResponse(String exceptionPolicyId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertExceptionPolicy' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertExceptionPolicy' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertExceptionPolicyWithResponse(exceptionPolicyId, resource, requestOptions);
}
@@ -1248,34 +1170,15 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
/**
* Creates or updates a queue.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1288,9 +1191,7 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1316,8 +1217,7 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Response upsertQueueWithResponse(String queueId, BinaryData resource, RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertQueue' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertQueue' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertQueueWithResponse(queueId, resource, requestOptions);
}
@@ -1503,9 +1403,7 @@ public RouterQueue createQueue(CreateQueueOptions createQueueOptions) {
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1535,28 +1433,14 @@ public Response getQueueWithResponse(String queueId, RequestOptions
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
diff --git a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClientBuilder.java b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClientBuilder.java
index 55d42b11f47d..e3d36ca9ef21 100644
--- a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClientBuilder.java
+++ b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAdministrationClientBuilder.java
@@ -3,18 +3,15 @@
// Code generated by Microsoft (R) TypeSpec Code Generator.
package com.azure.communication.jobrouter;
-import com.azure.communication.common.implementation.CommunicationConnectionString;
+import com.azure.core.client.traits.TokenCredentialTrait;
+import com.azure.core.client.traits.KeyCredentialTrait;
+import com.azure.core.client.traits.ConnectionStringTrait;
import com.azure.communication.jobrouter.implementation.JobRouterAdministrationClientImpl;
import com.azure.core.annotation.Generated;
import com.azure.core.annotation.ServiceClientBuilder;
import com.azure.core.client.traits.ConfigurationTrait;
-import com.azure.core.client.traits.ConnectionStringTrait;
import com.azure.core.client.traits.EndpointTrait;
import com.azure.core.client.traits.HttpTrait;
-import com.azure.core.client.traits.KeyCredentialTrait;
-import com.azure.core.client.traits.TokenCredentialTrait;
-import com.azure.core.credential.KeyCredential;
-import com.azure.core.credential.TokenCredential;
import com.azure.core.http.HttpClient;
import com.azure.core.http.HttpHeaderName;
import com.azure.core.http.HttpHeaders;
@@ -24,8 +21,8 @@
import com.azure.core.http.policy.AddDatePolicy;
import com.azure.core.http.policy.AddHeadersFromContextPolicy;
import com.azure.core.http.policy.AddHeadersPolicy;
-import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpLoggingPolicy;
+import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpPipelinePolicy;
import com.azure.core.http.policy.HttpPolicyProviders;
import com.azure.core.http.policy.RequestIdPolicy;
@@ -42,6 +39,9 @@
import java.util.List;
import java.util.Map;
import java.util.Objects;
+import com.azure.communication.common.implementation.CommunicationConnectionString;
+import com.azure.core.credential.KeyCredential;
+import com.azure.core.credential.TokenCredential;
/**
* A builder for creating a new instance of the JobRouterAdministrationClient type.
@@ -265,17 +265,21 @@ private HttpPipeline createHttpPipeline() {
if (headers.getSize() > 0) {
policies.add(new AddHeadersPolicy(headers));
}
- this.pipelinePolicies.stream().filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
+ this.pipelinePolicies.stream()
+ .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
.forEach(p -> policies.add(p));
HttpPolicyProviders.addBeforeRetryPolicies(policies);
policies.add(ClientBuilderUtil.validateAndGetRetryPolicy(retryPolicy, retryOptions, new RetryPolicy()));
policies.add(new AddDatePolicy());
- this.pipelinePolicies.stream().filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
+ this.pipelinePolicies.stream()
+ .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
.forEach(p -> policies.add(p));
HttpPolicyProviders.addAfterRetryPolicies(policies);
policies.add(new HttpLoggingPolicy(localHttpLogOptions));
HttpPipeline httpPipeline = new HttpPipelineBuilder().policies(policies.toArray(new HttpPipelinePolicy[0]))
- .httpClient(httpClient).clientOptions(localClientOptions).build();
+ .httpClient(httpClient)
+ .clientOptions(localClientOptions)
+ .build();
return httpPipeline;
}
diff --git a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAsyncClient.java b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAsyncClient.java
index d5e799d9758e..6e4985941079 100644
--- a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAsyncClient.java
+++ b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterAsyncClient.java
@@ -4,10 +4,6 @@
package com.azure.communication.jobrouter;
import com.azure.communication.jobrouter.implementation.JobRouterClientImpl;
-import com.azure.communication.jobrouter.implementation.accesshelpers.RouterJobConstructorProxy;
-import com.azure.communication.jobrouter.implementation.accesshelpers.RouterWorkerConstructorProxy;
-import com.azure.communication.jobrouter.implementation.converters.JobAdapter;
-import com.azure.communication.jobrouter.implementation.converters.WorkerAdapter;
import com.azure.communication.jobrouter.implementation.models.CancelJobOptionsInternal;
import com.azure.communication.jobrouter.implementation.models.CancelJobResultInternal;
import com.azure.communication.jobrouter.implementation.models.CloseJobOptionsInternal;
@@ -21,13 +17,8 @@
import com.azure.communication.jobrouter.implementation.models.RouterJobInternal;
import com.azure.communication.jobrouter.implementation.models.RouterWorkerInternal;
import com.azure.communication.jobrouter.models.AcceptJobOfferResult;
-import com.azure.communication.jobrouter.models.CreateJobOptions;
-import com.azure.communication.jobrouter.models.CreateWorkerOptions;
-import com.azure.communication.jobrouter.models.RouterJob;
import com.azure.communication.jobrouter.models.RouterJobPositionDetails;
import com.azure.communication.jobrouter.models.RouterJobStatusSelector;
-import com.azure.communication.jobrouter.models.RouterQueueStatistics;
-import com.azure.communication.jobrouter.models.RouterWorker;
import com.azure.communication.jobrouter.models.RouterWorkerStateSelector;
import com.azure.communication.jobrouter.models.UnassignJobOptions;
import com.azure.communication.jobrouter.models.UnassignJobResult;
@@ -51,6 +42,15 @@
import java.util.stream.Collectors;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
+import com.azure.communication.jobrouter.implementation.accesshelpers.RouterJobConstructorProxy;
+import com.azure.communication.jobrouter.implementation.accesshelpers.RouterWorkerConstructorProxy;
+import com.azure.communication.jobrouter.implementation.converters.JobAdapter;
+import com.azure.communication.jobrouter.implementation.converters.WorkerAdapter;
+import com.azure.communication.jobrouter.models.CreateJobOptions;
+import com.azure.communication.jobrouter.models.CreateWorkerOptions;
+import com.azure.communication.jobrouter.models.RouterJob;
+import com.azure.communication.jobrouter.models.RouterQueueStatistics;
+import com.azure.communication.jobrouter.models.RouterWorker;
/**
* Initializes a new instance of the asynchronous JobRouterClient type.
@@ -73,34 +73,15 @@ public final class JobRouterAsyncClient {
/**
* Creates or updates a router job.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -150,12 +131,11 @@ public final class JobRouterAsyncClient {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -205,6 +185,7 @@ public final class JobRouterAsyncClient {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -221,8 +202,7 @@ public final class JobRouterAsyncClient {
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> upsertJobWithResponse(String jobId, BinaryData resource, RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertJob' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertJob' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertJobWithResponseAsync(jobId, resource, requestOptions);
}
@@ -554,9 +534,7 @@ public Mono createJob(CreateJobOptions createJobOptions) {
/**
* Retrieves an existing job by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -606,6 +584,7 @@ public Mono createJob(CreateJobOptions createJobOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -763,67 +742,20 @@ public Mono cancelJob(String jobId, RequestOptions requestOptions) {
/**
* Retrieves list of jobs based on filter parameters.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
- *
- * status
- * String
- * No
- * If specified, filter jobs by status. Allowed values: "all", "pendingClassification", "queued", "assigned",
- * "completed", "closed", "cancelled", "classificationFailed", "created", "pendingSchedule", "scheduled",
- * "scheduleFailed", "waitingForActivation", "active".
- *
- *
- * queueId
- * String
- * No
- * If specified, filter jobs by queue.
- *
- *
- * channelId
- * String
- * No
- * If specified, filter jobs by channel.
- *
- *
- * classificationPolicyId
- * String
- * No
- * If specified, filter jobs by classificationPolicy.
- *
- *
- * scheduledBefore
- * OffsetDateTime
- * No
- * If specified, filter on jobs that was scheduled before or at given timestamp. Range: (-Inf,
- * scheduledBefore].
- *
- *
- * scheduledAfter
- * OffsetDateTime
- * No
- * If specified, filter on jobs that was scheduled at or after given value. Range: [scheduledAfter, +Inf).
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page. status String No If specified, filter jobs by status. Allowed values: "all", "pendingClassification", "queued", "assigned", "completed", "closed", "cancelled", "classificationFailed", "created", "pendingSchedule", "scheduled", "scheduleFailed", "waitingForActivation", "active". queueId String No If specified, filter jobs by queue. channelId String No If specified, filter jobs by channel. classificationPolicyId String No If specified, filter jobs by classificationPolicy. scheduledBefore OffsetDateTime No If specified, filter on jobs that was scheduled before or at given timestamp. Range: (-Inf, scheduledBefore]. scheduledAfter OffsetDateTime No If specified, filter on jobs that was scheduled at or after given value. Range: [scheduledAfter, +Inf).
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -873,6 +805,7 @@ public Mono cancelJob(String jobId, RequestOptions requestOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -892,9 +825,7 @@ public PagedFlux listJobs(RequestOptions requestOptions) {
/**
* Gets a job's position details.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* jobId: String (Required)
@@ -921,17 +852,13 @@ public Mono> getQueuePositionWithResponse(String jobId, Req
/**
* Unassign a job.
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* suspendMatching: Boolean (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* jobId: String (Required)
@@ -946,8 +873,7 @@ public Mono> getQueuePositionWithResponse(String jobId, Req
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return response payload after a job has been successfully unassigned along with {@link Response} on successful
- * completion of {@link Mono}.
+ * @return response payload after a job has been successfully unassigned along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -958,9 +884,7 @@ public Mono> unassignJobWithResponse(String jobId, String a
/**
* Accepts an offer to work on a job and returns a 409/Conflict if another agent accepted the job already.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* assignmentId: String (Required)
@@ -976,8 +900,7 @@ public Mono> unassignJobWithResponse(String jobId, String a
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return response containing ids for the worker, job, and assignment from an accepted offer along with
- * {@link Response} on successful completion of {@link Mono}.
+ * @return response containing ids for the worker, job, and assignment from an accepted offer along with {@link Response} on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -1052,9 +975,7 @@ public Mono declineJobOffer(String workerId, String offerId, Request
/**
* Retrieves a queue's statistics.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* queueId: String (Required)
@@ -1082,34 +1003,15 @@ public Mono> getQueueStatisticsWithResponse(String queueId,
/**
* Creates or updates a worker.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1154,9 +1056,7 @@ public Mono> getQueueStatisticsWithResponse(String queueId,
* maxConcurrentOffers: Integer (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1215,8 +1115,7 @@ public Mono> getQueueStatisticsWithResponse(String queueId,
@ServiceMethod(returns = ReturnType.SINGLE)
Mono> upsertWorkerWithResponse(String workerId, BinaryData resource,
RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertWorker' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertWorker' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertWorkerWithResponseAsync(workerId, resource, requestOptions);
}
@@ -1526,9 +1425,7 @@ public Mono createWorker(CreateWorkerOptions createWorkerOptions)
/**
* Retrieves an existing worker by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1607,54 +1504,18 @@ public Mono> deleteWorkerWithResponse(String workerId, RequestOpt
/**
* Retrieves existing workers.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
- *
- * state
- * String
- * No
- * If specified, select workers by worker state. Allowed values: "active", "draining", "inactive", "all".
- *
- *
- * channelId
- * String
- * No
- * If specified, select workers who have a channel configuration with this channel.
- *
- *
- * queueId
- * String
- * No
- * If specified, select workers who are assigned to this queue.
- *
- *
- * hasCapacity
- * Boolean
- * No
- * If set to true, select only workers who have capacity for the channel specified by `channelId` or for any
- * channel if `channelId` not specified. If set to false, then will return all workers including workers without any
- * capacity for jobs. Defaults to false.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page. state String No If specified, select workers by worker state. Allowed values: "active", "draining", "inactive", "all". channelId String No If specified, select workers who have a channel configuration with this channel. queueId String No If specified, select workers who are assigned to this queue. hasCapacity Boolean No If set to true, select only workers who have capacity for the channel specified by `channelId` or for any channel if `channelId` not specified. If set to false, then will return all workers including workers without any capacity for jobs. Defaults to false.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1818,11 +1679,13 @@ public PagedFlux listJobs(RouterJobStatusSelector status, String queu
}
PagedFlux pagedFluxResponse = listJobs(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(RouterJob.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
@@ -1845,11 +1708,13 @@ public PagedFlux listJobs() {
RequestOptions requestOptions = new RequestOptions();
PagedFlux pagedFluxResponse = listJobs(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(RouterJob.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
@@ -1910,8 +1775,7 @@ public Mono unassignJob(String jobId, String assignmentId) {
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return response containing ids for the worker, job, and assignment from an accepted offer on successful
- * completion of {@link Mono}.
+ * @return response containing ids for the worker, job, and assignment from an accepted offer on successful completion of {@link Mono}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -2040,11 +1904,13 @@ public PagedFlux listWorkers(RouterWorkerStateSelector state, Stri
}
PagedFlux pagedFluxResponse = listWorkers(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(RouterWorker.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
@@ -2067,11 +1933,13 @@ public PagedFlux listWorkers() {
RequestOptions requestOptions = new RequestOptions();
PagedFlux pagedFluxResponse = listWorkers(requestOptions);
return PagedFlux.create(() -> (continuationToken, pageSize) -> {
- Flux> flux = (continuationToken == null) ? pagedFluxResponse.byPage().take(1)
+ Flux> flux = (continuationToken == null)
+ ? pagedFluxResponse.byPage().take(1)
: pagedFluxResponse.byPage(continuationToken).take(1);
return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
- pagedResponse.getValue().stream()
+ pagedResponse.getValue()
+ .stream()
.map(protocolMethodData -> protocolMethodData.toObject(RouterWorker.class))
.collect(Collectors.toList()),
pagedResponse.getContinuationToken(), null));
diff --git a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClient.java b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClient.java
index 84fb6a865702..9545a2891e72 100644
--- a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClient.java
+++ b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClient.java
@@ -4,10 +4,6 @@
package com.azure.communication.jobrouter;
import com.azure.communication.jobrouter.implementation.JobRouterClientImpl;
-import com.azure.communication.jobrouter.implementation.accesshelpers.RouterJobConstructorProxy;
-import com.azure.communication.jobrouter.implementation.accesshelpers.RouterWorkerConstructorProxy;
-import com.azure.communication.jobrouter.implementation.converters.JobAdapter;
-import com.azure.communication.jobrouter.implementation.converters.WorkerAdapter;
import com.azure.communication.jobrouter.implementation.models.CancelJobOptionsInternal;
import com.azure.communication.jobrouter.implementation.models.CancelJobResultInternal;
import com.azure.communication.jobrouter.implementation.models.CloseJobOptionsInternal;
@@ -21,13 +17,8 @@
import com.azure.communication.jobrouter.implementation.models.RouterJobInternal;
import com.azure.communication.jobrouter.implementation.models.RouterWorkerInternal;
import com.azure.communication.jobrouter.models.AcceptJobOfferResult;
-import com.azure.communication.jobrouter.models.CreateJobOptions;
-import com.azure.communication.jobrouter.models.CreateWorkerOptions;
-import com.azure.communication.jobrouter.models.RouterJob;
import com.azure.communication.jobrouter.models.RouterJobPositionDetails;
import com.azure.communication.jobrouter.models.RouterJobStatusSelector;
-import com.azure.communication.jobrouter.models.RouterQueueStatistics;
-import com.azure.communication.jobrouter.models.RouterWorker;
import com.azure.communication.jobrouter.models.RouterWorkerStateSelector;
import com.azure.communication.jobrouter.models.UnassignJobOptions;
import com.azure.communication.jobrouter.models.UnassignJobResult;
@@ -45,6 +36,15 @@
import com.azure.core.http.rest.SimpleResponse;
import com.azure.core.util.BinaryData;
import java.time.OffsetDateTime;
+import com.azure.communication.jobrouter.implementation.accesshelpers.RouterJobConstructorProxy;
+import com.azure.communication.jobrouter.implementation.accesshelpers.RouterWorkerConstructorProxy;
+import com.azure.communication.jobrouter.implementation.converters.JobAdapter;
+import com.azure.communication.jobrouter.implementation.converters.WorkerAdapter;
+import com.azure.communication.jobrouter.models.CreateJobOptions;
+import com.azure.communication.jobrouter.models.CreateWorkerOptions;
+import com.azure.communication.jobrouter.models.RouterJob;
+import com.azure.communication.jobrouter.models.RouterQueueStatistics;
+import com.azure.communication.jobrouter.models.RouterWorker;
/**
* Initializes a new instance of the synchronous JobRouterClient type.
@@ -67,34 +67,15 @@ public final class JobRouterClient {
/**
* Creates or updates a router job.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -144,12 +125,11 @@ public final class JobRouterClient {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -199,6 +179,7 @@ public final class JobRouterClient {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -215,8 +196,7 @@ public final class JobRouterClient {
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Response upsertJobWithResponse(String jobId, BinaryData resource, RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertJob' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertJob' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertJobWithResponse(jobId, resource, requestOptions);
}
@@ -556,9 +536,7 @@ public RouterJob createJob(CreateJobOptions createJobOptions) {
/**
* Retrieves an existing job by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -608,6 +586,7 @@ public RouterJob createJob(CreateJobOptions createJobOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -769,67 +748,20 @@ public BinaryData cancelJob(String jobId, RequestOptions requestOptions) {
/**
* Retrieves list of jobs based on filter parameters.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
- *
- * status
- * String
- * No
- * If specified, filter jobs by status. Allowed values: "all", "pendingClassification", "queued", "assigned",
- * "completed", "closed", "cancelled", "classificationFailed", "created", "pendingSchedule", "scheduled",
- * "scheduleFailed", "waitingForActivation", "active".
- *
- *
- * queueId
- * String
- * No
- * If specified, filter jobs by queue.
- *
- *
- * channelId
- * String
- * No
- * If specified, filter jobs by channel.
- *
- *
- * classificationPolicyId
- * String
- * No
- * If specified, filter jobs by classificationPolicy.
- *
- *
- * scheduledBefore
- * OffsetDateTime
- * No
- * If specified, filter on jobs that was scheduled before or at given timestamp. Range: (-Inf,
- * scheduledBefore].
- *
- *
- * scheduledAfter
- * OffsetDateTime
- * No
- * If specified, filter on jobs that was scheduled at or after given value. Range: [scheduledAfter, +Inf).
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page. status String No If specified, filter jobs by status. Allowed values: "all", "pendingClassification", "queued", "assigned", "completed", "closed", "cancelled", "classificationFailed", "created", "pendingSchedule", "scheduled", "scheduleFailed", "waitingForActivation", "active". queueId String No If specified, filter jobs by queue. channelId String No If specified, filter jobs by channel. classificationPolicyId String No If specified, filter jobs by classificationPolicy. scheduledBefore OffsetDateTime No If specified, filter on jobs that was scheduled before or at given timestamp. Range: (-Inf, scheduledBefore]. scheduledAfter OffsetDateTime No If specified, filter on jobs that was scheduled at or after given value. Range: [scheduledAfter, +Inf).
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -879,6 +811,7 @@ public BinaryData cancelJob(String jobId, RequestOptions requestOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -898,9 +831,7 @@ public PagedIterable listJobs(RequestOptions requestOptions) {
/**
* Gets a job's position details.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* jobId: String (Required)
@@ -927,17 +858,13 @@ public Response getQueuePositionWithResponse(String jobId, RequestOp
/**
* Unassign a job.
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* suspendMatching: Boolean (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* jobId: String (Required)
@@ -963,9 +890,7 @@ public Response unassignJobWithResponse(String jobId, String assignm
/**
* Accepts an offer to work on a job and returns a 409/Conflict if another agent accepted the job already.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* assignmentId: String (Required)
@@ -981,8 +906,7 @@ public Response unassignJobWithResponse(String jobId, String assignm
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return response containing ids for the worker, job, and assignment from an accepted offer along with
- * {@link Response}.
+ * @return response containing ids for the worker, job, and assignment from an accepted offer along with {@link Response}.
*/
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
@@ -1058,9 +982,7 @@ public BinaryData declineJobOffer(String workerId, String offerId, RequestOption
/**
* Retrieves a queue's statistics.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* queueId: String (Required)
@@ -1088,34 +1010,15 @@ public Response getQueueStatisticsWithResponse(String queueId, Reque
/**
* Creates or updates a worker.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1160,9 +1063,7 @@ public Response getQueueStatisticsWithResponse(String queueId, Reque
* maxConcurrentOffers: Integer (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1220,8 +1121,7 @@ public Response getQueueStatisticsWithResponse(String queueId, Reque
@Generated
@ServiceMethod(returns = ReturnType.SINGLE)
Response upsertWorkerWithResponse(String workerId, BinaryData resource, RequestOptions requestOptions) {
- // Convenience API is not generated, as operation 'upsertWorker' is 'application/merge-patch+json' and
- // stream-style-serialization is not enabled
+ // Convenience API is not generated, as operation 'upsertWorker' is 'application/merge-patch+json' and stream-style-serialization is not enabled
return this.serviceClient.upsertWorkerWithResponse(workerId, resource, requestOptions);
}
@@ -1535,9 +1435,7 @@ public RouterWorker createWorker(CreateWorkerOptions createWorkerOptions) {
/**
* Retrieves an existing worker by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1616,54 +1514,18 @@ public Response deleteWorkerWithResponse(String workerId, RequestOptions r
/**
* Retrieves existing workers.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
- *
- * state
- * String
- * No
- * If specified, select workers by worker state. Allowed values: "active", "draining", "inactive", "all".
- *
- *
- * channelId
- * String
- * No
- * If specified, select workers who have a channel configuration with this channel.
- *
- *
- * queueId
- * String
- * No
- * If specified, select workers who are assigned to this queue.
- *
- *
- * hasCapacity
- * Boolean
- * No
- * If set to true, select only workers who have capacity for the channel specified by `channelId` or for any
- * channel if `channelId` not specified. If set to false, then will return all workers including workers without any
- * capacity for jobs. Defaults to false.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page. state String No If specified, select workers by worker state. Allowed values: "active", "draining", "inactive", "all". channelId String No If specified, select workers who have a channel configuration with this channel. queueId String No If specified, select workers who are assigned to this queue. hasCapacity Boolean No If set to true, select only workers who have capacity for the channel specified by `channelId` or for any channel if `channelId` not specified. If set to false, then will return all workers including workers without any capacity for jobs. Defaults to false.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
diff --git a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClientBuilder.java b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClientBuilder.java
index 1b2ca0cc07a9..dc21bd5288ec 100644
--- a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClientBuilder.java
+++ b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/JobRouterClientBuilder.java
@@ -3,18 +3,15 @@
// Code generated by Microsoft (R) TypeSpec Code Generator.
package com.azure.communication.jobrouter;
-import com.azure.communication.common.implementation.CommunicationConnectionString;
+import com.azure.core.client.traits.TokenCredentialTrait;
+import com.azure.core.client.traits.KeyCredentialTrait;
+import com.azure.core.client.traits.ConnectionStringTrait;
import com.azure.communication.jobrouter.implementation.JobRouterClientImpl;
import com.azure.core.annotation.Generated;
import com.azure.core.annotation.ServiceClientBuilder;
import com.azure.core.client.traits.ConfigurationTrait;
-import com.azure.core.client.traits.ConnectionStringTrait;
import com.azure.core.client.traits.EndpointTrait;
import com.azure.core.client.traits.HttpTrait;
-import com.azure.core.client.traits.KeyCredentialTrait;
-import com.azure.core.client.traits.TokenCredentialTrait;
-import com.azure.core.credential.KeyCredential;
-import com.azure.core.credential.TokenCredential;
import com.azure.core.http.HttpClient;
import com.azure.core.http.HttpHeaderName;
import com.azure.core.http.HttpHeaders;
@@ -24,8 +21,8 @@
import com.azure.core.http.policy.AddDatePolicy;
import com.azure.core.http.policy.AddHeadersFromContextPolicy;
import com.azure.core.http.policy.AddHeadersPolicy;
-import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpLoggingPolicy;
+import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpPipelinePolicy;
import com.azure.core.http.policy.HttpPolicyProviders;
import com.azure.core.http.policy.RequestIdPolicy;
@@ -42,6 +39,9 @@
import java.util.List;
import java.util.Map;
import java.util.Objects;
+import com.azure.communication.common.implementation.CommunicationConnectionString;
+import com.azure.core.credential.KeyCredential;
+import com.azure.core.credential.TokenCredential;
/**
* A builder for creating a new instance of the JobRouterClient type.
@@ -263,17 +263,21 @@ private HttpPipeline createHttpPipeline() {
if (headers.getSize() > 0) {
policies.add(new AddHeadersPolicy(headers));
}
- this.pipelinePolicies.stream().filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
+ this.pipelinePolicies.stream()
+ .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
.forEach(p -> policies.add(p));
HttpPolicyProviders.addBeforeRetryPolicies(policies);
policies.add(ClientBuilderUtil.validateAndGetRetryPolicy(retryPolicy, retryOptions, new RetryPolicy()));
policies.add(new AddDatePolicy());
- this.pipelinePolicies.stream().filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
+ this.pipelinePolicies.stream()
+ .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
.forEach(p -> policies.add(p));
HttpPolicyProviders.addAfterRetryPolicies(policies);
policies.add(new HttpLoggingPolicy(localHttpLogOptions));
HttpPipeline httpPipeline = new HttpPipelineBuilder().policies(policies.toArray(new HttpPipelinePolicy[0]))
- .httpClient(httpClient).clientOptions(localClientOptions).build();
+ .httpClient(httpClient)
+ .clientOptions(localClientOptions)
+ .build();
return httpPipeline;
}
diff --git a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/implementation/JobRouterAdministrationClientImpl.java b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/implementation/JobRouterAdministrationClientImpl.java
index 1ee22ed8e203..8b8c44a8d6f3 100644
--- a/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/implementation/JobRouterAdministrationClientImpl.java
+++ b/sdk/communication/azure-communication-jobrouter/src/main/java/com/azure/communication/jobrouter/implementation/JobRouterAdministrationClientImpl.java
@@ -152,8 +152,7 @@ public JobRouterAdministrationClientImpl(HttpPipeline httpPipeline, SerializerAd
}
/**
- * The interface defining all the services for JobRouterAdministrationClient to be used by the proxy service to
- * perform REST calls.
+ * The interface defining all the services for JobRouterAdministrationClient to be used by the proxy service to perform REST calls.
*/
@Host("{endpoint}")
@ServiceInterface(name = "JobRouterAdministrat")
@@ -589,34 +588,15 @@ Response listQueuesNextSync(@PathParam(value = "nextLink", encoded =
/**
* Creates or updates a distribution policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -624,15 +604,14 @@ Response listQueuesNextSync(@PathParam(value = "nextLink", encoded =
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
* }
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -640,6 +619,7 @@ Response listQueuesNextSync(@PathParam(value = "nextLink", encoded =
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -654,8 +634,7 @@ Response listQueuesNextSync(@PathParam(value = "nextLink", encoded =
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion
- * of {@link Mono}.
+ * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> upsertDistributionPolicyWithResponseAsync(String distributionPolicyId,
@@ -669,34 +648,15 @@ public Mono> upsertDistributionPolicyWithResponseAsync(Stri
/**
* Creates or updates a distribution policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -704,15 +664,14 @@ public Mono> upsertDistributionPolicyWithResponseAsync(Stri
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
* }
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -720,6 +679,7 @@ public Mono> upsertDistributionPolicyWithResponseAsync(Stri
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -747,9 +707,7 @@ public Response upsertDistributionPolicyWithResponse(String distribu
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -757,6 +715,7 @@ public Response upsertDistributionPolicyWithResponse(String distribu
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -770,8 +729,7 @@ public Response upsertDistributionPolicyWithResponse(String distribu
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion
- * of {@link Mono}.
+ * @return policy governing how jobs are distributed to workers along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getDistributionPolicyWithResponseAsync(String distributionPolicyId,
@@ -783,9 +741,7 @@ public Mono> getDistributionPolicyWithResponseAsync(String
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -793,6 +749,7 @@ public Mono> getDistributionPolicyWithResponseAsync(String
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -818,28 +775,14 @@ public Response getDistributionPolicyWithResponse(String distributio
/**
* Retrieves existing distribution policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -847,6 +790,7 @@ public Response getDistributionPolicyWithResponse(String distributio
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -859,8 +803,7 @@ public Response getDistributionPolicyWithResponse(String distributio
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return paged collection of DistributionPolicy items along with {@link PagedResponse} on successful completion of
- * {@link Mono}.
+ * @return paged collection of DistributionPolicy items along with {@link PagedResponse} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listDistributionPoliciesSinglePageAsync(RequestOptions requestOptions) {
@@ -874,28 +817,14 @@ private Mono> listDistributionPoliciesSinglePageAsync(
/**
* Retrieves existing distribution policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -903,6 +832,7 @@ private Mono> listDistributionPoliciesSinglePageAsync(
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -948,28 +878,14 @@ public PagedFlux listDistributionPoliciesAsync(RequestOptions reques
/**
* Retrieves existing distribution policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -977,6 +893,7 @@ public PagedFlux listDistributionPoliciesAsync(RequestOptions reques
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -1002,28 +919,14 @@ private PagedResponse listDistributionPoliciesSinglePage(RequestOpti
/**
* Retrieves existing distribution policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1031,6 +934,7 @@ private PagedResponse listDistributionPoliciesSinglePage(RequestOpti
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -1114,34 +1018,15 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
/**
* Creates or updates a classification policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1150,19 +1035,20 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1171,12 +1057,15 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1189,8 +1078,7 @@ public Response deleteDistributionPolicyWithResponse(String distributionPo
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful
- * completion of {@link Mono}.
+ * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> upsertClassificationPolicyWithResponseAsync(String classificationPolicyId,
@@ -1204,34 +1092,15 @@ public Mono> upsertClassificationPolicyWithResponseAsync(St
/**
* Creates or updates a classification policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1240,19 +1109,20 @@ public Mono> upsertClassificationPolicyWithResponseAsync(St
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1261,12 +1131,15 @@ public Mono> upsertClassificationPolicyWithResponseAsync(St
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1292,9 +1165,7 @@ public Response upsertClassificationPolicyWithResponse(String classi
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1303,12 +1174,15 @@ public Response upsertClassificationPolicyWithResponse(String classi
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1320,8 +1194,7 @@ public Response upsertClassificationPolicyWithResponse(String classi
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful
- * completion of {@link Mono}.
+ * @return a container for the rules that govern how jobs are classified along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getClassificationPolicyWithResponseAsync(String classificationPolicyId,
@@ -1333,9 +1206,7 @@ public Mono> getClassificationPolicyWithResponseAsync(Strin
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1344,12 +1215,15 @@ public Mono> getClassificationPolicyWithResponseAsync(Strin
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1373,28 +1247,14 @@ public Response getClassificationPolicyWithResponse(String classific
/**
* Retrieves existing classification policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1403,12 +1263,15 @@ public Response getClassificationPolicyWithResponse(String classific
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1419,8 +1282,7 @@ public Response getClassificationPolicyWithResponse(String classific
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return paged collection of ClassificationPolicy items along with {@link PagedResponse} on successful completion
- * of {@link Mono}.
+ * @return paged collection of ClassificationPolicy items along with {@link PagedResponse} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listClassificationPoliciesSinglePageAsync(RequestOptions requestOptions) {
@@ -1434,28 +1296,14 @@ private Mono> listClassificationPoliciesSinglePageAsyn
/**
* Retrieves existing classification policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1464,12 +1312,15 @@ private Mono> listClassificationPoliciesSinglePageAsyn
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1513,28 +1364,14 @@ public PagedFlux listClassificationPoliciesAsync(RequestOptions requ
/**
* Retrieves existing classification policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1543,12 +1380,15 @@ public PagedFlux listClassificationPoliciesAsync(RequestOptions requ
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1572,28 +1412,14 @@ private PagedResponse listClassificationPoliciesSinglePage(RequestOp
/**
* Retrieves existing classification policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1602,12 +1428,15 @@ private PagedResponse listClassificationPoliciesSinglePage(RequestOp
* fallbackQueueId: String (Optional)
* queueSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* prioritizationRule (Optional): {
+ * kind: String(directMap/expression/function/static/webhook) (Required)
* }
* workerSelectorAttachments (Optional): [
* (Optional){
+ * kind: String(conditional/passThrough/ruleEngine/static/weightedAllocation) (Required)
* }
* ]
* }
@@ -1689,34 +1518,15 @@ public Response deleteClassificationPolicyWithResponse(String classificati
/**
* Creates or updates a exception policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1726,9 +1536,11 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -1736,9 +1548,7 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1748,9 +1558,11 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -1766,8 +1578,7 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a policy that defines actions to execute when exception are triggered along with {@link Response} on
- * successful completion of {@link Mono}.
+ * @return a policy that defines actions to execute when exception are triggered along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> upsertExceptionPolicyWithResponseAsync(String exceptionPolicyId,
@@ -1781,34 +1592,15 @@ public Mono> upsertExceptionPolicyWithResponseAsync(String
/**
* Creates or updates a exception policy.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -1818,9 +1610,11 @@ public Mono> upsertExceptionPolicyWithResponseAsync(String
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -1828,9 +1622,7 @@ public Mono> upsertExceptionPolicyWithResponseAsync(String
* ]
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1840,9 +1632,11 @@ public Mono> upsertExceptionPolicyWithResponseAsync(String
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -1871,9 +1665,7 @@ public Response upsertExceptionPolicyWithResponse(String exceptionPo
/**
* Retrieves an existing exception policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1883,9 +1675,11 @@ public Response upsertExceptionPolicyWithResponse(String exceptionPo
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -1900,8 +1694,7 @@ public Response upsertExceptionPolicyWithResponse(String exceptionPo
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a policy that defines actions to execute when exception are triggered along with {@link Response} on
- * successful completion of {@link Mono}.
+ * @return a policy that defines actions to execute when exception are triggered along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getExceptionPolicyWithResponseAsync(String exceptionPolicyId,
@@ -1913,9 +1706,7 @@ public Mono> getExceptionPolicyWithResponseAsync(String exc
/**
* Retrieves an existing exception policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1925,9 +1716,11 @@ public Mono> getExceptionPolicyWithResponseAsync(String exc
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -1954,28 +1747,14 @@ public Response getExceptionPolicyWithResponse(String exceptionPolic
/**
* Retrieves existing exception policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -1985,9 +1764,11 @@ public Response getExceptionPolicyWithResponse(String exceptionPolic
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -2001,8 +1782,7 @@ public Response getExceptionPolicyWithResponse(String exceptionPolic
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return paged collection of ExceptionPolicy items along with {@link PagedResponse} on successful completion of
- * {@link Mono}.
+ * @return paged collection of ExceptionPolicy items along with {@link PagedResponse} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listExceptionPoliciesSinglePageAsync(RequestOptions requestOptions) {
@@ -2016,28 +1796,14 @@ private Mono> listExceptionPoliciesSinglePageAsync(Req
/**
* Retrieves existing exception policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2047,9 +1813,11 @@ private Mono> listExceptionPoliciesSinglePageAsync(Req
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -2096,28 +1864,14 @@ public PagedFlux listExceptionPoliciesAsync(RequestOptions requestOp
/**
* Retrieves existing exception policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2127,9 +1881,11 @@ public PagedFlux listExceptionPoliciesAsync(RequestOptions requestOp
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -2156,28 +1912,14 @@ private PagedResponse listExceptionPoliciesSinglePage(RequestOptions
/**
* Retrieves existing exception policies.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2187,9 +1929,11 @@ private PagedResponse listExceptionPoliciesSinglePage(RequestOptions
* (Optional){
* id: String (Required)
* trigger (Required): {
+ * kind: String(queueLength/waitTime) (Required)
* }
* actions (Required): [
* (Required){
+ * kind: String(cancel/manualReclassify/reclassify) (Required)
* id: String (Optional)
* }
* ]
@@ -2273,34 +2017,15 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
/**
* Creates or updates a queue.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -2313,9 +2038,7 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2336,8 +2059,7 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of
- * {@link Mono}.
+ * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> upsertQueueWithResponseAsync(String queueId, BinaryData resource,
@@ -2350,34 +2072,15 @@ public Mono> upsertQueueWithResponseAsync(String queueId, B
/**
* Creates or updates a queue.
- *
- * Header Parameters
- *
+ * Header Parameters
*
- * Header Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * If-Match
- * String
- * No
- * The request should only proceed if an entity matches this string.
- *
- *
- * If-Unmodified-Since
- * OffsetDateTime
- * No
- * The request should only proceed if the entity was not modified after this time.
- *
+ * Header Parameters
+ * Name Type Required Description If-Match String No The request should only proceed if an entity matches this string. If-Unmodified-Since OffsetDateTime No The request should only proceed if the entity was not modified after this time.
* You can add these to a request with {@link RequestOptions#addHeader}
- *
- * Request Body Schema
- *
+ * Request Body Schema
* {@code
* {
* etag: String (Required)
@@ -2390,9 +2093,7 @@ public Mono> upsertQueueWithResponseAsync(String queueId, B
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2426,9 +2127,7 @@ public Response upsertQueueWithResponse(String queueId, BinaryData r
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2448,8 +2147,7 @@ public Response upsertQueueWithResponse(String queueId, BinaryData r
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of
- * {@link Mono}.
+ * @return a queue that can contain jobs to be routed along with {@link Response} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getQueueWithResponseAsync(String queueId, RequestOptions requestOptions) {
@@ -2460,9 +2158,7 @@ public Mono> getQueueWithResponseAsync(String queueId, Requ
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2493,28 +2189,14 @@ public Response getQueueWithResponse(String queueId, RequestOptions
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2533,8 +2215,7 @@ public Response getQueueWithResponse(String queueId, RequestOptions
* @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
* @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
* @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
- * @return paged collection of RouterQueue items along with {@link PagedResponse} on successful completion of
- * {@link Mono}.
+ * @return paged collection of RouterQueue items along with {@link PagedResponse} on successful completion of {@link Mono}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono> listQueuesSinglePageAsync(RequestOptions requestOptions) {
@@ -2548,28 +2229,14 @@ private Mono> listQueuesSinglePageAsync(RequestOptions
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * Query Parameters
+ * Name Type Required Description maxpagesize Integer No Number of objects to return per page.
* You can add these to a request with {@link RequestOptions#addQueryParam}
- *
- * Response Body Schema
- *
+ * Response Body Schema
* {@code
* {
* etag: String (Required)
@@ -2621,28 +2288,14 @@ public PagedFlux listQueuesAsync(RequestOptions requestOptions) {
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
- * Query Parameters
- *
- *