Package com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Class MultiSourceSingleFileProcessLogConfig

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.ProcessLogConfig

com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderProcessLogConfig

com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceSingleFileProcessLogConfig

public class MultiSourceSingleFileProcessLogConfig
extends GlobalOrderProcessLogConfig

Since:

8.0.4

Author:

idan

Constructor Summary

Constructors

Constructor	Description
MultiSourceSingleFileProcessLogConfig()

Method Summary

Modifier and Type	Method	Description
double	getHighMemoryUsagePercentage()
long	getPendingPacketPacketsIntervalBeforeConsumption()	Gets the packets interval before consuming a pending packet
int	getPendingPacketsQueueSizeThreshold()
boolean	isMonitorPendingOperationsMemory()
void	setMonitorPendingOperationsMemory(boolean memoryMonitoringEnabled)	Sets whether to enable pending packets queue memory monitoring.
void	setPendingPacketPacketsIntervalBeforeConsumption(long pendingPacketPacketsIntervalBeforeConsumption)	Gets the pending time before consuming a pending packet
void	setPendingPacketsQueueSizeThreshold(int pendingPacketsQueueSizeThreshold)	Sets the pending packets queue size threshold which after memory monitoring will occur.
String	toString()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.ProcessLogConfig

getConsumeTimeout, setConsumeTimeout

Methods inherited from class java.lang.Object

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

Constructor Details

MultiSourceSingleFileProcessLogConfig

public MultiSourceSingleFileProcessLogConfig()

Method Details

getPendingPacketPacketsIntervalBeforeConsumption

public long getPendingPacketPacketsIntervalBeforeConsumption()

Gets the packets interval before consuming a pending packet

setPendingPacketPacketsIntervalBeforeConsumption

public void setPendingPacketPacketsIntervalBeforeConsumption(long pendingPacketPacketsIntervalBeforeConsumption)

Gets the pending time before consuming a pending packet

getPendingPacketsQueueSizeThreshold

public int getPendingPacketsQueueSizeThreshold()

Returns:

Pending packets queue size threshold which after memory monitoring will occur.

setPendingPacketsQueueSizeThreshold

public void setPendingPacketsQueueSizeThreshold(int pendingPacketsQueueSizeThreshold)

Sets the pending packets queue size threshold which after memory monitoring will occur.

getHighMemoryUsagePercentage

public double getHighMemoryUsagePercentage()

Returns:

The memory usage percentage which after a MemoryShortageException will be thrown upon batch receive.

setMonitorPendingOperationsMemory

public void setMonitorPendingOperationsMemory(boolean memoryMonitoringEnabled)

Sets whether to enable pending packets queue memory monitoring.

isMonitorPendingOperationsMemory

public boolean isMonitorPendingOperationsMemory()

Returns:

Whether pending packets queue memory monitoring is enabled.

toString

public String toString()

Overrides:

toString in class GlobalOrderProcessLogConfig