org.gridgain.grid.kernal.visor.cmd.dto.node

Class VisorDrReceiverHubConfig

java.lang.Object

org.gridgain.grid.kernal.visor.cmd.dto.node.VisorDrReceiverHubConfig

All Implemented Interfaces:

Serializable

public class VisorDrReceiverHubConfig
extends Object
implements Serializable

Data transfer object for DR receiver hub configuration properties.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
VisorDrReceiverHubConfig()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	directBuffer()
void	directBuffer(boolean directBuf)
long	flushFrequency()
void	flushFrequency(long flushFreq)
static VisorDrReceiverHubConfig	from(GridDrReceiverHubConfiguration rcvHubCfg)
long	idleTimeout()
void	idleTimeout(long idleTimeout)
String	localInboundHost()
void	localInboundHost(String locInboundHost)
int	localInboundPort()
void	localInboundPort(int locInboundPort)
int	messageQueueLimit()
void	messageQueueLimit(int msgQueueLimit)
int	perNodeBufferSize()
void	perNodeBufferSize(int perNodeBufSize)
int	perNodeParallelLoadOperations()
void	perNodeParallelLoadOperations(int perNodeParallelLoadOperations)
int	selectorCount()
void	selectorCount(int selectorCnt)
boolean	tcpNodelay()
void	tcpNodelay(boolean tcpNodelay)
String	toString()
int	workerThreads()
void	workerThreads(int workerThreads)
long	writeTimeout()
void	writeTimeout(long writeTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

VisorDrReceiverHubConfig

public VisorDrReceiverHubConfig()

Method Detail

from

public static VisorDrReceiverHubConfig from(GridDrReceiverHubConfiguration rcvHubCfg)

Parameters:

rcvHubCfg - Data center replication receiver hub configuration.

Returns:

Data transfer object for DR receiver hub configuration properties.

localInboundHost

public String localInboundHost()

Returns:

Local host name receiving hub server is bound to.

localInboundHost

public void localInboundHost(String locInboundHost)

Parameters:

locInboundHost - New local host name receiving hub server is bound to.

localInboundPort

public int localInboundPort()

Returns:

Local port receiving hub is bound to.

localInboundPort

public void localInboundPort(int locInboundPort)

Parameters:

locInboundPort - New local port receiving hub is bound to.

selectorCount

public int selectorCount()

Returns:

Number of selector threads in receiver hub's TCP server.

selectorCount

public void selectorCount(int selectorCnt)

Parameters:

selectorCnt - New number of selector threads in receiver hub's TCP server.

workerThreads

public int workerThreads()

Returns:

Number of threads responsible for sender hub requests processing.

workerThreads

public void workerThreads(int workerThreads)

Parameters:

workerThreads - New number of threads responsible for sender hub requests processing.

messageQueueLimit

public int messageQueueLimit()

Returns:

Message queue limit for incoming and outgoing messages.

messageQueueLimit

public void messageQueueLimit(int msgQueueLimit)

Parameters:

msgQueueLimit - New message queue limit for incoming and outgoing messages.

tcpNodelay

public boolean tcpNodelay()

Returns:

Whether to use TCP_NODELAY mode.

tcpNodelay

public void tcpNodelay(boolean tcpNodelay)

Parameters:

tcpNodelay - New whether to use TCP_NODELAY mode.

directBuffer

public boolean directBuffer()

Returns:

Whether to use direct buffer when processing sender hub requests.

directBuffer

public void directBuffer(boolean directBuf)

Parameters:

directBuf - New whether to use direct buffer when processing sender hub requests.

idleTimeout

public long idleTimeout()

Returns:

Idle timeout for sender hub socket connection.

idleTimeout

public void idleTimeout(long idleTimeout)

Parameters:

idleTimeout - New idle timeout for sender hub socket connection.

writeTimeout

public long writeTimeout()

Returns:

Write timeout for sender hub socket connection.

writeTimeout

public void writeTimeout(long writeTimeout)

Parameters:

writeTimeout - New write timeout for sender hub socket connection.

flushFrequency

public long flushFrequency()

Returns:

DR data loader flush frequency.

flushFrequency

public void flushFrequency(long flushFreq)

Parameters:

flushFreq - New dR data loader flush frequency.

perNodeBufferSize

public int perNodeBufferSize()

Returns:

DR data loader per node buffer size.

perNodeBufferSize

public void perNodeBufferSize(int perNodeBufSize)

Parameters:

perNodeBufSize - New dR data loader per node buffer size.

perNodeParallelLoadOperations

public int perNodeParallelLoadOperations()

Returns:

Per node parallel load operations.

perNodeParallelLoadOperations

public void perNodeParallelLoadOperations(int perNodeParallelLoadOperations)

Parameters:

perNodeParallelLoadOperations - New per node parallel load operations.

toString

public String toString()

Overrides:

toString in class Object