Skip to content

Commit

Permalink
Remove dependency on log4j
Browse files Browse the repository at this point in the history
  • Loading branch information
iansrobinson committed Jan 5, 2022
1 parent db4376b commit ab83c5a
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 45 deletions.
32 changes: 0 additions & 32 deletions neptune-streams-utils/examples/java8/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -68,30 +68,6 @@
</exclusions>
</dependency>

<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-lambda-java-log4j2</artifactId>
<version>1.1.0</version>
</dependency>

<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.17.1</version>
</dependency>

<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.17.1</version>
</dependency>

<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j18-impl</artifactId>
<version>2.13.0</version>
</dependency>


</dependencies>

Expand All @@ -113,9 +89,6 @@
<configuration>
<finalName>${uberjar.name}</finalName>
<transformers>
<transformer
implementation="com.github.edwgiz.maven_shade_plugin.log4j2_cache_transformer.PluginsCacheFileTransformer">
</transformer>
</transformers>
<filters>
<filter>
Expand All @@ -131,11 +104,6 @@
</execution>
</executions>
<dependencies>
<dependency>
<groupId>com.github.edwgiz</groupId>
<artifactId>maven-shade-plugin.log4j2-cachefile-transformer</artifactId>
<version>2.14.0</version>
</dependency>
</dependencies>
</plugin>
<plugin>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,18 +13,12 @@
package stream_handler;

import com.amazonaws.neptune.StreamRecordsHandler;
import com.amazonaws.neptune.StreamsResponse;
import com.amazonaws.neptune.config.CredentialsConfig;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.io.IOException;
import java.util.Map;

public abstract class AbstractStreamHandler implements StreamRecordsHandler {

private static final Logger logger = LogManager.getLogger(StreamHandler.class);

protected final String neptuneEndpoint;
protected final Integer neptunePort;
protected final CredentialsConfig credentialsConfig;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,6 @@
import com.amazonaws.neptune.StreamsRecord;
import com.amazonaws.neptune.StreamsResponse;
import com.amazonaws.neptune.config.CredentialsConfig;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.tinkerpop.gremlin.driver.Cluster;
import org.apache.tinkerpop.gremlin.driver.SigV4WebSocketChannelizer;
import org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteConnection;
Expand All @@ -30,12 +28,9 @@

public class StreamHandler extends AbstractStreamHandler {

private static final Logger logger = LogManager.getLogger(StreamHandler.class);

private final GraphTraversalSource g;
private final Cluster cluster;


public StreamHandler(String neptuneEndpoint,
Integer neptunePort,
CredentialsConfig credentialsConfig,
Expand All @@ -62,9 +57,9 @@ public void handleRecords(StreamsResponse streamsResponse) throws IOException {
String id = record.getData().getId();
String type = record.getData().getType();
if (type.equals("vl")) {
logger.info(g.V(id).valueMap(true).toList());
System.out.println(g.V(id).valueMap(true).toList());
} else if (type.equals("e")) {
logger.info(g.E(id).valueMap(true).toList());
System.out.println(g.E(id).valueMap(true).toList());
}
}

Expand Down

0 comments on commit ab83c5a

Please sign in to comment.