Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions sdk/iothub/azure-resourcemanager-iothub/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
# Release History

## 1.0.0-beta.1 (2021-10-25)

- Azure Resource Manager IotHub client library for Java. This package contains Microsoft Azure SDK for IotHub Management SDK. Use this API to manage the IoT hubs in your Azure subscription. Package tag package-2021-07. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).

## 1.1.0 (2021-08-30)

- Add support for new service API version 2021-07-01
Expand Down
1,171 changes: 1,113 additions & 58 deletions sdk/iothub/azure-resourcemanager-iothub/SAMPLE.md

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ public IotHubManager authenticate(TokenCredential credential, AzureProfile profi
.append("-")
.append("com.azure.resourcemanager.iothub")
.append("/")
.append("1.1.0");
.append("1.0.0-beta.1");
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder
.append(" (")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ Response<IotHubDescriptionInner> getByResourceGroupWithResponse(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCreateOrUpdate(
String resourceGroupName, String resourceName, IotHubDescriptionInner iotHubDescription, String ifMatch);

Expand All @@ -101,7 +101,7 @@ SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCrea
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCreateOrUpdate(
String resourceGroupName,
String resourceName,
Expand Down Expand Up @@ -186,7 +186,7 @@ IotHubDescriptionInner createOrUpdate(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpdate(
String resourceGroupName, String resourceName, TagsResource iotHubTags);

Expand All @@ -202,7 +202,7 @@ SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpda
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpdate(
String resourceGroupName, String resourceName, TagsResource iotHubTags, Context context);

Expand Down Expand Up @@ -247,7 +247,7 @@ IotHubDescriptionInner update(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDelete(
String resourceGroupName, String resourceName);

Expand All @@ -263,7 +263,7 @@ SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDele
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDelete(
String resourceGroupName, String resourceName, Context context);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public interface IotHubsClient {
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<Void>, Void> beginManualFailover(
String iotHubName, String resourceGroupName, FailoverInput failoverInput);

Expand All @@ -46,7 +46,7 @@ SyncPoller<PollResult<Void>, Void> beginManualFailover(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<Void>, Void> beginManualFailover(
String iotHubName, String resourceGroupName, FailoverInput failoverInput, Context context);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ Response<PrivateEndpointConnectionInner> getWithResponse(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the private endpoint connection of an IotHub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<PrivateEndpointConnectionInner>, PrivateEndpointConnectionInner> beginUpdate(
String resourceGroupName,
String resourceName,
Expand All @@ -112,7 +112,7 @@ SyncPoller<PollResult<PrivateEndpointConnectionInner>, PrivateEndpointConnection
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the private endpoint connection of an IotHub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<PrivateEndpointConnectionInner>, PrivateEndpointConnectionInner> beginUpdate(
String resourceGroupName,
String resourceName,
Expand Down Expand Up @@ -174,7 +174,7 @@ PrivateEndpointConnectionInner update(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the private endpoint connection of an IotHub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<PrivateEndpointConnectionInner>, PrivateEndpointConnectionInner> beginDelete(
String resourceGroupName, String resourceName, String privateEndpointConnectionName);

Expand All @@ -191,7 +191,7 @@ SyncPoller<PollResult<PrivateEndpointConnectionInner>, PrivateEndpointConnection
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the private endpoint connection of an IotHub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
SyncPoller<PollResult<PrivateEndpointConnectionInner>, PrivateEndpointConnectionInner> beginDelete(
String resourceGroupName, String resourceName, String privateEndpointConnectionName, Context context);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
import com.azure.core.management.ProxyResource;
import com.azure.core.util.logging.ClientLogger;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Map;

Expand All @@ -20,6 +21,7 @@ public final class EventHubConsumerGroupInfoInner extends ProxyResource {
* The tags.
*/
@JsonProperty(value = "properties")
@JsonInclude(value = JsonInclude.Include.NON_NULL, content = JsonInclude.Include.ALWAYS)
private Map<String, Object> properties;

/*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -817,7 +817,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCreateOrUpdateAsync(
String resourceGroupName, String resourceName, IotHubDescriptionInner iotHubDescription, String ifMatch) {
Mono<Response<Flux<ByteBuffer>>> mono =
Expand Down Expand Up @@ -849,7 +849,7 @@ private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> b
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCreateOrUpdateAsync(
String resourceGroupName,
String resourceName,
Expand Down Expand Up @@ -885,7 +885,7 @@ private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> b
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCreateOrUpdate(
String resourceGroupName, String resourceName, IotHubDescriptionInner iotHubDescription, String ifMatch) {
return beginCreateOrUpdateAsync(resourceGroupName, resourceName, iotHubDescription, ifMatch).getSyncPoller();
Expand All @@ -908,7 +908,7 @@ public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> be
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginCreateOrUpdate(
String resourceGroupName,
String resourceName,
Expand Down Expand Up @@ -1184,7 +1184,7 @@ private Mono<Response<Flux<ByteBuffer>>> updateWithResponseAsync(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpdateAsync(
String resourceGroupName, String resourceName, TagsResource iotHubTags) {
Mono<Response<Flux<ByteBuffer>>> mono = updateWithResponseAsync(resourceGroupName, resourceName, iotHubTags);
Expand All @@ -1210,7 +1210,7 @@ private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> b
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpdateAsync(
String resourceGroupName, String resourceName, TagsResource iotHubTags, Context context) {
context = this.client.mergeContext(context);
Expand All @@ -1237,7 +1237,7 @@ private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> b
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpdate(
String resourceGroupName, String resourceName, TagsResource iotHubTags) {
return beginUpdateAsync(resourceGroupName, resourceName, iotHubTags).getSyncPoller();
Expand All @@ -1255,7 +1255,7 @@ public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> be
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginUpdate(
String resourceGroupName, String resourceName, TagsResource iotHubTags, Context context) {
return beginUpdateAsync(resourceGroupName, resourceName, iotHubTags, context).getSyncPoller();
Expand Down Expand Up @@ -1437,7 +1437,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDeleteAsync(
String resourceGroupName, String resourceName) {
Mono<Response<Flux<ByteBuffer>>> mono = deleteWithResponseAsync(resourceGroupName, resourceName);
Expand All @@ -1462,7 +1462,7 @@ private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> b
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDeleteAsync(
String resourceGroupName, String resourceName, Context context) {
context = this.client.mergeContext(context);
Expand All @@ -1487,7 +1487,7 @@ private PollerFlux<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> b
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDelete(
String resourceGroupName, String resourceName) {
return beginDeleteAsync(resourceGroupName, resourceName).getSyncPoller();
Expand All @@ -1504,7 +1504,7 @@ public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> be
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the description of the IoT hub.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<IotHubDescriptionInner>, IotHubDescriptionInner> beginDelete(
String resourceGroupName, String resourceName, Context context) {
return beginDeleteAsync(resourceGroupName, resourceName, context).getSyncPoller();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -201,7 +201,7 @@ private Mono<Response<Flux<ByteBuffer>>> manualFailoverWithResponseAsync(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<Void>, Void> beginManualFailoverAsync(
String iotHubName, String resourceGroupName, FailoverInput failoverInput) {
Mono<Response<Flux<ByteBuffer>>> mono =
Expand All @@ -225,7 +225,7 @@ private PollerFlux<PollResult<Void>, Void> beginManualFailoverAsync(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
private PollerFlux<PollResult<Void>, Void> beginManualFailoverAsync(
String iotHubName, String resourceGroupName, FailoverInput failoverInput, Context context) {
context = this.client.mergeContext(context);
Expand All @@ -249,7 +249,7 @@ private PollerFlux<PollResult<Void>, Void> beginManualFailoverAsync(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<Void>, Void> beginManualFailover(
String iotHubName, String resourceGroupName, FailoverInput failoverInput) {
return beginManualFailoverAsync(iotHubName, resourceGroupName, failoverInput).getSyncPoller();
Expand All @@ -269,7 +269,7 @@ public SyncPoller<PollResult<Void>, Void> beginManualFailover(
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
@ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
public SyncPoller<PollResult<Void>, Void> beginManualFailover(
String iotHubName, String resourceGroupName, FailoverInput failoverInput, Context context) {
return beginManualFailoverAsync(iotHubName, resourceGroupName, failoverInput, context).getSyncPoller();
Expand Down
Loading