Skip to content

Commit 30f0b10

Browse files
fix: change toString to value in TopicStatsClient (#210)
1 parent a4ca349 commit 30f0b10

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/internal/TopicStatsClient.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,5 +51,6 @@ ApiFuture<ComputeMessageStatsResponse> computeMessageStats(
5151
*
5252
* @throws StatusException on a failure to properly terminate.
5353
*/
54+
@Override
5455
void close() throws StatusException;
5556
}

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/internal/TopicStatsClientImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public ApiFuture<ComputeMessageStatsResponse> computeMessageStats(
110110
() -> {
111111
return stub.computeMessageStats(
112112
ComputeMessageStatsRequest.newBuilder()
113-
.setTopic(path.toString())
113+
.setTopic(path.value())
114114
.setPartition(partition.value())
115115
.setStartCursor(Cursor.newBuilder().setOffset(start.value()).build())
116116
.setEndCursor(Cursor.newBuilder().setOffset(end.value()).build())

google-cloud-pubsublite/src/test/java/com/google/cloud/pubsublite/internal/TopicStatsClientImplTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ private static Offset end() {
9696

9797
private static ComputeMessageStatsRequest request() {
9898
return ComputeMessageStatsRequest.newBuilder()
99-
.setTopic(path().toString())
99+
.setTopic(path().value())
100100
.setPartition(partition().value())
101101
.setStartCursor(Cursor.newBuilder().setOffset(start().value()).build())
102102
.setEndCursor(Cursor.newBuilder().setOffset(end().value()).build())

0 commit comments

Comments
 (0)