Package org.infinispan.server.core.transport

Class NettyTransport

java.lang.Object

org.infinispan.server.core.transport.NettyTransport

All Implemented Interfaces:

Transport

public class NettyTransport
extends Object
implements Transport

A Netty based transport.

Since:

4.1

Author:

Galder Zamarreño, wburns

Constructor Summary

Constructors

Constructor	Description
NettyTransport(InetSocketAddress address, ProtocolServerConfiguration configuration, String threadNamePrefix, EmbeddedCacheManager cacheManager)

Method Summary

Modifier and Type	Method	Description
String	getHostName()
int	getIdleTimeout()
int	getNumberIOThreads()
int	getNumberOfGlobalConnections()
int	getNumberOfLocalConnections()
int	getPendingTasks()
int	getPort()
int	getReceiveBufferSize()
int	getSendBufferSize()
boolean	getTcpNoDelay()
long	getTotalBytesRead()
long	getTotalBytesWritten()
void	initializeHandler(io.netty.channel.ChannelInitializer<io.netty.channel.Channel> handler)
void	start()
void	stop()
void	updateTotalBytesRead(int bytes)
void	updateTotalBytesWritten(int bytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyTransport

public NettyTransport(InetSocketAddress address,
                      ProtocolServerConfiguration configuration,
                      String threadNamePrefix,
                      EmbeddedCacheManager cacheManager)

Method Detail

initializeHandler

public void initializeHandler(io.netty.channel.ChannelInitializer<io.netty.channel.Channel> handler)

start

public void start()

Specified by:

start in interface Transport

stop

public void stop()

Specified by:

stop in interface Transport

getTotalBytesWritten

public long getTotalBytesWritten()

Specified by:

getTotalBytesWritten in interface Transport

getTotalBytesRead

public long getTotalBytesRead()

Specified by:

getTotalBytesRead in interface Transport

getHostName

public String getHostName()

Specified by:

getHostName in interface Transport

getPort

public int getPort()

Specified by:

getPort in interface Transport

getNumberIOThreads

public int getNumberIOThreads()

Specified by:

getNumberIOThreads in interface Transport

getPendingTasks

public int getPendingTasks()

Specified by:

getPendingTasks in interface Transport

getIdleTimeout

public int getIdleTimeout()

Specified by:

getIdleTimeout in interface Transport

getTcpNoDelay

public boolean getTcpNoDelay()

Specified by:

getTcpNoDelay in interface Transport

getSendBufferSize

public int getSendBufferSize()

Specified by:

getSendBufferSize in interface Transport

getReceiveBufferSize

public int getReceiveBufferSize()

Specified by:

getReceiveBufferSize in interface Transport

getNumberOfLocalConnections

public int getNumberOfLocalConnections()

Specified by:

getNumberOfLocalConnections in interface Transport

getNumberOfGlobalConnections

public int getNumberOfGlobalConnections()

Specified by:

getNumberOfGlobalConnections in interface Transport

updateTotalBytesWritten

public void updateTotalBytesWritten(int bytes)

updateTotalBytesRead

public void updateTotalBytesRead(int bytes)