Class DXClientAeronContext
- java.lang.Object
-
- deltix.qsrv.hf.tickdb.comm.client.DXClientAeronContext
-
public class DXClientAeronContext extends java.lang.Object
This class contains Aeron-specific client instance bound data. Client context permits restart.
-
-
Field Summary
Fields Modifier and Type Field Description static int
DRIVER_COMMUNICATION_TIMEOUT
static java.lang.String
ENV_VAR_AERON_DIR
static java.lang.String
PROP_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.String
getAeronDirForRemoteServer()
io.aeron.Aeron
getServerSharedAeronInstance(java.lang.String aeronDir)
Get (or initialize) Aeron instance for communication with local server (via IPC or UDP).io.aeron.Aeron
getStandaloneAeronInstance()
Get (or initialize) Aeron instance for communication with remote server (via UDP).DXAeronSubscriptionChecker
getSubscriptionChecker()
boolean
isStarted()
void
reset()
void
setAffinityConfig(deltix.thread.affinity.AffinityConfig affinityConfig)
void
start()
void
stop()
void
stopIfStarted()
-
-
-
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)
-
-