class EventBusOptions extends TCPSSLOptions
Options to configure the event bus.
- Alphabetic
- By Inheritance
- EventBusOptions
- TCPSSLOptions
- NetworkOptions
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new EventBusOptions(_asJava: core.eventbus.EventBusOptions)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
addCrlPath(value: String): EventBusOptions
Add a CRL path
Add a CRL path
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
addCrlValue(value: Buffer): EventBusOptions
Add a CRL value
Add a CRL value
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
addEnabledCipherSuite(value: String): EventBusOptions
Add an enabled cipher suite, appended to the ordered suites.
Add an enabled cipher suite, appended to the ordered suites.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
addEnabledSecureTransportProtocol(value: String): EventBusOptions
Sets the list of enabled SSL/TLS protocols.
Sets the list of enabled SSL/TLS protocols.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJava: core.eventbus.EventBusOptions
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def getAcceptBacklog: Int
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getClientAuth: ClientAuth
- def getClusterPingInterval: Long
- def getClusterPingReplyInterval: Long
- def getClusterPublicHost: String
- def getClusterPublicPort: Int
- def getConnectTimeout: Int
-
def
getCrlPaths: Buffer[String]
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getCrlValues: Buffer[Buffer]
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getEnabledCipherSuites: Set[String]
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getEnabledSecureTransportProtocols: Set[String]
- Definition Classes
- EventBusOptions → TCPSSLOptions
- def getHost: String
-
def
getIdleTimeout: Int
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getIdleTimeoutUnit: TimeUnit
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getJdkSslEngineOptions: JdkSSLEngineOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getKeyStoreOptions: JksOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getLogActivity: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
getOpenSslEngineOptions: OpenSSLEngineOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getPemKeyCertOptions: PemKeyCertOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getPemTrustOptions: PemTrustOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getPfxKeyCertOptions: PfxOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getPfxTrustOptions: PfxOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
- def getPort: Int
-
def
getReceiveBufferSize: Int
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
- def getReconnectAttempts: Int
- def getReconnectInterval: Long
-
def
getSendBufferSize: Int
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
getSoLinger: Int
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
getTrafficClass: Int
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
getTrustStoreOptions: JksOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def isClustered: Boolean
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isReuseAddress: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
isReusePort: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
isSsl: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
isTcpCork: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
isTcpFastOpen: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
isTcpKeepAlive: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
isTcpNoDelay: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
isTcpQuickAck: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
- def isTrustAll: Boolean
-
def
isUseAlpn: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
isUsePooledBuffers: Boolean
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
setAcceptBacklog(value: Int): EventBusOptions
Set the accept back log.
-
def
setClientAuth(value: ClientAuth): EventBusOptions
Set whether client auth is required
-
def
setClusterPingInterval(value: Long): EventBusOptions
Set the value of cluster ping interval, in ms.
-
def
setClusterPingReplyInterval(value: Long): EventBusOptions
Set the value of cluster ping reply interval, in ms.
-
def
setClusterPublicHost(value: String): EventBusOptions
Set the public facing hostname to be used for clustering.
Set the public facing hostname to be used for clustering. Sometimes, e.g. when running on certain clouds, the local address the server listens on for clustering is not the same address that other nodes connect to it at, as the OS / cloud infrastructure does some kind of proxying. If this is the case you can specify a public hostname which is different from the hostname the server listens at.
The default value is null which means use the same as the cluster hostname.
-
def
setClusterPublicPort(value: Int): EventBusOptions
See EventBusOptions for an explanation.
-
def
setClustered(value: Boolean): EventBusOptions
Sets whether or not the event bus is clustered.
-
def
setConnectTimeout(value: Int): EventBusOptions
Sets the connect timeout
-
def
setEnabledSecureTransportProtocols(value: Set[String]): EventBusOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setHost(value: String): EventBusOptions
Sets the host.
-
def
setIdleTimeout(value: Int): EventBusOptions
Set the idle timeout, default time unit is seconds.
Set the idle timeout, default time unit is seconds. Zero means don't timeout. This determines if a connection will timeout and be closed if no data is received within the timeout.
If you want change default time unit, use TCPSSLOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setIdleTimeoutUnit(value: TimeUnit): EventBusOptions
Set the idle timeout unit.
Set the idle timeout unit. If not specified, default is seconds.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setJdkSslEngineOptions(value: JdkSSLEngineOptions): EventBusOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setKeyStoreOptions(value: JksOptions): EventBusOptions
Set the key/cert options in jks format, aka Java keystore.
Set the key/cert options in jks format, aka Java keystore.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setLogActivity(value: Boolean): EventBusOptions
Set to true to enabled network activity logging: Netty's pipeline is configured for logging on Netty's logger.
Set to true to enabled network activity logging: Netty's pipeline is configured for logging on Netty's logger.
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
setOpenSslEngineOptions(value: OpenSSLEngineOptions): EventBusOptions
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setPemKeyCertOptions(value: PemKeyCertOptions): EventBusOptions
Set the key/cert store options in pem format.
Set the key/cert store options in pem format.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setPemTrustOptions(value: PemTrustOptions): EventBusOptions
Set the trust options in pem format
Set the trust options in pem format
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setPfxKeyCertOptions(value: PfxOptions): EventBusOptions
Set the key/cert options in pfx format.
Set the key/cert options in pfx format.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setPfxTrustOptions(value: PfxOptions): EventBusOptions
Set the trust options in pfx format
Set the trust options in pfx format
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setPort(value: Int): EventBusOptions
Sets the port.
-
def
setReceiveBufferSize(value: Int): EventBusOptions
Set the TCP receive buffer size
Set the TCP receive buffer size
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
setReconnectAttempts(value: Int): EventBusOptions
Sets the value of reconnect attempts.
-
def
setReconnectInterval(value: Long): EventBusOptions
Set the reconnect interval.
-
def
setReuseAddress(value: Boolean): EventBusOptions
Set the value of reuse address
Set the value of reuse address
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
setReusePort(value: Boolean): EventBusOptions
Set the value of reuse port.
Set the value of reuse port.
This is only supported by native transports.
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
setSendBufferSize(value: Int): EventBusOptions
Set the TCP send buffer size
Set the TCP send buffer size
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
setSoLinger(value: Int): EventBusOptions
Set whether SO_linger keep alive is enabled
Set whether SO_linger keep alive is enabled
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setSsl(value: Boolean): EventBusOptions
Set whether SSL/TLS is enabled
Set whether SSL/TLS is enabled
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setTcpCork(value: Boolean): EventBusOptions
Enable the
TCP_CORK
option - only with linux native transport.Enable the
TCP_CORK
option - only with linux native transport.- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setTcpFastOpen(value: Boolean): EventBusOptions
Enable the
TCP_FASTOPEN
option - only with linux native transport.Enable the
TCP_FASTOPEN
option - only with linux native transport.- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setTcpKeepAlive(value: Boolean): EventBusOptions
Set whether TCP keep alive is enabled
Set whether TCP keep alive is enabled
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setTcpNoDelay(value: Boolean): EventBusOptions
Set whether TCP no delay is enabled
Set whether TCP no delay is enabled
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setTcpQuickAck(value: Boolean): EventBusOptions
Enable the
TCP_QUICKACK
option - only with linux native transport.Enable the
TCP_QUICKACK
option - only with linux native transport.- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setTrafficClass(value: Int): EventBusOptions
Set the value of traffic class
Set the value of traffic class
- Definition Classes
- EventBusOptions → TCPSSLOptions → NetworkOptions
-
def
setTrustAll(value: Boolean): EventBusOptions
Set whether all server certificates should be trusted.
-
def
setTrustStoreOptions(value: JksOptions): EventBusOptions
Set the trust options in jks format, aka Java truststore
Set the trust options in jks format, aka Java truststore
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setUseAlpn(value: Boolean): EventBusOptions
Set the ALPN usage.
Set the ALPN usage.
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
def
setUsePooledBuffers(value: Boolean): EventBusOptions
Set whether Netty pooled buffers are enabled
Set whether Netty pooled buffers are enabled
- Definition Classes
- EventBusOptions → TCPSSLOptions
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )