Skip to content

Commit

Permalink
Reset changes to the patch version.
Browse files Browse the repository at this point in the history
  • Loading branch information
ibrahimrabab committed Jun 6, 2024
1 parent e653b15 commit 48e7aa2
Show file tree
Hide file tree
Showing 6 changed files with 40 additions and 43 deletions.
10 changes: 0 additions & 10 deletions sdk/storage/azure-storage-queue/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,15 +1,5 @@
# Release History

## 12.22.0-beta.1 (Unreleased)

### Features Added

### Breaking Changes

### Bugs Fixed

### Other Changes

## 12.21.0 (2024-05-15)

### Features Added
Expand Down
20 changes: 10 additions & 10 deletions sdk/storage/azure-storage-queue/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@

<groupId>com.azure</groupId>
<artifactId>azure-storage-queue</artifactId>
<version>12.22.0-beta.1</version> <!-- {x-version-update;com.azure:azure-storage-queue;current} -->
<version>12.21.0</version> <!-- {x-version-update;com.azure:azure-storage-queue;current} -->

<name>Microsoft Azure client library for Queue Storage</name>
<description>This module contains client library for Microsoft Azure Queue Storage.</description>
Expand Down Expand Up @@ -66,31 +66,31 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core</artifactId>
<version>1.49.1</version> <!-- {x-version-update;com.azure:azure-core;dependency} -->
<version>1.49.0</version> <!-- {x-version-update;com.azure:azure-core;dependency} -->
</dependency>
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core-http-netty</artifactId>
<version>1.15.1</version> <!-- {x-version-update;com.azure:azure-core-http-netty;dependency} -->
<version>1.15.0</version> <!-- {x-version-update;com.azure:azure-core-http-netty;dependency} -->
</dependency>
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-storage-common</artifactId>
<version>12.25.1</version> <!-- {x-version-update;com.azure:azure-storage-common;current} -->
<version>12.25.0</version> <!-- {x-version-update;com.azure:azure-storage-common;current} -->
</dependency>

<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-storage-common</artifactId>
<version>12.25.1</version> <!-- {x-version-update;com.azure:azure-storage-common;current} -->
<version>12.25.0</version> <!-- {x-version-update;com.azure:azure-storage-common;current} -->
<classifier>tests</classifier>
<type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core-test</artifactId>
<version>1.26.0</version> <!-- {x-version-update;com.azure:azure-core-test;dependency} -->
<version>1.25.0</version> <!-- {x-version-update;com.azure:azure-core-test;dependency} -->
<scope>test</scope>
</dependency>
<dependency>
Expand All @@ -114,7 +114,7 @@
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-test</artifactId>
<version>3.4.38</version> <!-- {x-version-update;io.projectreactor:reactor-test;external_dependency} -->
<version>3.4.36</version> <!-- {x-version-update;io.projectreactor:reactor-test;external_dependency} -->
<scope>test</scope>
</dependency>
<dependency>
Expand All @@ -126,13 +126,13 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core-http-okhttp</artifactId>
<version>1.12.0</version> <!-- {x-version-update;com.azure:azure-core-http-okhttp;dependency} -->
<version>1.11.21</version> <!-- {x-version-update;com.azure:azure-core-http-okhttp;dependency} -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core-http-vertx</artifactId>
<version>1.0.0-beta.19</version> <!-- {x-version-update;com.azure:azure-core-http-vertx;dependency} -->
<version>1.0.0-beta.18</version> <!-- {x-version-update;com.azure:azure-core-http-vertx;dependency} -->
<scope>test</scope>
</dependency>
</dependencies>
Expand Down Expand Up @@ -187,7 +187,7 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core-http-jdk-httpclient</artifactId>
<version>1.0.0-beta.14</version> <!-- {x-version-update;com.azure:azure-core-http-jdk-httpclient;dependency} -->
<version>1.0.0-beta.13</version> <!-- {x-version-update;com.azure:azure-core-http-jdk-httpclient;dependency} -->
<scope>test</scope>
</dependency>
</dependencies>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -225,7 +225,8 @@ public Mono<Response<Void>> createWithResponse(Map<String, String> metadata) {

Mono<Response<Void>> createWithResponse(Map<String, String> metadata, Context context) {
context = context == null ? Context.NONE : context;
return client.getQueues().createNoCustomHeadersWithResponseAsync(queueName, null, metadata, null, context);
return client.getQueues().createWithResponseAsync(queueName, null, metadata, null, context)
.map(response -> new SimpleResponse<>(response, null));
}

/**
Expand Down Expand Up @@ -361,7 +362,8 @@ public Mono<Response<Void>> deleteWithResponse() {

Mono<Response<Void>> deleteWithResponse(Context context) {
context = context == null ? Context.NONE : context;
return client.getQueues().deleteNoCustomHeadersWithResponseAsync(queueName, null, null, context);
return client.getQueues().deleteWithResponseAsync(queueName, null, null, context)
.map(response -> new SimpleResponse<>(response, null));
}

/**
Expand Down Expand Up @@ -577,7 +579,8 @@ public Mono<Void> setMetadata(Map<String, String> metadata) {
public Mono<Response<Void>> setMetadataWithResponse(Map<String, String> metadata) {
try {
return withContext(context -> client.getQueues()
.setMetadataNoCustomHeadersWithResponseAsync(queueName, null, metadata, null, context));
.setMetadataWithResponseAsync(queueName, null, metadata, null, context)
.map(response -> new SimpleResponse<>(response, null)));
} catch (RuntimeException ex) {
return monoError(LOGGER, ex);
}
Expand Down Expand Up @@ -711,7 +714,8 @@ Mono<Response<Void>> setAccessPolicyWithResponse(Iterable<QueueSignedIdentifier>
.collect(Collectors.toList());

return client.getQueues()
.setAccessPolicyNoCustomHeadersWithResponseAsync(queueName, null, null, permissionsList, context);
.setAccessPolicyWithResponseAsync(queueName, null, null, permissionsList, context)
.map(response -> new SimpleResponse<>(response, null));
}

/**
Expand Down Expand Up @@ -763,8 +767,8 @@ public Mono<Void> clearMessages() {
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Void>> clearMessagesWithResponse() {
try {
return withContext(context -> client.getMessages()
.clearNoCustomHeadersWithResponseAsync(queueName, null, null, context));
return withContext(context -> client.getMessages().clearWithResponseAsync(queueName, null, null, context)
.map(response -> new SimpleResponse<>(response, null)));
} catch (RuntimeException ex) {
return monoError(LOGGER, ex);
}
Expand Down Expand Up @@ -1395,8 +1399,9 @@ public Mono<Void> deleteMessage(String messageId, String popReceipt) {
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Void>> deleteMessageWithResponse(String messageId, String popReceipt) {
try {
return withContext(context -> client.getMessageIds()
.deleteNoCustomHeadersWithResponseAsync(queueName, messageId, popReceipt, null, null, context));
return withContext(context -> client.getMessageIds().deleteWithResponseAsync(queueName, messageId,
popReceipt, null, null, context)
.map(response -> new SimpleResponse<>(response, null)));
} catch (RuntimeException ex) {
return monoError(LOGGER, ex);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -213,8 +213,8 @@ public void create() {
public Response<Void> createWithResponse(Map<String, String> metadata, Duration timeout, Context context) {
Context finalContext = context == null ? Context.NONE : context;
try {
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getQueues()
.createNoCustomHeadersWithResponse(queueName, null, metadata, null, finalContext);
Supplier<Response<Void>> operation = () ->
this.azureQueueStorage.getQueues().createWithResponse(queueName, null, metadata, null, finalContext);

return submitThreadPool(operation, LOGGER, timeout);
} catch (RuntimeException e) {
Expand Down Expand Up @@ -281,8 +281,8 @@ public Response<Boolean> createIfNotExistsWithResponse(Map<String, String> metad
Context context) {
Context finalContext = context == null ? Context.NONE : context;
try {
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getQueues()
.createNoCustomHeadersWithResponse(queueName, null, metadata, null, finalContext);
Supplier<Response<Void>> operation = () ->
this.azureQueueStorage.getQueues().createWithResponse(queueName, null, metadata, null, finalContext);
Response<Void> response = submitThreadPool(operation, LOGGER, timeout);
return new SimpleResponse<>(response, true);
} catch (QueueStorageException e) {
Expand Down Expand Up @@ -346,8 +346,8 @@ public void delete() {
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<Void> deleteWithResponse(Duration timeout, Context context) {
Context finalContext = context == null ? Context.NONE : context;
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getQueues()
.deleteNoCustomHeadersWithResponse(queueName, null, null, finalContext);
Supplier<Response<Void>> operation = () ->
this.azureQueueStorage.getQueues().deleteWithResponse(queueName, null, null, finalContext);
return submitThreadPool(operation, LOGGER, timeout);
}

Expand Down Expand Up @@ -406,11 +406,12 @@ public boolean deleteIfExists() {
public Response<Boolean> deleteIfExistsWithResponse(Duration timeout, Context context) {
Context finalContext = context == null ? Context.NONE : context;
try {
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getQueues()
.deleteNoCustomHeadersWithResponse(queueName, null, null, finalContext);
Supplier<Response<Void>> operation = () ->
this.azureQueueStorage.getQueues().deleteWithResponse(queueName, null, null, finalContext);

Response<Void> response = submitThreadPool(operation, LOGGER, timeout);
return new SimpleResponse<>(response, true);

} catch (QueueStorageException e) {
if (e.getStatusCode() == 404) {
HttpResponse res = e.getResponse();
Expand Down Expand Up @@ -563,7 +564,7 @@ public void setMetadata(Map<String, String> metadata) {
public Response<Void> setMetadataWithResponse(Map<String, String> metadata, Duration timeout, Context context) {
Context finalContext = context == null ? Context.NONE : context;
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getQueues()
.setMetadataNoCustomHeadersWithResponse(queueName, null, metadata, null, finalContext);
.setMetadataWithResponse(queueName, null, metadata, null, finalContext);

return submitThreadPool(operation, LOGGER, timeout);
}
Expand Down Expand Up @@ -668,7 +669,7 @@ public Response<Void> setAccessPolicyWithResponse(List<QueueSignedIdentifier> pe
Context context) {
Context finalContext = context == null ? Context.NONE : context;
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getQueues()
.setAccessPolicyNoCustomHeadersWithResponse(queueName, null, null, permissions, finalContext);
.setAccessPolicyWithResponse(queueName, null, null, permissions, finalContext);

return submitThreadPool(operation, LOGGER, timeout);
}
Expand Down Expand Up @@ -725,7 +726,7 @@ public void clearMessages() {
public Response<Void> clearMessagesWithResponse(Duration timeout, Context context) {
Context finalContext = context == null ? Context.NONE : context;
Supplier<Response<Void>> operation = () ->
this.azureQueueStorage.getMessages().clearNoCustomHeadersWithResponse(queueName, null, null, finalContext);
this.azureQueueStorage.getMessages().clearWithResponse(queueName, null, null, finalContext);

return submitThreadPool(operation, LOGGER, timeout);
}
Expand Down Expand Up @@ -1350,7 +1351,7 @@ public Response<Void> deleteMessageWithResponse(String messageId, String popRece
Context context) {
Context finalContext = context == null ? Context.NONE : context;
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getMessageIds()
.deleteNoCustomHeadersWithResponse(queueName, messageId, popReceipt, null, null, finalContext);
.deleteWithResponse(queueName, messageId, popReceipt, null, null, finalContext);

return submitThreadPool(operation, LOGGER, timeout);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -539,7 +539,8 @@ public Mono<Response<Void>> setPropertiesWithResponse(QueueServiceProperties pro

Mono<Response<Void>> setPropertiesWithResponse(QueueServiceProperties properties, Context context) {
context = context == null ? Context.NONE : context;
return client.getServices().setPropertiesNoCustomHeadersWithResponseAsync(properties, null, null, context);
return client.getServices().setPropertiesWithResponseAsync(properties, null, null, context)
.map(response -> new SimpleResponse<>(response, null));
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -526,8 +526,8 @@ public void setProperties(QueueServiceProperties properties) {
public Response<Void> setPropertiesWithResponse(QueueServiceProperties properties, Duration timeout,
Context context) {
Context finalContext = context == null ? Context.NONE : context;
Supplier<Response<Void>> operation = () -> this.azureQueueStorage.getServices()
.setPropertiesNoCustomHeadersWithResponse(properties, null, null, finalContext);
Supplier<Response<Void>> operation = () ->
this.azureQueueStorage.getServices().setPropertiesWithResponse(properties, null, null, finalContext);

return submitThreadPool(operation, LOGGER, timeout);
}
Expand Down

0 comments on commit 48e7aa2

Please sign in to comment.