| Package | Description |
|---|---|
| com.hivemq.spi.message | |
| com.hivemq.spi.services | |
| com.hivemq.spi.services.configuration.entity |
| Modifier and Type | Method and Description |
|---|---|
QoS |
Topic.getQoS() |
static QoS |
QoS.valueOf(int i)
Creates a QoS level enum from an integer
|
| Constructor and Description |
|---|
Topic(String topic,
QoS qoS) |
| Modifier and Type | Method and Description |
|---|---|
ClientData |
BlockingClientService.getClientData(String clientId)
Returns additional client information about a given client with a given client identifier.
|
<T extends com.codahale.metrics.Metric> |
BlockingMetricService.getClusterMetric(HiveMQMetric<T> metric)
Returns a map which contains an entry for every node in the cluster with the given HiveMQ metric.
|
<T extends com.codahale.metrics.Metric> |
MetricService.getHiveMQMetric(HiveMQMetric<T> metric)
Deprecated.
Use
BlockingMetricService or AsyncMetricService instead. |
<T extends com.codahale.metrics.Metric> |
BlockingMetricService.getHiveMQMetric(HiveMQMetric<T> metric)
Returns a specific HiveMQ metric.
|
ClientData |
BlockingClientService.getLocalClientData(String clientId)
Returns client information for clients that are connected to this broker instance.
|
RetainedMessage |
BlockingRetainedMessageStore.getRetainedMessage(String topic) |
| Constructor and Description |
|---|
OptionalAttribute(byte[] value,
boolean replaced) |
| Modifier and Type | Method and Description |
|---|---|
Long |
Tls.getConcurrentHandshakeLimit() |
String |
Tls.getTruststorePassword() |
String |
Tls.getTruststorePath() |
String |
Tls.getTruststoreType() |
| Constructor and Description |
|---|
TcpListener(int port,
String bindAddress,
boolean proxyProtocolSupported,
SocketOptionsProperties socketOptionsProperties,
ConnectOverloadProtectionProperties connectOverloadProtectionProperties,
ClientWriteBufferProperties clientWriteBufferProperties)
Creates a new TCP listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
|
TcpListener(int port,
String bindAddress,
boolean proxyProtocolSupported,
SocketOptionsProperties socketOptionsProperties,
ConnectOverloadProtectionProperties connectOverloadProtectionProperties,
ClientWriteBufferProperties clientWriteBufferProperties)
Creates a new TCP listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
|
TcpListener(int port,
String bindAddress,
boolean proxyProtocolSupported,
SocketOptionsProperties socketOptionsProperties,
ConnectOverloadProtectionProperties connectOverloadProtectionProperties,
ClientWriteBufferProperties clientWriteBufferProperties)
Creates a new TCP listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites,
Long concurrentHandshakeLimit,
boolean nativeSSl,
boolean ocspStaplingEnabled,
String ocspOverrideUrl,
int ocspCacheInterval)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites,
Long concurrentHandshakeLimit,
boolean nativeSSl,
boolean ocspStaplingEnabled,
String ocspOverrideUrl,
int ocspCacheInterval)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites,
Long concurrentHandshakeLimit,
boolean nativeSSl,
boolean ocspStaplingEnabled,
String ocspOverrideUrl,
int ocspCacheInterval)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites,
Long concurrentHandshakeLimit,
boolean nativeSSl,
boolean ocspStaplingEnabled,
String ocspOverrideUrl,
int ocspCacheInterval)
Creates a new TLS configuration
|
Tls(String keystorePath,
String keystorePassword,
String keystoreType,
String privateKeyPassword,
String truststorePath,
String truststorePassword,
String truststoreType,
int handshakeTimeout,
Tls.ClientAuthMode clientAuthMode,
List<String> protocols,
List<String> cipherSuites,
Long concurrentHandshakeLimit,
boolean nativeSSl,
boolean ocspStaplingEnabled,
String ocspOverrideUrl,
int ocspCacheInterval)
Creates a new TLS configuration
|
TlsTcpListener(int port,
String bindAddress,
Tls tls,
boolean proxyProtocolSupported,
SocketOptionsProperties socketOptionsProperties,
ConnectOverloadProtectionProperties connectOverloadProtectionProperties,
ClientWriteBufferProperties clientWriteBufferProperties)
Creates a new TLS Listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
|
TlsTcpListener(int port,
String bindAddress,
Tls tls,
boolean proxyProtocolSupported,
SocketOptionsProperties socketOptionsProperties,
ConnectOverloadProtectionProperties connectOverloadProtectionProperties,
ClientWriteBufferProperties clientWriteBufferProperties)
Creates a new TLS Listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
|
TlsTcpListener(int port,
String bindAddress,
Tls tls,
boolean proxyProtocolSupported,
SocketOptionsProperties socketOptionsProperties,
ConnectOverloadProtectionProperties connectOverloadProtectionProperties,
ClientWriteBufferProperties clientWriteBufferProperties)
Creates a new TLS Listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
|
Copyright © 2013-2018 dc-square GmbH. All Rights Reserved.