Skip to content

Commit a409eac

Browse files
committed
make AckDeadlineRenewerTest pass
1 parent fb6c5ae commit a409eac

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/AckDeadlineRenewerTest.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818

1919
import static org.junit.Assert.assertTrue;
2020

21+
import com.google.cloud.Clock;
2122
import com.google.cloud.GrpcServiceOptions.ExecutorFactory;
2223
import com.google.common.collect.ImmutableList;
2324
import java.util.concurrent.CountDownLatch;
@@ -29,11 +30,12 @@
2930
import java.util.concurrent.atomic.AtomicLong;
3031
import org.easymock.EasyMock;
3132
import org.easymock.IAnswer;
33+
import org.joda.time.DateTimeUtils;
3234
import org.junit.After;
3335
import org.junit.Before;
3436
import org.junit.Rule;
35-
import org.junit.Test;
3637
import org.junit.rules.Timeout;
38+
import org.junit.Test;
3739

3840
public class AckDeadlineRenewerTest {
3941

@@ -49,7 +51,12 @@ public class AckDeadlineRenewerTest {
4951
private PubSub pubsub;
5052
private FakeScheduledExecutorService executorService;
5153
private AckDeadlineRenewer ackDeadlineRenewer;
52-
private final FakeClock clock = new FakeClock();
54+
private final Clock clock = new Clock() {
55+
@Override
56+
public long millis() {
57+
return DateTimeUtils.currentTimeMillis();
58+
}
59+
};
5360

5461
@Rule
5562
public Timeout globalTimeout = Timeout.seconds(60);

0 commit comments

Comments
 (0)