Class TransportConfig


  • public final class TransportConfig
    extends java.lang.Object
    Configuration used to setup a transport.
    Since:
    v4.2.0 - 2022-07-21
    • Field Detail

      • preConnectCallback

        private java.util.function.Consumer<AbstractTransport> preConnectCallback
      • timeout

        private int timeout
      • autoConnect

        private boolean autoConnect
      • fileOwner

        private java.lang.String fileOwner
        user to set on socket file if this is a server transport (null to do nothing).
      • fileGroup

        private java.lang.String fileGroup
        group to set on socket file if this is a server transport (null to do nothing).
      • fileUnixPermissions

        private java.util.Set<java.nio.file.attribute.PosixFilePermission> fileUnixPermissions
        Unix file permissions to set on socket file if this is a server transport (ignored on Windows, does nothing if null)
      • additionalConfig

        private java.util.Map<java.lang.String,​java.lang.Object> additionalConfig
        Contains additional configuration where no direct getter/setter is available for.
    • Constructor Detail

      • TransportConfig

        public TransportConfig​(BusAddress _address)
      • TransportConfig

        public TransportConfig()
    • Method Detail

      • getBusAddress

        public BusAddress getBusAddress()
      • setBusAddress

        public void setBusAddress​(BusAddress _busAddress)
      • setListening

        public void setListening​(boolean _listen)
      • isListening

        public boolean isListening()
      • getPreConnectCallback

        public java.util.function.Consumer<AbstractTransport> getPreConnectCallback()
      • setPreConnectCallback

        public void setPreConnectCallback​(java.util.function.Consumer<AbstractTransport> _preConnectCallback)
      • isAutoConnect

        public boolean isAutoConnect()
      • setAutoConnect

        public void setAutoConnect​(boolean _autoConnect)
      • getTimeout

        public int getTimeout()
      • setTimeout

        public void setTimeout​(int _timeout)
      • getFileOwner

        public java.lang.String getFileOwner()
      • setFileOwner

        public void setFileOwner​(java.lang.String _fileOwner)
      • getFileGroup

        public java.lang.String getFileGroup()
      • setFileGroup

        public void setFileGroup​(java.lang.String _fileGroup)
      • getFileUnixPermissions

        public java.util.Set<java.nio.file.attribute.PosixFilePermission> getFileUnixPermissions()
      • setFileUnixPermissions

        public void setFileUnixPermissions​(java.nio.file.attribute.PosixFilePermission... _permissions)
      • getAdditionalConfig

        public java.util.Map<java.lang.String,​java.lang.Object> getAdditionalConfig()
      • setAdditionalConfig

        public void setAdditionalConfig​(java.util.Map<java.lang.String,​java.lang.Object> _additionalConfig)
      • getSaslConfig

        public SaslConfig getSaslConfig()
      • updateBusAddress

        void updateBusAddress​(boolean _listening)
        Toggles the busaddress to be a listening (server) or non listening (client) connection.
        Parameters:
        _listening - true to be a server connection