Class DXClientAeronContext


  • public class DXClientAeronContext
    extends java.lang.Object
    This class contains Aeron-specific client instance bound data. Client context permits restart.
    • 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
    • Constructor Detail

      • DXClientAeronContext

        public DXClientAeronContext​(deltix.thread.affinity.AffinityConfig affinityConfig)
    • 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()
      • setAffinityConfig

        public void setAffinityConfig​(deltix.thread.affinity.AffinityConfig affinityConfig)