Remove unused imports

Signed-off-by: Kevin O'Donnell <[email protected]>
blockchaintp · May 22, 2019 · 95f3579 · 95f3579
1 parent 2ec6a47
commit 95f3579
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/sawtooth-daml-rpc/src/main/java/com/blockchaintp/sawtooth/daml/rpc/SawtoothReadService.java b/sawtooth-daml-rpc/src/main/java/com/blockchaintp/sawtooth/daml/rpc/SawtoothReadService.java
@@ -14,7 +14,6 @@
 import akka.NotUsed;
 import akka.stream.scaladsl.Source;
 import io.reactivex.Flowable;
-import io.reactivex.processors.UnicastProcessor;
 import scala.Option;
 import scala.Tuple2;
 

diff --git a/...-rpc/src/test/java/com/blockchaintp/sawtooth/daml/rpc/events/DamlLogEventHandlerTest.java b/...-rpc/src/test/java/com/blockchaintp/sawtooth/daml/rpc/events/DamlLogEventHandlerTest.java
@@ -17,15 +17,13 @@
 
 import com.blockchaintp.sawtooth.daml.util.EventConstants;
 import com.daml.ledger.participant.state.kvutils.DamlKvutils.DamlLogEntry;
-import com.daml.ledger.participant.state.kvutils.DamlKvutils.DamlLogEntryId;
 import com.daml.ledger.participant.state.v1.Offset;
 import com.daml.ledger.participant.state.v1.Update;
 import com.google.protobuf.ByteString;
 import com.google.protobuf.InvalidProtocolBufferException;
 
 import akka.NotUsed;
 import akka.stream.scaladsl.Source;
-import io.reactivex.Observer;
 import io.reactivex.subscribers.TestSubscriber;
 import net.bytebuddy.utility.RandomString;
 import sawtooth.sdk.protobuf.Event;

diff --git a/...ain/java/com/blockchaintp/sawtooth/timekeeper/processor/TimeKeeperTransactionHandler.java b/...ain/java/com/blockchaintp/sawtooth/timekeeper/processor/TimeKeeperTransactionHandler.java
@@ -7,6 +7,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.logging.Logger;
+import java.util.logging.Level;
 
 import com.blockchaintp.sawtooth.timekeeper.protobuf.TimeKeeperEvent;
 import com.blockchaintp.sawtooth.timekeeper.protobuf.TimeKeeperGlobalRecord;
@@ -20,6 +21,7 @@
 import com.google.protobuf.Timestamp;
 import com.google.protobuf.util.Timestamps;
 
+
 import sawtooth.sdk.processor.Context;
 import sawtooth.sdk.processor.TransactionHandler;
 import sawtooth.sdk.processor.exceptions.InternalError;
@@ -129,6 +131,7 @@ public void apply(final TpProcessRequest transactionRequest, final Context state
       TimeKeeperEvent updateEventData = TimeKeeperEvent.newBuilder().setTimeUpdate(newGlobalTs).build();
       Map<String, String> attrMap = new HashMap<>();
       attrMap.put(EventConstants.TIMEKEEPER_MICROS_ATTRIBUTE, Long.toString(Timestamps.toMicros(newGlobalTs)));
+      LOGGER.log(Level.FINE, "New time event {}", newGlobalTs);
       state.addEvent(EventConstants.TIMEKEEPER_EVENT_SUBJECT, attrMap.entrySet(), updateEventData.toByteString());
     } catch (InvalidProtocolBufferException exc) {
       throw new InvalidTransactionException("Transaction has bad format " + exc.getMessage());