com.github.jcustenborder.kafka.connect.utils

Class SystemTime

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.SystemTime

All Implemented Interfaces:

org.apache.kafka.common.utils.Time

public class SystemTime
extends Object
implements org.apache.kafka.common.utils.Time

Field Summary

Fields inherited from interface org.apache.kafka.common.utils.Time

SYSTEM

Method Summary

Modifier and Type	Method and Description
static SystemTime	getSystemTime()
long	milliseconds()
long	nanoseconds()
void	sleep(long ms)
void	waitObject(Object obj, Supplier<Boolean> condition, long deadlineMs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.common.utils.Time

hiResClockMs, timer, timer, waitForFuture

Method Detail

getSystemTime

public static SystemTime getSystemTime()

milliseconds

public long milliseconds()

Specified by:

milliseconds in interface org.apache.kafka.common.utils.Time

nanoseconds

public long nanoseconds()

Specified by:

nanoseconds in interface org.apache.kafka.common.utils.Time

sleep

public void sleep(long ms)

Specified by:

sleep in interface org.apache.kafka.common.utils.Time

waitObject

public void waitObject(Object obj,
                       Supplier<Boolean> condition,
                       long deadlineMs)
                throws InterruptedException

Specified by:

waitObject in interface org.apache.kafka.common.utils.Time

Throws:

InterruptedException