Package akka.remote.artery
Class ArterySettings.Advanced$
- java.lang.Object
-
- akka.remote.artery.ArterySettings.Advanced$
-
- Enclosing class:
- ArterySettings
public class ArterySettings.Advanced$ extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
ArterySettings.Advanced$.Aeron
class
ArterySettings.Advanced$.Aeron$
class
ArterySettings.Advanced$.Tcp
class
ArterySettings.Advanced$.Tcp$
-
Constructor Summary
Constructors Constructor Description Advanced$()
-
Method Summary
-
-
-
Method Detail
-
Aeron
public ArterySettings.Advanced$.Aeron$ Aeron()
-
Tcp
public ArterySettings.Advanced$.Tcp$ Tcp()
-
config
public com.typesafe.config.Config config()
-
TestMode
public boolean TestMode()
-
Dispatcher
public java.lang.String Dispatcher()
-
ControlStreamDispatcher
public java.lang.String ControlStreamDispatcher()
-
MaterializerSettings
public ActorMaterializerSettings MaterializerSettings()
-
ControlStreamMaterializerSettings
public ActorMaterializerSettings ControlStreamMaterializerSettings()
-
OutboundLanes
public int OutboundLanes()
-
InboundLanes
public int InboundLanes()
-
SysMsgBufferSize
public int SysMsgBufferSize()
-
OutboundMessageQueueSize
public int OutboundMessageQueueSize()
-
OutboundControlQueueSize
public int OutboundControlQueueSize()
-
OutboundLargeMessageQueueSize
public int OutboundLargeMessageQueueSize()
-
SystemMessageResendInterval
public scala.concurrent.duration.FiniteDuration SystemMessageResendInterval()
-
HandshakeTimeout
public scala.concurrent.duration.FiniteDuration HandshakeTimeout()
-
HandshakeRetryInterval
public scala.concurrent.duration.FiniteDuration HandshakeRetryInterval()
-
InjectHandshakeInterval
public scala.concurrent.duration.FiniteDuration InjectHandshakeInterval()
-
GiveUpSystemMessageAfter
public scala.concurrent.duration.FiniteDuration GiveUpSystemMessageAfter()
-
StopIdleOutboundAfter
public scala.concurrent.duration.FiniteDuration StopIdleOutboundAfter()
-
QuarantineIdleOutboundAfter
public scala.concurrent.duration.FiniteDuration QuarantineIdleOutboundAfter()
-
StopQuarantinedAfterIdle
public scala.concurrent.duration.FiniteDuration StopQuarantinedAfterIdle()
-
RemoveQuarantinedAssociationAfter
public scala.concurrent.duration.FiniteDuration RemoveQuarantinedAssociationAfter()
-
ShutdownFlushTimeout
public scala.concurrent.duration.FiniteDuration ShutdownFlushTimeout()
-
DeathWatchNotificationFlushTimeout
public scala.concurrent.duration.FiniteDuration DeathWatchNotificationFlushTimeout()
-
InboundRestartTimeout
public scala.concurrent.duration.FiniteDuration InboundRestartTimeout()
-
InboundMaxRestarts
public int InboundMaxRestarts()
-
OutboundRestartBackoff
public scala.concurrent.duration.FiniteDuration OutboundRestartBackoff()
-
OutboundRestartTimeout
public scala.concurrent.duration.FiniteDuration OutboundRestartTimeout()
-
OutboundMaxRestarts
public int OutboundMaxRestarts()
-
Compression
public ArterySettings.Compression Compression()
-
MaximumFrameSize
public final int MaximumFrameSize()
-
BufferPoolSize
public final int BufferPoolSize()
-
InboundHubBufferSize
public final int InboundHubBufferSize()
-
MaximumLargeFrameSize
public final int MaximumLargeFrameSize()
-
LargeBufferPoolSize
public final int LargeBufferPoolSize()
-
-