@@ -82,7 +82,7 @@ protected void dispatch(Collection<Telemetry> telemetries) {
8282 }
8383 }
8484
85- private static final class ScheduledSendHandler extends SendHandler implements Runnable {
85+ private static final class ScheduledSendHandler extends SendHandler {
8686 private final TelemetriesFetcher <Telemetry > telemetriesFetcher ;
8787
8888 public ScheduledSendHandler (TransmissionDispatcher transmissionDispatcher , TelemetriesFetcher <Telemetry > telemetriesFetcher , TelemetrySerializer serializer ) {
@@ -93,14 +93,13 @@ public ScheduledSendHandler(TransmissionDispatcher transmissionDispatcher, Telem
9393 this .telemetriesFetcher = telemetriesFetcher ;
9494 }
9595
96- @ Override
9796 public void run () {
9897 Collection <Telemetry > telemetriesToSend = telemetriesFetcher .fetch ();
9998 dispatch (telemetriesToSend );
10099 }
101100 }
102101
103- private static final class SendNowHandler extends SendHandler implements Runnable {
102+ private static final class SendNowHandler extends SendHandler {
104103 private final Collection <Telemetry > telemetries ;
105104
106105 public SendNowHandler (TransmissionDispatcher transmissionDispatcher , TelemetrySerializer serializer , Collection <Telemetry > telemetries ) {
@@ -111,7 +110,6 @@ public SendNowHandler(TransmissionDispatcher transmissionDispatcher, TelemetrySe
111110 this .telemetries = telemetries ;
112111 }
113112
114- @ Override
115113 public void run () {
116114 dispatch (telemetries );
117115 }
@@ -158,7 +156,7 @@ public boolean scheduleSend(TelemetriesFetcher telemetriesFetcher, long value, T
158156 }
159157
160158 try {
161- final Runnable command = new ScheduledSendHandler (transmissionDispatcher , telemetriesFetcher , serializer );
159+ final ScheduledSendHandler command = new ScheduledSendHandler (transmissionDispatcher , telemetriesFetcher , serializer );
162160 threadPool .schedule (new Runnable () {
163161 public void run () {
164162 try {
@@ -205,7 +203,7 @@ public boolean sendNow(Collection<Telemetry> telemetries) {
205203 return false ;
206204 }
207205
208- final Runnable command = new SendNowHandler (transmissionDispatcher , serializer , telemetries );
206+ final SendNowHandler command = new SendNowHandler (transmissionDispatcher , serializer , telemetries );
209207 try {
210208 threadPool .execute (new Runnable () {
211209 public void run () {
0 commit comments