Package com.Lomikel.Januser

Class GremlinClient

java.lang.Object

com.Lomikel.Januser.GremlinClient

Direct Known Subclasses:

DirectGremlinClient, StringGremlinClient

public abstract class GremlinClient
extends Object

Shared remote Gremlin connection and cleanup lifecycle.

Subclasses select a serializer and either expose a typed remote traversal source or script-submission results.

Author:

J.Hrivnac

Field Summary

Fields

Modifier and Type	Field	Description
private Cluster	_cluster
private static org.apache.logging.log4j.Logger	log	Logging .

Constructor Summary

Constructors

Modifier	Constructor	Description
	GremlinClient(String hostname, int port)	Create with connection parameters.
protected	GremlinClient(String hostname, int port, boolean deferInitialization)	Create with optional deferred initialization for subclasses that need their own state initialized before open(java.lang.String, int) and connect().

Method Summary

Modifier and Type	Method	Description
abstract void	close()	Close client.
Cluster	cluster()	Give the Cluster.
protected static RuntimeException	collectCleanupFailure(RuntimeException failure, String resource, Exception cause)	Accumulate cleanup failures without preventing later resources from closing.
abstract void	connect()	Connect client.
void	createCluster(String hostname, int port, MessageSerializer serializer)	Create Cluster.
protected final void	initialize(String hostname, int port)	Open and connect, closing partial resources if initialization fails.
abstract void	open(String hostname, int port)	Open.

Methods inherited from class java.lang.Object

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

Field Details

_cluster

private Cluster _cluster

log

private static org.apache.logging.log4j.Logger log

Logging .

Constructor Details

GremlinClient

public GremlinClient(String hostname,
 int port)

Create with connection parameters.

Parameters:

hostname - The Gremlin hostname.

port - The Gremlin port.

GremlinClient

protected GremlinClient(String hostname,
 int port,
 boolean deferInitialization)

Create with optional deferred initialization for subclasses that need their own state initialized before open(java.lang.String, int) and connect().

Parameters:

hostname - The Gremlin hostname.

port - The Gremlin port.

deferInitialization - Whether the subclass will call initialize(java.lang.String, int) explicitly.

Method Details

initialize

protected final void initialize(String hostname,
 int port)

Open and connect, closing partial resources if initialization fails.

Parameters:

hostname - The Gremlin hostname.

port - The Gremlin port.

collectCleanupFailure

protected static RuntimeException collectCleanupFailure(RuntimeException failure,
 String resource,
 Exception cause)

Accumulate cleanup failures without preventing later resources from closing.

Parameters:

failure - The previously collected failure, or null.

resource - The resource whose close failed.

cause - The close failure.

Returns:

The first failure with later failures suppressed.

open

public abstract void open(String hostname,
 int port)

Open.

Parameters:

hostname - The Gremlin hostname.

port - The Gremlin port.

connect

public abstract void connect()

Connect client.

close

public abstract void close()

Close client.

createCluster

public void createCluster(String hostname,
 int port,
 MessageSerializer serializer)

Create Cluster.

Parameters:

hostname - The Gremlin hostname.

port - The Gremlin port.

serializer - The used MessageSerializer.

cluster

public Cluster cluster()

Give the Cluster.

Returns:

The attached Cluster.