File tree Expand file tree Collapse file tree
trunk/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11---
2- refs/heads/master: 04ed15d7c3cd77e84026bdd7c1a3abad9e35d235
2+ refs/heads/master: f5081165ddd8816aa7536d183788fc9e421394ae
33refs/heads/travis: dae77e558b884bc1b165155482d76c8e40b0fca4
44refs/heads/gh-pages: 229631582f8957646f81e92ae5a326504f48ee5b
55refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
Original file line number Diff line number Diff line change 1717package com .google .cloud .pubsub ;
1818
1919import com .google .common .math .Stats ;
20- import java .time .LocalDateTime ;
2120import javax .annotation .concurrent .Immutable ;
2221
2322/**
2726//TODO: Finish implementation.
2827@ Immutable
2928public class SubscriberStats {
30- private final LocalDateTime startTime ;
3129 private final long totalReceivedMessages ;
3230 private final long totalAckedMessages ;
3331 private final Stats endToEndLatency ;
3432 private final Stats ackLatency ;
3533 private final long numberOfAutoExtendedAckDeadlines ;
3634
37- SubscriberStats (LocalDateTime startTime ) {
38- this .startTime = startTime ;
35+ SubscriberStats () {
3936 this .totalReceivedMessages = 0 ;
4037 this .totalAckedMessages = 0 ;
4138 this .numberOfAutoExtendedAckDeadlines = 0 ;
@@ -53,11 +50,6 @@ public long getAckedMessages() {
5350 return totalAckedMessages ;
5451 }
5552
56- /** Time when the subscriber started. */
57- public LocalDateTime getStartTime () {
58- return startTime ;
59- }
60-
6153 /** Number of received messages. */
6254 public long getTotalReceivedMessages () {
6355 return totalReceivedMessages ;
You can’t perform that action at this time.
0 commit comments