org.neo4j.com

Class Client<T>

java.lang.Object

org.neo4j.kernel.lifecycle.LifecycleAdapter

org.neo4j.com.Client<T>

All Implemented Interfaces:

org.jboss.netty.channel.ChannelPipelineFactory, org.neo4j.kernel.lifecycle.Lifecycle

public abstract class Client<T>
extends org.neo4j.kernel.lifecycle.LifecycleAdapter
implements org.jboss.netty.channel.ChannelPipelineFactory

A means for a client to communicate with a Server. It serializes requests and sends them to the server and waits for a response back.

See Also:

Server

Nested Class Summary

Nested classes/interfaces inherited from interface org.neo4j.kernel.lifecycle.Lifecycle

org.neo4j.kernel.lifecycle.Lifecycle.Delegate

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_NUMBER_OF_CONCURRENT_CHANNELS_PER_CLIENT
static int	DEFAULT_READ_RESPONSE_TIMEOUT_SECONDS

Constructor Summary

Constructors

Constructor and Description

Client(String destinationHostNameOrIp, int destinationPort, String originHostNameOrIp, org.neo4j.logging.LogProvider logProvider, org.neo4j.kernel.impl.store.StoreId storeId, int frameLength, long readTimeout, int maxConcurrentChannels, int chunkSize, ResponseUnpacker responseUnpacker, org.neo4j.kernel.monitoring.ByteCounterMonitor byteCounterMonitor, RequestMonitor requestMonitor, org.neo4j.kernel.impl.transaction.log.entry.LogEntryReader<org.neo4j.kernel.impl.transaction.log.ReadableClosablePositionAwareChannel> entryReader)

Method Summary

Modifier and Type	Method and Description
org.jboss.netty.channel.ChannelPipeline	getPipeline()
abstract ProtocolVersion	getProtocolVersion()
void	setComExceptionHandler(ComExceptionHandler handler)
void	start()
void	stop()
String	toString()

Methods inherited from class org.neo4j.kernel.lifecycle.LifecycleAdapter

init, shutdown

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_MAX_NUMBER_OF_CONCURRENT_CHANNELS_PER_CLIENT

public static final int DEFAULT_MAX_NUMBER_OF_CONCURRENT_CHANNELS_PER_CLIENT

See Also:

Constant Field Values

DEFAULT_READ_RESPONSE_TIMEOUT_SECONDS

public static final int DEFAULT_READ_RESPONSE_TIMEOUT_SECONDS

See Also:

Constant Field Values

Constructor Detail

Client

public Client(String destinationHostNameOrIp,
              int destinationPort,
              String originHostNameOrIp,
              org.neo4j.logging.LogProvider logProvider,
              org.neo4j.kernel.impl.store.StoreId storeId,
              int frameLength,
              long readTimeout,
              int maxConcurrentChannels,
              int chunkSize,
              ResponseUnpacker responseUnpacker,
              org.neo4j.kernel.monitoring.ByteCounterMonitor byteCounterMonitor,
              RequestMonitor requestMonitor,
              org.neo4j.kernel.impl.transaction.log.entry.LogEntryReader<org.neo4j.kernel.impl.transaction.log.ReadableClosablePositionAwareChannel> entryReader)

Method Detail

getProtocolVersion

public abstract ProtocolVersion getProtocolVersion()

start

public void start()

Specified by:

start in interface org.neo4j.kernel.lifecycle.Lifecycle

Overrides:

start in class org.neo4j.kernel.lifecycle.LifecycleAdapter

stop

public void stop()

Specified by:

stop in interface org.neo4j.kernel.lifecycle.Lifecycle

Overrides:

stop in class org.neo4j.kernel.lifecycle.LifecycleAdapter

getPipeline

public org.jboss.netty.channel.ChannelPipeline getPipeline()
                                                    throws Exception

Specified by:

getPipeline in interface org.jboss.netty.channel.ChannelPipelineFactory

Throws:

Exception

setComExceptionHandler

public void setComExceptionHandler(ComExceptionHandler handler)

toString

public String toString()

Overrides:

toString in class Object