Class DXClientAeronContext
- java.lang.Object
-
- deltix.qsrv.hf.tickdb.comm.client.DXClientAeronContext
-
public class DXClientAeronContext extends java.lang.ObjectThis class contains Aeron-specific client instance bound data. Client context permits restart.
-
-
Field Summary
Fields Modifier and Type Field Description static intDRIVER_COMMUNICATION_TIMEOUTstatic java.lang.StringENV_VAR_AERON_DIRstatic java.lang.StringPROP_NAME_AERON_DIRECTORY
-
Constructor Summary
Constructors Constructor Description DXClientAeronContext(deltix.thread.affinity.AffinityConfig affinityConfig)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static java.lang.StringgetAeronDirForRemoteServer()io.aeron.AerongetServerSharedAeronInstance(java.lang.String aeronDir)Get (or initialize) Aeron instance for communication with local server (via IPC or UDP).io.aeron.AerongetStandaloneAeronInstance()Get (or initialize) Aeron instance for communication with remote server (via UDP).DXAeronSubscriptionCheckergetSubscriptionChecker()booleanisStarted()voidreset()voidsetAffinityConfig(deltix.thread.affinity.AffinityConfig affinityConfig)voidstart()voidstop()voidstopIfStarted()
-
-
-
Field Detail
-
PROP_NAME_AERON_DIRECTORY
public static final java.lang.String PROP_NAME_AERON_DIRECTORY
- See Also:
- Constant Field Values
-
ENV_VAR_AERON_DIR
public static final java.lang.String ENV_VAR_AERON_DIR
- See Also:
- Constant Field Values
-
DRIVER_COMMUNICATION_TIMEOUT
public static final int DRIVER_COMMUNICATION_TIMEOUT
-
-
Method Detail
-
getAeronDirForRemoteServer
public static java.lang.String getAeronDirForRemoteServer()
-
start
public void start()
-
getServerSharedAeronInstance
@Nonnull public io.aeron.Aeron getServerSharedAeronInstance(@Nonnull java.lang.String aeronDir)Get (or initialize) Aeron instance for communication with local server (via IPC or UDP). Note: this can be used only if client and server on same machine.- Parameters:
aeronDir- aeron work directory, shared with server
-
getStandaloneAeronInstance
@Nonnull public io.aeron.Aeron getStandaloneAeronInstance()
Get (or initialize) Aeron instance for communication with remote server (via UDP). Note: this should be used only if client and server on separate machines. Note: Aeron driver must be launched externally
-
reset
public void reset()
-
stop
public void stop()
-
stopIfStarted
public void stopIfStarted()
-
isStarted
public boolean isStarted()
-
getSubscriptionChecker
@Nonnull public DXAeronSubscriptionChecker getSubscriptionChecker()
-
setAffinityConfig
public void setAffinityConfig(deltix.thread.affinity.AffinityConfig affinityConfig)
-
-