listTable
* {@code
* try (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
* BaseBigtableTableAdminClient.create()) {
+ * ListTablesRequest request =
+ * ListTablesRequest.newBuilder()
+ * .setParent(InstanceName.of("[PROJECT]", "[INSTANCE]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListTablesResponse response =
* baseBigtableTableAdminClient.listTablesCallable().call(request);
@@ -1853,6 +1859,12 @@ public final ListSnapshotsPagedResponse listSnapshots(ListSnapshotsRequest reque
* {@code
* try (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
* BaseBigtableTableAdminClient.create()) {
+ * ListSnapshotsRequest request =
+ * ListSnapshotsRequest.newBuilder()
+ * .setParent(ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListSnapshotsResponse response =
* baseBigtableTableAdminClient.listSnapshotsCallable().call(request);
@@ -2578,6 +2590,14 @@ public final ListBackupsPagedResponse listBackups(ListBackupsRequest request) {
* {@code
* try (BaseBigtableTableAdminClient baseBigtableTableAdminClient =
* BaseBigtableTableAdminClient.create()) {
+ * ListBackupsRequest request =
+ * ListBackupsRequest.newBuilder()
+ * .setParent(ClusterName.of("[PROJECT]", "[INSTANCE]", "[CLUSTER]").toString())
+ * .setFilter("filter-1274492040")
+ * .setOrderBy("orderBy-1207110587")
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
* while (true) {
* ListBackupsResponse response =
* baseBigtableTableAdminClient.listBackupsCallable().call(request);
diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableInstanceAdminImpl.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableInstanceAdminImpl.java
index 2bee8b466b..db4a0a1c0b 100644
--- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableInstanceAdminImpl.java
+++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableInstanceAdminImpl.java
@@ -88,7 +88,7 @@ public void reset() {
@Override
public void createInstance(
CreateInstanceRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -100,7 +100,7 @@ public void createInstance(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateInstance, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -108,7 +108,7 @@ public void createInstance(
@Override
public void getInstance(GetInstanceRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Instance) {
requests.add(request);
responseObserver.onNext(((Instance) response));
@@ -120,7 +120,7 @@ public void getInstance(GetInstanceRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetInstance, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Instance.class.getName(),
Exception.class.getName())));
}
@@ -129,7 +129,7 @@ public void getInstance(GetInstanceRequest request, StreamObserver res
@Override
public void listInstances(
ListInstancesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListInstancesResponse) {
requests.add(request);
responseObserver.onNext(((ListInstancesResponse) response));
@@ -141,7 +141,7 @@ public void listInstances(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListInstances, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListInstancesResponse.class.getName(),
Exception.class.getName())));
}
@@ -149,7 +149,7 @@ public void listInstances(
@Override
public void updateInstance(Instance request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Instance) {
requests.add(request);
responseObserver.onNext(((Instance) response));
@@ -161,7 +161,7 @@ public void updateInstance(Instance request, StreamObserver responseOb
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateInstance, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Instance.class.getName(),
Exception.class.getName())));
}
@@ -170,7 +170,7 @@ public void updateInstance(Instance request, StreamObserver responseOb
@Override
public void partialUpdateInstance(
PartialUpdateInstanceRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -182,7 +182,7 @@ public void partialUpdateInstance(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method PartialUpdateInstance, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -191,7 +191,7 @@ public void partialUpdateInstance(
@Override
public void deleteInstance(
DeleteInstanceRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -203,7 +203,7 @@ public void deleteInstance(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteInstance, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -212,7 +212,7 @@ public void deleteInstance(
@Override
public void createCluster(
CreateClusterRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -224,7 +224,7 @@ public void createCluster(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateCluster, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -232,7 +232,7 @@ public void createCluster(
@Override
public void getCluster(GetClusterRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Cluster) {
requests.add(request);
responseObserver.onNext(((Cluster) response));
@@ -244,7 +244,7 @@ public void getCluster(GetClusterRequest request, StreamObserver respon
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetCluster, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Cluster.class.getName(),
Exception.class.getName())));
}
@@ -253,7 +253,7 @@ public void getCluster(GetClusterRequest request, StreamObserver respon
@Override
public void listClusters(
ListClustersRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListClustersResponse) {
requests.add(request);
responseObserver.onNext(((ListClustersResponse) response));
@@ -265,7 +265,7 @@ public void listClusters(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListClusters, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListClustersResponse.class.getName(),
Exception.class.getName())));
}
@@ -273,7 +273,7 @@ public void listClusters(
@Override
public void updateCluster(Cluster request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -285,7 +285,7 @@ public void updateCluster(Cluster request, StreamObserver responseObs
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateCluster, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -293,7 +293,7 @@ public void updateCluster(Cluster request, StreamObserver responseObs
@Override
public void deleteCluster(DeleteClusterRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -305,7 +305,7 @@ public void deleteCluster(DeleteClusterRequest request, StreamObserver re
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteCluster, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -314,7 +314,7 @@ public void deleteCluster(DeleteClusterRequest request, StreamObserver re
@Override
public void createAppProfile(
CreateAppProfileRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof AppProfile) {
requests.add(request);
responseObserver.onNext(((AppProfile) response));
@@ -326,7 +326,7 @@ public void createAppProfile(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateAppProfile, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
AppProfile.class.getName(),
Exception.class.getName())));
}
@@ -335,7 +335,7 @@ public void createAppProfile(
@Override
public void getAppProfile(
GetAppProfileRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof AppProfile) {
requests.add(request);
responseObserver.onNext(((AppProfile) response));
@@ -347,7 +347,7 @@ public void getAppProfile(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetAppProfile, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
AppProfile.class.getName(),
Exception.class.getName())));
}
@@ -356,7 +356,7 @@ public void getAppProfile(
@Override
public void listAppProfiles(
ListAppProfilesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListAppProfilesResponse) {
requests.add(request);
responseObserver.onNext(((ListAppProfilesResponse) response));
@@ -368,7 +368,7 @@ public void listAppProfiles(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListAppProfiles, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListAppProfilesResponse.class.getName(),
Exception.class.getName())));
}
@@ -377,7 +377,7 @@ public void listAppProfiles(
@Override
public void updateAppProfile(
UpdateAppProfileRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -389,7 +389,7 @@ public void updateAppProfile(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateAppProfile, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -398,7 +398,7 @@ public void updateAppProfile(
@Override
public void deleteAppProfile(
DeleteAppProfileRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -410,7 +410,7 @@ public void deleteAppProfile(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteAppProfile, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -418,7 +418,7 @@ public void deleteAppProfile(
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -430,7 +430,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -438,7 +438,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -450,7 +450,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -460,7 +460,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -472,7 +472,7 @@ public void testIamPermissions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TestIamPermissionsResponse.class.getName(),
Exception.class.getName())));
}
diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java
index 191ea139f8..cb5d6947c7 100644
--- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java
+++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/MockBigtableTableAdminImpl.java
@@ -94,7 +94,7 @@ public void reset() {
@Override
public void createTable(CreateTableRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Table) {
requests.add(request);
responseObserver.onNext(((Table) response));
@@ -106,7 +106,7 @@ public void createTable(CreateTableRequest request, StreamObserver respon
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTable, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Table.class.getName(),
Exception.class.getName())));
}
@@ -115,7 +115,7 @@ public void createTable(CreateTableRequest request, StreamObserver respon
@Override
public void createTableFromSnapshot(
CreateTableFromSnapshotRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -127,7 +127,7 @@ public void createTableFromSnapshot(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTableFromSnapshot, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -136,7 +136,7 @@ public void createTableFromSnapshot(
@Override
public void listTables(
ListTablesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTablesResponse) {
requests.add(request);
responseObserver.onNext(((ListTablesResponse) response));
@@ -148,7 +148,7 @@ public void listTables(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTables, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTablesResponse.class.getName(),
Exception.class.getName())));
}
@@ -156,7 +156,7 @@ public void listTables(
@Override
public void getTable(GetTableRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Table) {
requests.add(request);
responseObserver.onNext(((Table) response));
@@ -168,7 +168,7 @@ public void getTable(GetTableRequest request, StreamObserver responseObse
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTable, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Table.class.getName(),
Exception.class.getName())));
}
@@ -176,7 +176,7 @@ public void getTable(GetTableRequest request, StreamObserver responseObse
@Override
public void deleteTable(DeleteTableRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -188,7 +188,7 @@ public void deleteTable(DeleteTableRequest request, StreamObserver respon
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTable, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -197,7 +197,7 @@ public void deleteTable(DeleteTableRequest request, StreamObserver respon
@Override
public void modifyColumnFamilies(
ModifyColumnFamiliesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Table) {
requests.add(request);
responseObserver.onNext(((Table) response));
@@ -209,7 +209,7 @@ public void modifyColumnFamilies(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ModifyColumnFamilies, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Table.class.getName(),
Exception.class.getName())));
}
@@ -217,7 +217,7 @@ public void modifyColumnFamilies(
@Override
public void dropRowRange(DropRowRangeRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -229,7 +229,7 @@ public void dropRowRange(DropRowRangeRequest request, StreamObserver resp
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DropRowRange, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -239,7 +239,7 @@ public void dropRowRange(DropRowRangeRequest request, StreamObserver resp
public void generateConsistencyToken(
GenerateConsistencyTokenRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof GenerateConsistencyTokenResponse) {
requests.add(request);
responseObserver.onNext(((GenerateConsistencyTokenResponse) response));
@@ -251,7 +251,7 @@ public void generateConsistencyToken(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GenerateConsistencyToken, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
GenerateConsistencyTokenResponse.class.getName(),
Exception.class.getName())));
}
@@ -260,7 +260,7 @@ public void generateConsistencyToken(
@Override
public void checkConsistency(
CheckConsistencyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof CheckConsistencyResponse) {
requests.add(request);
responseObserver.onNext(((CheckConsistencyResponse) response));
@@ -272,7 +272,7 @@ public void checkConsistency(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CheckConsistency, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
CheckConsistencyResponse.class.getName(),
Exception.class.getName())));
}
@@ -281,7 +281,7 @@ public void checkConsistency(
@Override
public void snapshotTable(
SnapshotTableRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -293,7 +293,7 @@ public void snapshotTable(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SnapshotTable, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -301,7 +301,7 @@ public void snapshotTable(
@Override
public void getSnapshot(GetSnapshotRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Snapshot) {
requests.add(request);
responseObserver.onNext(((Snapshot) response));
@@ -313,7 +313,7 @@ public void getSnapshot(GetSnapshotRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetSnapshot, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Snapshot.class.getName(),
Exception.class.getName())));
}
@@ -322,7 +322,7 @@ public void getSnapshot(GetSnapshotRequest request, StreamObserver res
@Override
public void listSnapshots(
ListSnapshotsRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListSnapshotsResponse) {
requests.add(request);
responseObserver.onNext(((ListSnapshotsResponse) response));
@@ -334,7 +334,7 @@ public void listSnapshots(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListSnapshots, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListSnapshotsResponse.class.getName(),
Exception.class.getName())));
}
@@ -343,7 +343,7 @@ public void listSnapshots(
@Override
public void deleteSnapshot(
DeleteSnapshotRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -355,7 +355,7 @@ public void deleteSnapshot(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteSnapshot, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -364,7 +364,7 @@ public void deleteSnapshot(
@Override
public void createBackup(
CreateBackupRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -376,7 +376,7 @@ public void createBackup(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateBackup, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -384,7 +384,7 @@ public void createBackup(
@Override
public void getBackup(GetBackupRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Backup) {
requests.add(request);
responseObserver.onNext(((Backup) response));
@@ -396,7 +396,7 @@ public void getBackup(GetBackupRequest request, StreamObserver responseO
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetBackup, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Backup.class.getName(),
Exception.class.getName())));
}
@@ -404,7 +404,7 @@ public void getBackup(GetBackupRequest request, StreamObserver responseO
@Override
public void updateBackup(UpdateBackupRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Backup) {
requests.add(request);
responseObserver.onNext(((Backup) response));
@@ -416,7 +416,7 @@ public void updateBackup(UpdateBackupRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateBackup, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Backup.class.getName(),
Exception.class.getName())));
}
@@ -424,7 +424,7 @@ public void updateBackup(UpdateBackupRequest request, StreamObserver res
@Override
public void deleteBackup(DeleteBackupRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -436,7 +436,7 @@ public void deleteBackup(DeleteBackupRequest request, StreamObserver resp
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteBackup, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -445,7 +445,7 @@ public void deleteBackup(DeleteBackupRequest request, StreamObserver resp
@Override
public void listBackups(
ListBackupsRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListBackupsResponse) {
requests.add(request);
responseObserver.onNext(((ListBackupsResponse) response));
@@ -457,7 +457,7 @@ public void listBackups(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListBackups, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListBackupsResponse.class.getName(),
Exception.class.getName())));
}
@@ -466,7 +466,7 @@ public void listBackups(
@Override
public void restoreTable(
RestoreTableRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Operation) {
requests.add(request);
responseObserver.onNext(((Operation) response));
@@ -478,7 +478,7 @@ public void restoreTable(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method RestoreTable, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Operation.class.getName(),
Exception.class.getName())));
}
@@ -486,7 +486,7 @@ public void restoreTable(
@Override
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -498,7 +498,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -506,7 +506,7 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver res
@Override
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Policy) {
requests.add(request);
responseObserver.onNext(((Policy) response));
@@ -518,7 +518,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Policy.class.getName(),
Exception.class.getName())));
}
@@ -528,7 +528,7 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver res
public void testIamPermissions(
TestIamPermissionsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TestIamPermissionsResponse) {
requests.add(request);
responseObserver.onNext(((TestIamPermissionsResponse) response));
@@ -540,7 +540,7 @@ public void testIamPermissions(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TestIamPermissionsResponse.class.getName(),
Exception.class.getName())));
}
diff --git a/synth.metadata b/synth.metadata
index 4b37397307..98e83037b3 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-bigtable.git",
- "sha": "6ba3bf3a642bd5b7ecf2a86a821ede0f2bae084f"
+ "sha": "63c67ea0d780d37db5b5fda93a28f574a8b48009"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "0e915217fb5261c1e57bfaf0e16ee5c7feaaba89",
- "internalRef": "361377784"
+ "sha": "1305ca41d554eb0725237561e34129373bb8cbc1",
+ "internalRef": "362856902"
}
},
{
From 30baa70d7135048d6f6f17d75c798b23574df83a Mon Sep 17 00:00:00 2001
From: "release-please[bot]"
<55107282+release-please[bot]@users.noreply.github.com>
Date: Tue, 16 Mar 2021 15:04:08 +0000
Subject: [PATCH 0018/1631] chore: release 1.21.1 (#668)
:robot: I have created a release \*beep\* \*boop\*
---
### [1.21.1](https://www.github.com/googleapis/java-bigtable/compare/v1.21.0...v1.21.1) (2021-03-15)
### Bug Fixes
* **retry:** restore grpc_service_config for CreateBackup and {Restore,Snapshot}Table ([#667](https://www.github.com/googleapis/java-bigtable/issues/667)) ([121f071](https://www.github.com/googleapis/java-bigtable/commit/121f07159c2715368cb53753ba39d70d1d25efb8))
### Dependencies
* update dependency com.google.cloud:google-cloud-shared-dependencies to v0.20.1 ([#671](https://www.github.com/googleapis/java-bigtable/issues/671)) ([6ba3bf3](https://www.github.com/googleapis/java-bigtable/commit/6ba3bf3a642bd5b7ecf2a86a821ede0f2bae084f))
---
This PR was generated with [Release Please](https://github.com/googleapis/release-please). See [documentation](https://github.com/googleapis/release-please#release-please).
---
CHANGELOG.md | 12 ++++++++++++
google-cloud-bigtable-bom/pom.xml | 14 +++++++-------
google-cloud-bigtable-deps-bom/pom.xml | 2 +-
google-cloud-bigtable-emulator/pom.xml | 8 ++++----
google-cloud-bigtable/pom.xml | 10 +++++-----
grpc-google-cloud-bigtable-admin-v2/pom.xml | 8 ++++----
grpc-google-cloud-bigtable-v2/pom.xml | 8 ++++----
pom.xml | 2 +-
proto-google-cloud-bigtable-admin-v2/pom.xml | 8 ++++----
proto-google-cloud-bigtable-v2/pom.xml | 8 ++++----
samples/snapshot/pom.xml | 2 +-
versions.txt | 12 ++++++------
12 files changed, 53 insertions(+), 41 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 36b6382346..084ad5bc93 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,17 @@
# Changelog
+### [1.21.1](https://www.github.com/googleapis/java-bigtable/compare/v1.21.0...v1.21.1) (2021-03-15)
+
+
+### Bug Fixes
+
+* **retry:** restore grpc_service_config for CreateBackup and {Restore,Snapshot}Table ([#667](https://www.github.com/googleapis/java-bigtable/issues/667)) ([121f071](https://www.github.com/googleapis/java-bigtable/commit/121f07159c2715368cb53753ba39d70d1d25efb8))
+
+
+### Dependencies
+
+* update dependency com.google.cloud:google-cloud-shared-dependencies to v0.20.1 ([#671](https://www.github.com/googleapis/java-bigtable/issues/671)) ([6ba3bf3](https://www.github.com/googleapis/java-bigtable/commit/6ba3bf3a642bd5b7ecf2a86a821ede0f2bae084f))
+
## [1.21.0](https://www.github.com/googleapis/java-bigtable/compare/v1.20.1...v1.21.0) (2021-03-02)
diff --git a/google-cloud-bigtable-bom/pom.xml b/google-cloud-bigtable-bom/pom.xml
index e7f7d4a0ba..3a7cf90ccc 100644
--- a/google-cloud-bigtable-bom/pom.xml
+++ b/google-cloud-bigtable-bom/pom.xml
@@ -3,7 +3,7 @@
4.0.0
com.google.cloud
google-cloud-bigtable-bom
- 1.21.1-SNAPSHOT
+ 1.21.1
pom