- * 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 +84,16 @@ 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 +101,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)
@@ -137,8 +123,7 @@ public final class JobRouterAdministrationAsyncClient {
@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 +319,8 @@ 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 +328,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)
@@ -369,28 +354,15 @@ 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.
- *
+ * 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 +370,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 +411,18 @@ 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.
- *
+ * 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 +431,22 @@ 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 +455,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)
* }
* ]
* }
@@ -520,8 +483,7 @@ public Mono> deleteDistributionPolicyWithResponse(String distribu
@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 +702,8 @@ public Mono updateClassificationPolicy(String classificationPolicyId
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -751,12 +712,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)
* }
* ]
* }
@@ -780,28 +744,15 @@ 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.
- *
+ * 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 +761,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 +808,18 @@ 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.
- *
+ * 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 +829,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 +841,9 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
* ]
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -913,9 +853,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)
* }
* ]
@@ -938,8 +880,7 @@ public Mono> deleteClassificationPolicyWithResponse(String classi
@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);
}
@@ -1150,6 +1091,7 @@ public Mono createExceptionPolicy(CreateExceptionPolicyOptions
*
* Response Body Schema
*
+ *
* {@code
* {
* etag: String (Required)
@@ -1209,6 +1151,7 @@ public Mono> getExceptionPolicyWithResponse(String exceptio
*
* Response Body Schema
*
+ *
* {@code
* {
* etag: String (Required)
@@ -1261,34 +1204,18 @@ 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.
- *
+ * 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 +1228,9 @@ public Mono> deleteExceptionPolicyWithResponse(String exceptionPo
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1331,8 +1258,7 @@ public Mono> deleteExceptionPolicyWithResponse(String exceptionPo
@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 +1448,8 @@ public Mono createQueue(CreateQueueOptions createQueueOptions) {
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1555,28 +1480,15 @@ 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.
- *
+ * 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 +1568,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 +1637,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 +1708,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 +1777,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..5b1b43731ebc 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,18 @@ 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.
- *
+ * 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 +78,16 @@ 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 +95,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 +116,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 +311,8 @@ public Response createDistributionPolicyWithResponse(
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -336,6 +320,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 +345,15 @@ 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.
- *
+ * 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 +361,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 +402,18 @@ 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.
- *
+ * 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 +422,22 @@ 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 +446,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 +473,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 +691,8 @@ public Response createClassificationPolicyWithResponse(
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -740,12 +701,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 +732,15 @@ 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.
- *
+ * 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 +749,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 +796,18 @@ 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.
- *
+ * 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 +817,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 +829,9 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* ]
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -901,9 +841,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 +867,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);
}
@@ -1139,6 +1080,7 @@ public ExceptionPolicy createExceptionPolicy(CreateExceptionPolicyOptions create
*
* Response Body Schema
*
+ *
* {@code
* {
* etag: String (Required)
@@ -1197,6 +1139,7 @@ public Response getExceptionPolicyWithResponse(String exceptionPolic
*
* Response Body Schema
*
+ *
* {@code
* {
* etag: String (Required)
@@ -1248,34 +1191,18 @@ 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.
- *
+ * 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 +1215,9 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1316,8 +1243,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 +1429,8 @@ public RouterQueue createQueue(CreateQueueOptions createQueueOptions) {
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1535,28 +1460,15 @@ 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.
- *
+ * 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..8bf59540deaa 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.
@@ -94,7 +94,7 @@ public JobRouterAdministrationClientBuilder() {
@Override
public JobRouterAdministrationClientBuilder pipeline(HttpPipeline pipeline) {
if (this.pipeline != null && pipeline == null) {
- LOGGER.info("HttpPipeline is being set to 'null' when it was previously configured.");
+ LOGGER.atInfo().log("HttpPipeline is being set to 'null' when it was previously configured.");
}
this.pipeline = pipeline;
return this;
@@ -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..8932ec23931d 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,18 @@ 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.
- *
+ * 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 +134,13 @@ 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 +190,7 @@ public final class JobRouterAsyncClient {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -221,8 +207,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 +539,8 @@ public Mono createJob(CreateJobOptions createJobOptions) {
/**
* Retrieves an existing job by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -606,6 +590,7 @@ public Mono createJob(CreateJobOptions createJobOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -646,16 +631,17 @@ public Mono> deleteJobWithResponse(String jobId, RequestOptions r
*
* Request Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -677,16 +663,17 @@ public Mono> reclassifyJobWithResponse(String jobId, Reques
*
* Request Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -704,18 +691,20 @@ public Mono reclassifyJob(String jobId, RequestOptions requestOption
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* dispositionCode: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -737,18 +726,20 @@ public Mono> cancelJobWithResponse(String jobId, RequestOpt
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* dispositionCode: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -763,67 +754,26 @@ 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).
- *
+ * 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 +823,7 @@ public Mono cancelJob(String jobId, RequestOptions requestOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -892,9 +843,8 @@ public PagedFlux listJobs(RequestOptions requestOptions) {
/**
* Gets a job's position details.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* jobId: String (Required)
@@ -921,17 +871,16 @@ 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)
@@ -958,9 +907,8 @@ 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)
@@ -991,17 +939,19 @@ public Mono> acceptJobOfferWithResponse(String workerId, St
*
* Request Body Schema
*
+ *
* {@code
* {
* retryOfferAt: OffsetDateTime (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param workerId Id of a worker.
@@ -1025,17 +975,19 @@ public Mono> declineJobOfferWithResponse(String workerId, S
*
* Request Body Schema
*
+ *
* {@code
* {
* retryOfferAt: OffsetDateTime (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param workerId Id of a worker.
@@ -1052,9 +1004,8 @@ 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 +1033,18 @@ 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.
- *
+ * 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 +1089,9 @@ public Mono> getQueueStatisticsWithResponse(String queueId,
* maxConcurrentOffers: Integer (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1215,8 +1150,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 +1460,8 @@ public Mono createWorker(CreateWorkerOptions createWorkerOptions)
/**
* Retrieves an existing worker by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1607,54 +1540,24 @@ 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.
- *
+ * 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 +1721,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 +1750,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));
@@ -2040,11 +1947,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 +1976,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));
@@ -2109,17 +2020,19 @@ public Mono unassignJob(String jobId, String assignmentId, Un
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -2143,17 +2056,19 @@ public Mono> completeJobWithResponse(String jobId, String a
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -2173,6 +2088,7 @@ public Mono completeJob(String jobId, String assignmentId, RequestOp
*
* Request Body Schema
*
+ *
* {@code
* {
* dispositionCode: String (Optional)
@@ -2180,12 +2096,13 @@ public Mono completeJob(String jobId, String assignmentId, RequestOp
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -2208,6 +2125,7 @@ public Mono> closeJobWithResponse(String jobId, String assi
*
* Request Body Schema
*
+ *
* {@code
* {
* dispositionCode: String (Optional)
@@ -2215,12 +2133,13 @@ public Mono> closeJobWithResponse(String jobId, String assi
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
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..fdbc7fa0c1bf 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,18 @@ 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.
- *
+ * 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 +128,13 @@ 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 +184,7 @@ public final class JobRouterClient {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -215,8 +201,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 +541,8 @@ public RouterJob createJob(CreateJobOptions createJobOptions) {
/**
* Retrieves an existing job by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -608,6 +592,7 @@ public RouterJob createJob(CreateJobOptions createJobOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -648,16 +633,17 @@ public Response deleteJobWithResponse(String jobId, RequestOptions request
*
* Request Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -678,16 +664,17 @@ public Response reclassifyJobWithResponse(String jobId, RequestOptio
*
* Request Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -708,18 +695,20 @@ public BinaryData reclassifyJob(String jobId, RequestOptions requestOptions) {
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* dispositionCode: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -740,18 +729,20 @@ public Response cancelJobWithResponse(String jobId, RequestOptions r
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* dispositionCode: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -769,67 +760,26 @@ 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).
- *
+ * 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 +829,7 @@ public BinaryData cancelJob(String jobId, RequestOptions requestOptions) {
* ]
* scheduledAt: OffsetDateTime (Optional)
* matchingMode (Optional): {
+ * kind: String(queueAndMatch/scheduleAndSuspend/suspend) (Required)
* }
* }
* }
@@ -898,9 +849,8 @@ public PagedIterable listJobs(RequestOptions requestOptions) {
/**
* Gets a job's position details.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* jobId: String (Required)
@@ -927,17 +877,16 @@ 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 +912,8 @@ 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)
@@ -996,17 +944,19 @@ public Response acceptJobOfferWithResponse(String workerId, String o
*
* Request Body Schema
*
+ *
* {@code
* {
* retryOfferAt: OffsetDateTime (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param workerId Id of a worker.
@@ -1029,17 +979,19 @@ public Response declineJobOfferWithResponse(String workerId, String
*
* Request Body Schema
*
+ *
* {@code
* {
* retryOfferAt: OffsetDateTime (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param workerId Id of a worker.
@@ -1058,9 +1010,8 @@ 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 +1039,18 @@ 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.
- *
+ * 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 +1095,9 @@ public Response getQueueStatisticsWithResponse(String queueId, Reque
* maxConcurrentOffers: Integer (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1220,8 +1155,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 +1469,8 @@ public RouterWorker createWorker(CreateWorkerOptions createWorkerOptions) {
/**
* Retrieves an existing worker by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1616,54 +1549,24 @@ 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.
- *
+ * 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)
@@ -2072,17 +1975,19 @@ public UnassignJobResult unassignJob(String jobId, String assignmentId, Unassign
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -2105,17 +2010,19 @@ public Response completeJobWithResponse(String jobId, String assignm
*
* Request Body Schema
*
+ *
* {@code
* {
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -2137,6 +2044,7 @@ public BinaryData completeJob(String jobId, String assignmentId, RequestOptions
*
* Request Body Schema
*
+ *
* {@code
* {
* dispositionCode: String (Optional)
@@ -2144,12 +2052,13 @@ public BinaryData completeJob(String jobId, String assignmentId, RequestOptions
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
@@ -2171,6 +2080,7 @@ public Response closeJobWithResponse(String jobId, String assignment
*
* Request Body Schema
*
+ *
* {@code
* {
* dispositionCode: String (Optional)
@@ -2178,12 +2088,13 @@ public Response closeJobWithResponse(String jobId, String assignment
* note: String (Optional)
* }
* }
+ *
*
* Response Body Schema
*
+ *
* {@code
- * {
- * }
+ * { }
* }
*
* @param jobId Id of a job.
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..fa869143918b 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.
@@ -92,7 +92,7 @@ public JobRouterClientBuilder() {
@Override
public JobRouterClientBuilder pipeline(HttpPipeline pipeline) {
if (this.pipeline != null && pipeline == null) {
- LOGGER.info("HttpPipeline is being set to 'null' when it was previously configured.");
+ LOGGER.atInfo().log("HttpPipeline is being set to 'null' when it was previously configured.");
}
this.pipeline = pipeline;
return this;
@@ -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..d08757099075 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
@@ -589,34 +589,18 @@ 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.
- *
+ * 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 +608,16 @@ 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 +625,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)
@@ -669,34 +655,18 @@ 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.
- *
+ * 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 +674,16 @@ 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 +691,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 +719,8 @@ public Response upsertDistributionPolicyWithResponse(String distribu
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -757,6 +728,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)
@@ -783,9 +755,8 @@ public Mono> getDistributionPolicyWithResponseAsync(String
/**
* Retrieves an existing distribution policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -793,6 +764,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 +790,15 @@ 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.
- *
+ * 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 +806,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)
@@ -874,28 +834,15 @@ 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.
- *
+ * 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 +850,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 +896,15 @@ 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.
- *
+ * 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 +912,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 +938,15 @@ 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.
- *
+ * 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 +954,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 +1038,18 @@ 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.
- *
+ * 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 +1058,22 @@ 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 +1082,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)
* }
* ]
* }
@@ -1204,34 +1118,18 @@ 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.
- *
+ * 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 +1138,22 @@ 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 +1162,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 +1196,8 @@ public Response upsertClassificationPolicyWithResponse(String classi
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1303,12 +1206,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)
* }
* ]
* }
@@ -1333,9 +1239,8 @@ public Mono> getClassificationPolicyWithResponseAsync(Strin
/**
* Retrieves an existing classification policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1344,12 +1249,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 +1281,15 @@ 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.
- *
+ * 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 +1298,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)
* }
* ]
* }
@@ -1434,28 +1332,15 @@ 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.
- *
+ * 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 +1349,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 +1401,15 @@ 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.
- *
+ * 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 +1418,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 +1450,15 @@ 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.
- *
+ * 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 +1467,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 +1557,18 @@ 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.
- *
+ * 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 +1578,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 +1590,9 @@ public Response deleteClassificationPolicyWithResponse(String classificati
* ]
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1748,9 +1602,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)
* }
* ]
@@ -1781,34 +1637,18 @@ 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.
- *
+ * 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 +1658,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 +1670,9 @@ public Mono> upsertExceptionPolicyWithResponseAsync(String
* ]
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1840,9 +1682,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 +1715,8 @@ public Response upsertExceptionPolicyWithResponse(String exceptionPo
/**
* Retrieves an existing exception policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1883,9 +1726,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)
* }
* ]
@@ -1913,9 +1758,8 @@ public Mono> getExceptionPolicyWithResponseAsync(String exc
/**
* Retrieves an existing exception policy by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -1925,9 +1769,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 +1800,15 @@ 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.
- *
+ * 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 +1818,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)
* }
* ]
@@ -2016,28 +1851,15 @@ 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.
- *
+ * 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 +1869,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 +1920,15 @@ 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.
- *
+ * 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 +1938,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 +1969,15 @@ 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.
- *
+ * 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 +1987,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 +2075,18 @@ 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.
- *
+ * 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 +2099,9 @@ public Response deleteExceptionPolicyWithResponse(String exceptionPolicyId
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -2350,34 +2136,18 @@ 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.
- *
+ * 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 +2160,9 @@ public Mono> upsertQueueWithResponseAsync(String queueId, B
* exceptionPolicyId: String (Optional)
* }
* }
- *
- * Response Body Schema
- *
+ *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -2426,9 +2196,8 @@ public Response upsertQueueWithResponse(String queueId, BinaryData r
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -2460,9 +2229,8 @@ public Mono> getQueueWithResponseAsync(String queueId, Requ
/**
* Retrieves an existing queue by Id.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -2493,28 +2261,15 @@ 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.
- *
+ * 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)
@@ -2548,28 +2303,15 @@ 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.
- *
+ * 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 +2363,15 @@ public PagedFlux listQueuesAsync(RequestOptions requestOptions) {
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
* Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * 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)
@@ -2674,28 +2403,15 @@ private PagedResponse listQueuesSinglePage(RequestOptions requestOpt
/**
* Retrieves existing queues.
- *
- * Query Parameters
- *
+ * Query Parameters
*
* Query Parameters
- *
- * Name
- * Type
- * Required
- * Description
- *
- *
- * maxpagesize
- * Integer
- * No
- * Number of objects to return per page.
- *
+ * 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)
@@ -2785,9 +2501,8 @@ public Response deleteQueueWithResponse(String queueId, RequestOptions req
* Retrieves existing distribution policies.
*
* Get the next page of items.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -2795,6 +2510,7 @@ public Response deleteQueueWithResponse(String queueId, RequestOptions req
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -2828,9 +2544,8 @@ private Mono> listDistributionPoliciesNextSinglePageAs
* Retrieves existing distribution policies.
*
* Get the next page of items.
- *
- * Response Body Schema
- *
+ * Response Body Schema
+ *
* {@code
* {
* etag: String (Required)
@@ -2838,6 +2553,7 @@ private Mono> listDistributionPoliciesNextSinglePageAs
* name: String (Optional)
* offerExpiresAfterSeconds: Double (Optional)
* mode (Optional): {
+ * kind: String(bestWorker/longestIdle/roundRobin) (Required)
* minConcurrentOffers: Integer (Optional)
* maxConcurrentOffers: Integer (Optional)
* bypassSelectors: Boolean (Optional)
@@ -2869,9 +2585,8 @@ private PagedResponse