org.infinispan.server.core.transport

Class NettyTransport

java.lang.Object

org.infinispan.server.core.transport.NettyTransport

All Implemented Interfaces:

Log, Transport

public class NettyTransport
extends Object
implements Transport, Log

A Netty based transport.

Since:

4.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
NettyTransport(ProtocolServer server, LifecycleChannelPipelineFactory pipeline, InetSocketAddress address, ProtocolServerConfiguration configuration, String threadNamePrefix, EmbeddedCacheManager cacheManager)

Method Summary

Methods

Modifier and Type	Method and Description
org.jboss.netty.channel.group.DefaultChannelGroup	acceptedChannels()
String	getHostName()
String	getIdleTimeout()
Integer	getNumberOfGlobalConnections()
Integer	getNumberOfLocalConnections()
String	getNumberWorkerThreads()
String	getPort()
String	getReceiveBufferSize()
String	getSendBufferSize()
String	getTcpNoDelay()
String	getTotalBytesRead()
String	getTotalBytesWritten()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.server.core.logging.Log

debug, debug, debug, debug, debug, debugf, error, info, info, isDebugEnabled, isTraceEnabled, log, logChannelStillBound, logChannelStillConnected, logErrorBeforeReadingRequest, logExceptionReported, logPostingShutdownRequest, logServerDidNotClose, logServerDidNotUnbind, logSettingMasterThreadsNotSupported, logStartWithArgs, trace, trace, trace, trace, tracef, warn

Constructor Detail

NettyTransport

public NettyTransport(ProtocolServer server,
              LifecycleChannelPipelineFactory pipeline,
              InetSocketAddress address,
              ProtocolServerConfiguration configuration,
              String threadNamePrefix,
              EmbeddedCacheManager cacheManager)

Method Detail

acceptedChannels

public org.jboss.netty.channel.group.DefaultChannelGroup acceptedChannels()

start

public void start()

Specified by:

start in interface Transport

stop

public void stop()

Specified by:

stop in interface Transport

getTotalBytesWritten

public String getTotalBytesWritten()

Specified by:

getTotalBytesWritten in interface Transport

getTotalBytesRead

public String getTotalBytesRead()

Specified by:

getTotalBytesRead in interface Transport

getHostName

public String getHostName()

Specified by:

getHostName in interface Transport

getPort

public String getPort()

Specified by:

getPort in interface Transport

getNumberWorkerThreads

public String getNumberWorkerThreads()

Specified by:

getNumberWorkerThreads in interface Transport

getIdleTimeout

public String getIdleTimeout()

Specified by:

getIdleTimeout in interface Transport

getTcpNoDelay

public String getTcpNoDelay()

Specified by:

getTcpNoDelay in interface Transport

getSendBufferSize

public String getSendBufferSize()

Specified by:

getSendBufferSize in interface Transport

getReceiveBufferSize

public String getReceiveBufferSize()

Specified by:

getReceiveBufferSize in interface Transport

getNumberOfLocalConnections

public Integer getNumberOfLocalConnections()

Specified by:

getNumberOfLocalConnections in interface Transport

getNumberOfGlobalConnections

public Integer getNumberOfGlobalConnections()

Specified by:

getNumberOfGlobalConnections in interface Transport