Skip to content

Commit 5129e14

Browse files
committed
remove unused code
1 parent e2a3302 commit 5129e14

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

pubsub/cloud-client/src/main/java/com/example/pubsub/SubscriberExample.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,6 @@ public class SubscriberExample {
3737

3838
private static final BlockingQueue<PubsubMessage> messages = new LinkedBlockingDeque<>();
3939

40-
private final List<String> receivedMessageIds = new ArrayList<>();
41-
4240
static class MessageReceiverExample implements MessageReceiver {
4341

4442
@Override
@@ -48,10 +46,6 @@ public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
4846
}
4947
}
5048

51-
List<String> getReceivedMessages() {
52-
return ImmutableList.copyOf(receivedMessageIds);
53-
}
54-
5549
public static void main(String... args) throws Exception {
5650
// set subscriber id, eg. my-subscriber-id
5751
String subscriptionId = args[0];

0 commit comments

Comments
 (0)