Loading kinetic-client/src/main/java/com/seagate/kinetic/client/internal/MessageFactory.java +0 −5 Original line number Diff line number Diff line Loading @@ -9,8 +9,6 @@ */ package com.seagate.kinetic.client.internal; import java.util.logging.Logger; import kinetic.client.Entry; import kinetic.client.EntryMetadata; import kinetic.client.KineticException; Loading @@ -36,9 +34,6 @@ import com.seagate.kinetic.proto.Kinetic.MessageOrBuilder; */ public class MessageFactory { private final static Logger logger = Logger.getLogger(MessageFactory.class .getName()); // persist synchronization mode private static Synchronization synchronization = Synchronization.WRITEBACK; Loading kinetic-client/src/main/java/com/seagate/kinetic/client/io/MessageHandler.java +0 −10 Original line number Diff line number Diff line Loading @@ -34,7 +34,6 @@ import com.seagate.kinetic.client.internal.async.GetMetadataAsyncCallbackHandler import com.seagate.kinetic.client.internal.async.PutAsyncCallbackHandler; import com.seagate.kinetic.client.io.provider.spi.ClientMessageService; import com.seagate.kinetic.common.lib.KineticMessage; import com.seagate.kinetic.proto.Kinetic.Message; import com.seagate.kinetic.proto.Kinetic.Message.MessageType; /** Loading Loading @@ -258,15 +257,6 @@ public class MessageHandler implements ClientMessageService, Runnable { this.doWrite(message); } /** * check if there is a thread running. * * @return true if the thread is polling the message. */ private boolean isRunning() { return isRunning; } @SuppressWarnings("rawtypes") private void invokeCallbackHandler(Object cbContext, KineticMessage response) { Loading kinetic-client/src/main/java/com/seagate/kinetic/client/io/provider/nio/ssl/SslTrustManagerFactory.java +0 −5 Original line number Diff line number Diff line Loading @@ -13,8 +13,6 @@ import java.security.InvalidAlgorithmParameterException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.cert.X509Certificate; import java.util.logging.Logger; import javax.net.ssl.ManagerFactoryParameters; import javax.net.ssl.TrustManager; import javax.net.ssl.TrustManagerFactorySpi; Loading @@ -28,9 +26,6 @@ import javax.net.ssl.X509TrustManager; */ public class SslTrustManagerFactory extends TrustManagerFactorySpi { private final Logger logger = Logger.getLogger(SslTrustManagerFactory.class .getName()); private static final TrustManager TRUST_MANAGER = new X509TrustManager() { @Override public X509Certificate[] getAcceptedIssuers() { Loading kinetic-client/src/main/java/com/seagate/kinetic/monitor/HeartbeatListener.java +1 −0 Original line number Diff line number Diff line Loading @@ -125,6 +125,7 @@ public class HeartbeatListener implements Runnable { } public static void main(String[] args) throws IOException { @SuppressWarnings("unused") HeartbeatListener listener = new HeartbeatListener(); } } kinetic-common/pom.xml +0 −1 Original line number Diff line number Diff line Loading @@ -59,7 +59,6 @@ <dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.2.4</version> </dependency> </dependencies> <dependencyManagement> Loading Loading
kinetic-client/src/main/java/com/seagate/kinetic/client/internal/MessageFactory.java +0 −5 Original line number Diff line number Diff line Loading @@ -9,8 +9,6 @@ */ package com.seagate.kinetic.client.internal; import java.util.logging.Logger; import kinetic.client.Entry; import kinetic.client.EntryMetadata; import kinetic.client.KineticException; Loading @@ -36,9 +34,6 @@ import com.seagate.kinetic.proto.Kinetic.MessageOrBuilder; */ public class MessageFactory { private final static Logger logger = Logger.getLogger(MessageFactory.class .getName()); // persist synchronization mode private static Synchronization synchronization = Synchronization.WRITEBACK; Loading
kinetic-client/src/main/java/com/seagate/kinetic/client/io/MessageHandler.java +0 −10 Original line number Diff line number Diff line Loading @@ -34,7 +34,6 @@ import com.seagate.kinetic.client.internal.async.GetMetadataAsyncCallbackHandler import com.seagate.kinetic.client.internal.async.PutAsyncCallbackHandler; import com.seagate.kinetic.client.io.provider.spi.ClientMessageService; import com.seagate.kinetic.common.lib.KineticMessage; import com.seagate.kinetic.proto.Kinetic.Message; import com.seagate.kinetic.proto.Kinetic.Message.MessageType; /** Loading Loading @@ -258,15 +257,6 @@ public class MessageHandler implements ClientMessageService, Runnable { this.doWrite(message); } /** * check if there is a thread running. * * @return true if the thread is polling the message. */ private boolean isRunning() { return isRunning; } @SuppressWarnings("rawtypes") private void invokeCallbackHandler(Object cbContext, KineticMessage response) { Loading
kinetic-client/src/main/java/com/seagate/kinetic/client/io/provider/nio/ssl/SslTrustManagerFactory.java +0 −5 Original line number Diff line number Diff line Loading @@ -13,8 +13,6 @@ import java.security.InvalidAlgorithmParameterException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.cert.X509Certificate; import java.util.logging.Logger; import javax.net.ssl.ManagerFactoryParameters; import javax.net.ssl.TrustManager; import javax.net.ssl.TrustManagerFactorySpi; Loading @@ -28,9 +26,6 @@ import javax.net.ssl.X509TrustManager; */ public class SslTrustManagerFactory extends TrustManagerFactorySpi { private final Logger logger = Logger.getLogger(SslTrustManagerFactory.class .getName()); private static final TrustManager TRUST_MANAGER = new X509TrustManager() { @Override public X509Certificate[] getAcceptedIssuers() { Loading
kinetic-client/src/main/java/com/seagate/kinetic/monitor/HeartbeatListener.java +1 −0 Original line number Diff line number Diff line Loading @@ -125,6 +125,7 @@ public class HeartbeatListener implements Runnable { } public static void main(String[] args) throws IOException { @SuppressWarnings("unused") HeartbeatListener listener = new HeartbeatListener(); } }
kinetic-common/pom.xml +0 −1 Original line number Diff line number Diff line Loading @@ -59,7 +59,6 @@ <dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.2.4</version> </dependency> </dependencies> <dependencyManagement> Loading