JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
A
AbstractApplication
- Class in
org.eclipse.kapua.gateway.client.spi
AbstractApplication(AbstractClient, String, Executor)
- Constructor for class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
AbstractClient
- Class in
org.eclipse.kapua.gateway.client.spi
AbstractClient(ScheduledExecutorService, Set<Module>)
- Constructor for class org.eclipse.kapua.gateway.client.spi.
AbstractClient
AbstractClient.Builder
<
T
extends
AbstractClient.Builder
<
T
>> - Class in
org.eclipse.kapua.gateway.client.spi
AbstractData
- Class in
org.eclipse.kapua.gateway.client.spi
AbstractData(AbstractApplication, Topic)
- Constructor for class org.eclipse.kapua.gateway.client.spi.
AbstractData
accountName(String)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraNamespace.Builder
accountName()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraNamespace.Builder
accountName(String)
- Method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
addMetric(KuraPayloadProto.KuraPayload.Builder, String, Object)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
Application
- Interface in
org.eclipse.kapua.gateway.client
An application is a sub-unit of a client, focused on handling data
Application.Builder
- Interface in
org.eclipse.kapua.gateway.client
applicationAdded(String)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule
applicationAdded(String)
- Method in interface org.eclipse.kapua.gateway.client.
Module
applicationId
- Variable in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
applicationRemoved(String)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule
applicationRemoved(String)
- Method in interface org.eclipse.kapua.gateway.client.
Module
asCallback(CompletableFuture<T>)
- Static method in class org.eclipse.kapua.gateway.client.mqtt.fuse.internal.
Callbacks
B
BinaryPayloadCodec
- Interface in
org.eclipse.kapua.gateway.client
A codec for BLOB based payload transports
broker(String)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
broker(URI)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
broker()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
brokerUrl(String)
- Method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
Buffers
- Class in
org.eclipse.kapua.gateway.client.utils
build()
- Method in interface org.eclipse.kapua.gateway.client.
Application.Builder
build()
- Method in interface org.eclipse.kapua.gateway.client.
Client.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBinaryPayloadCodec.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraNamespace.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.
Payload.Builder
build()
- Method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
buildApplication(String)
- Method in interface org.eclipse.kapua.gateway.client.
Client
Create a new application instance
buildApplication(String)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
buildBody(KuraPayloadProto.KuraPayload.Builder, ByteBuffer)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.kura.
KuraBinaryPayloadCodec.Builder
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.kura.
KuraNamespace.Builder
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient.Builder
builder()
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient.Builder
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient.Builder
builder()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient.Builder
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.
Payload.Builder
Builder()
- Constructor for class org.eclipse.kapua.gateway.client.spi.
AbstractClient.Builder
builder()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient.Builder
buildMetrics(KuraPayloadProto.KuraPayload.Builder, Map<String, ?>)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
Convert plain key value map into a Kura metric structure
Only the supported Kura values types must be used (String, boolean, int, long, float, double, byte[])
C
Callbacks
- Class in
org.eclipse.kapua.gateway.client.mqtt.fuse.internal
checkClosed()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
Client
- Interface in
org.eclipse.kapua.gateway.client
A client connection
Client.Builder
- Interface in
org.eclipse.kapua.gateway.client
clientId(String)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
clientId()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
clientId(String)
- Method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
close()
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient
close()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
close()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
codec(BinaryPayloadCodec)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
codec()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
connect()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
connected()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule
connected()
- Method in interface org.eclipse.kapua.gateway.client.
Module
connected(Runnable)
- Method in interface org.eclipse.kapua.gateway.client.
Transport.TransportEvents
Credentials
- Class in
org.eclipse.kapua.gateway.client
credentials(Credentials.UserAndPassword)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
credentials()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
credentials(Credentials.UserAndPassword)
- Method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
Credentials.UserAndPassword
- Class in
org.eclipse.kapua.gateway.client
customizer(Consumer<B>)
- Method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
D
data(Topic)
- Method in interface org.eclipse.kapua.gateway.client.
Application
Lookup a data controller to an application topic
Data
- Interface in
org.eclipse.kapua.gateway.client
An interface for control data
data(Topic)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttApplication
data(Topic)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
dataTopic(String, String, Topic)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraNamespace
dataTopic(String, String, Topic)
- Method in interface org.eclipse.kapua.gateway.client.mqtt.
MqttNamespace
Render an MQTT topic for the provided data topic
decode(ByteBuffer)
- Method in interface org.eclipse.kapua.gateway.client.
BinaryPayloadCodec
Decode a
Payload
structure from the provided BLOB
decode(ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBinaryPayloadCodec
defaultProviders()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Builder
disconnected()
- Method in interface org.eclipse.kapua.gateway.client.
Module
disconnected(Runnable)
- Method in interface org.eclipse.kapua.gateway.client.
Transport.TransportEvents
E
encode(Payload, ByteBuffer)
- Method in interface org.eclipse.kapua.gateway.client.
BinaryPayloadCodec
Encode a
Payload
structure into a BLOB
encode(Payload, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBinaryPayloadCodec
ensureNotSpecial(String)
- Static method in class org.eclipse.kapua.gateway.client.
Topic
equals(Object)
- Method in class org.eclipse.kapua.gateway.client.
Topic
ErrorHandler
<
X
extends
Throwable
> - Interface in
org.eclipse.kapua.gateway.client
Errors
- Class in
org.eclipse.kapua.gateway.client
errors(ErrorHandler<Y>)
- Method in interface org.eclipse.kapua.gateway.client.
Sender
events(Consumer<Transport.TransportEvents>)
- Method in interface org.eclipse.kapua.gateway.client.
Transport
This method allows to atomically set a state listener using simple runnable.
executor
- Variable in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
extractMetrics(KuraPayloadProto.KuraPayload)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
extractMetrics(List<KuraPayloadProto.KuraPayload.KuraMetric>)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
F
FuseClient
- Class in
org.eclipse.kapua.gateway.client.mqtt.fuse
FuseClient.Builder
- Class in
org.eclipse.kapua.gateway.client.mqtt.fuse
G
getAsString(Map<String, Object>, String)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
getAsString(Map<String, Object>, String, String)
- Static method in class org.eclipse.kapua.gateway.client.kura.internal.
Metrics
getClient()
- Method in interface org.eclipse.kapua.gateway.client.
ModuleContext
getCodec()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
getMqttClientId()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
getPassword()
- Method in class org.eclipse.kapua.gateway.client.
Credentials.UserAndPassword
getPasswordAsString()
- Method in class org.eclipse.kapua.gateway.client.
Credentials.UserAndPassword
getSegments()
- Method in class org.eclipse.kapua.gateway.client.
Topic
getTimestamp()
- Method in class org.eclipse.kapua.gateway.client.
Payload
getUsername()
- Method in class org.eclipse.kapua.gateway.client.
Credentials.UserAndPassword
getValues()
- Method in class org.eclipse.kapua.gateway.client.
Payload
H
handle(BiConsumer<Throwable, Optional<Payload>>)
- Static method in class org.eclipse.kapua.gateway.client.
Errors
handleApplicationClosed(String, AbstractApplication)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
handleConnected()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
handleConnected()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
handleConnected()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
handleConnected()
- Method in class org.eclipse.kapua.gateway.client.utils.
TransportAsync
handleDisconnected()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
handleDisconnected()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
handleDisconnected()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
handleDisconnected()
- Method in class org.eclipse.kapua.gateway.client.utils.
TransportAsync
handleError(Throwable, Optional<Payload>)
- Method in interface org.eclipse.kapua.gateway.client.
ErrorHandler
handleError(Throwable)
- Method in interface org.eclipse.kapua.gateway.client.
MessageErrorHandler
handleMessage(Payload)
- Method in interface org.eclipse.kapua.gateway.client.
MessageHandler
handleMessage(MessageHandler, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttApplication
handleMessage(String, ByteBuffer)
- Method in interface org.eclipse.kapua.gateway.client.mqtt.
MqttMessageHandler
handleMessageArrived(String, Buffer, Callback<Callback<Void>>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient
handleMessageArrived(String, MqttMessage)
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
hashCode()
- Method in class org.eclipse.kapua.gateway.client.
Topic
I
ignore()
- Static method in class org.eclipse.kapua.gateway.client.
Errors
ignore(Throwable, Optional<Payload>)
- Static method in class org.eclipse.kapua.gateway.client.
Errors
initialize(ModuleContext)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule
initialize(ModuleContext)
- Method in interface org.eclipse.kapua.gateway.client.
Module
internalBuildApplication(Application.Builder, String)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
internalCloseApplication(String, Set<Topic>, AbstractApplication)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
internalCreateApplication(Application.Builder, String)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
internalCreateApplication(Application.Builder, String)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
internalSubscribe(Topic, MessageHandler, ErrorHandler<? extends Throwable>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttApplication
internalSubscribe(Topic, MessageHandler, ErrorHandler<? extends Throwable>)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
internalUnsubscribe(String, Collection<Topic>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
internalUnsubscribe(String, Collection<Topic>)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
J
JVM
- Static variable in interface org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Provider
K
KuraBinaryPayloadCodec
- Class in
org.eclipse.kapua.gateway.client.kura
KuraBinaryPayloadCodec.Builder
- Class in
org.eclipse.kapua.gateway.client.kura
KuraBirthCertificateModule
- Class in
org.eclipse.kapua.gateway.client.kura
KuraBirthCertificateModule.Builder
- Class in
org.eclipse.kapua.gateway.client.kura
KuraBirthCertificateModule.Provider
- Interface in
org.eclipse.kapua.gateway.client.kura
KuraMqttProfile
<
B
extends
MqttClient.Builder
<
B
>> - Class in
org.eclipse.kapua.gateway.client.profile.kura
KuraNamespace
- Class in
org.eclipse.kapua.gateway.client.kura
KuraNamespace.Builder
- Class in
org.eclipse.kapua.gateway.client.kura
L
Listeners
- Class in
org.eclipse.kapua.gateway.client.mqtt.paho.internal
M
MessageErrorHandler
- Interface in
org.eclipse.kapua.gateway.client
MessageHandler
- Interface in
org.eclipse.kapua.gateway.client
Metrics
- Class in
org.eclipse.kapua.gateway.client.kura.internal
Module
- Interface in
org.eclipse.kapua.gateway.client
module(Module)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient.Builder
ModuleContext
- Interface in
org.eclipse.kapua.gateway.client
modules()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient.Builder
MqttApplication
- Class in
org.eclipse.kapua.gateway.client.mqtt
MqttApplication(MqttClient, String, Executor)
- Constructor for class org.eclipse.kapua.gateway.client.mqtt.
MqttApplication
MqttClient
- Class in
org.eclipse.kapua.gateway.client.mqtt
MqttClient(ScheduledExecutorService, BinaryPayloadCodec, MqttNamespace, String, Set<Module>)
- Constructor for class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
MqttClient.Builder
<
T
extends
MqttClient.Builder
<
T
>> - Class in
org.eclipse.kapua.gateway.client.mqtt
MqttMessageHandler
- Interface in
org.eclipse.kapua.gateway.client.mqtt
MqttNamespace
- Interface in
org.eclipse.kapua.gateway.client.mqtt
A namespace implementation for MQTT
N
namespace(MqttNamespace)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
namespace()
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient.Builder
newBuilder(String)
- Static method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule
newProfile(Supplier<B>)
- Static method in class org.eclipse.kapua.gateway.client.profile.kura.
KuraMqttProfile
nonEmptyText(String, String)
- Static method in class org.eclipse.kapua.gateway.client.utils.
Strings
notifyAddApplication(String)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
notifyConnected()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
notifyDisconnected()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
notifyRemoveApplication(String)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
O
of(String, Object)
- Static method in class org.eclipse.kapua.gateway.client.
Payload
of(Map<String, Object>)
- Static method in class org.eclipse.kapua.gateway.client.
Payload
of(Instant, String, Object)
- Static method in class org.eclipse.kapua.gateway.client.
Payload
of(Instant, Map<String, Object>)
- Static method in class org.eclipse.kapua.gateway.client.
Payload
of(List<String>)
- Static method in class org.eclipse.kapua.gateway.client.
Topic
of(String, String...)
- Static method in class org.eclipse.kapua.gateway.client.
Topic
org.eclipse.kapua.gateway.client
- package org.eclipse.kapua.gateway.client
Gateway client SDK for Eclipse Kapua™
org.eclipse.kapua.gateway.client.kura
- package org.eclipse.kapua.gateway.client.kura
org.eclipse.kapua.gateway.client.kura.internal
- package org.eclipse.kapua.gateway.client.kura.internal
org.eclipse.kapua.gateway.client.mqtt
- package org.eclipse.kapua.gateway.client.mqtt
Abstract base classes for implementing MQTT based clients
org.eclipse.kapua.gateway.client.mqtt.fuse
- package org.eclipse.kapua.gateway.client.mqtt.fuse
An MQTT based client using FUSE MQTT
org.eclipse.kapua.gateway.client.mqtt.fuse.internal
- package org.eclipse.kapua.gateway.client.mqtt.fuse.internal
org.eclipse.kapua.gateway.client.mqtt.paho
- package org.eclipse.kapua.gateway.client.mqtt.paho
An MQTT based client using Eclipse Paho™
org.eclipse.kapua.gateway.client.mqtt.paho.internal
- package org.eclipse.kapua.gateway.client.mqtt.paho.internal
org.eclipse.kapua.gateway.client.profile.kura
- package org.eclipse.kapua.gateway.client.profile.kura
An Eclipse Kura™ based connection profile
org.eclipse.kapua.gateway.client.spi
- package org.eclipse.kapua.gateway.client.spi
Abstract base classes for implementing
Client
s
org.eclipse.kapua.gateway.client.utils
- package org.eclipse.kapua.gateway.client.utils
Commons base utilities
P
PahoClient
- Class in
org.eclipse.kapua.gateway.client.mqtt.paho
PahoClient.Builder
- Class in
org.eclipse.kapua.gateway.client.mqtt.paho
Payload
- Class in
org.eclipse.kapua.gateway.client
Payload data
Payload.Builder
- Class in
org.eclipse.kapua.gateway.client
persistentProvider(Supplier<MqttClientPersistence>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient.Builder
persistentProvider()
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient.Builder
provideData(Map<String, String>)
- Method in interface org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Provider
provider(KuraBirthCertificateModule.Provider)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Builder
providers(Collection<KuraBirthCertificateModule.Provider>)
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Builder
providers()
- Method in class org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Builder
publish(Topic, Payload)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttApplication
publish(String, Topic, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
publish(String, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
publish(Topic, Payload)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
publishMqtt(String, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient
publishMqtt(String, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
publishMqtt(String, ByteBuffer)
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
put(String, Object)
- Method in class org.eclipse.kapua.gateway.client.
Payload.Builder
R
RUNTIME
- Static variable in interface org.eclipse.kapua.gateway.client.kura.
KuraBirthCertificateModule.Provider
S
send(Payload)
- Method in interface org.eclipse.kapua.gateway.client.
Sender
send(Payload.Builder)
- Method in interface org.eclipse.kapua.gateway.client.
Sender
send(Payload)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractData
Sender
<
X
extends
Throwable
> - Interface in
org.eclipse.kapua.gateway.client
An interface to publish data
split(String)
- Static method in class org.eclipse.kapua.gateway.client.
Topic
state(Consumer<Boolean>)
- Method in interface org.eclipse.kapua.gateway.client.
Transport
Set a state listener
state(Consumer<Boolean>)
- Method in class org.eclipse.kapua.gateway.client.utils.
TransportAsync
stream()
- Method in class org.eclipse.kapua.gateway.client.
Topic
Strings
- Class in
org.eclipse.kapua.gateway.client.utils
subscribe(MessageHandler)
- Method in interface org.eclipse.kapua.gateway.client.
Data
Receive messages on this data topic
subscribe(MessageHandler, ErrorHandler<? extends Throwable>)
- Method in interface org.eclipse.kapua.gateway.client.
Data
Receive messages and handle reception errors on this data topic
subscribe(String, Topic, MqttMessageHandler)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
subscribe(Topic, MessageHandler, ErrorHandler<? extends Throwable>)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
subscribe(MessageHandler, ErrorHandler<? extends Throwable>)
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractData
subscribeMqtt(String, MqttMessageHandler)
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient
subscribeMqtt(String, MqttMessageHandler)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
subscribeMqtt(String, MqttMessageHandler)
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
subscriptions
- Variable in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
T
timestamp()
- Method in class org.eclipse.kapua.gateway.client.
Payload.Builder
timestamp(Instant)
- Method in class org.eclipse.kapua.gateway.client.
Payload.Builder
toByteArray(ByteBuffer)
- Static method in class org.eclipse.kapua.gateway.client.utils.
Buffers
toListener(CompletableFuture<?>)
- Static method in class org.eclipse.kapua.gateway.client.mqtt.paho.internal.
Listeners
Topic
- Class in
org.eclipse.kapua.gateway.client
A topic
toString()
- Method in class org.eclipse.kapua.gateway.client.
Payload
toString()
- Method in class org.eclipse.kapua.gateway.client.
Topic
transport()
- Method in interface org.eclipse.kapua.gateway.client.
Application
Lookup a transport controller
transport()
- Method in interface org.eclipse.kapua.gateway.client.
Client
Get control over the transport
transport
- Variable in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
transport()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractApplication
transport()
- Method in class org.eclipse.kapua.gateway.client.spi.
AbstractClient
Transport
- Interface in
org.eclipse.kapua.gateway.client
A control interface on the underlying client transport
Transport.TransportEvents
- Interface in
org.eclipse.kapua.gateway.client
TransportAsync
- Class in
org.eclipse.kapua.gateway.client.utils
TransportAsync(Executor)
- Constructor for class org.eclipse.kapua.gateway.client.utils.
TransportAsync
U
unsubscribeMqtt(Set<String>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.fuse.
FuseClient
unsubscribeMqtt(Set<String>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.
MqttClient
unsubscribeMqtt(Set<String>)
- Method in class org.eclipse.kapua.gateway.client.mqtt.paho.
PahoClient
userAndPassword(String, String)
- Static method in class org.eclipse.kapua.gateway.client.
Credentials
userAndPassword(String, char[])
- Static method in class org.eclipse.kapua.gateway.client.
Credentials
V
values()
- Method in class org.eclipse.kapua.gateway.client.
Payload.Builder
values(Map<String, Object>)
- Method in class org.eclipse.kapua.gateway.client.
Payload.Builder
W
waitForConnection(Transport)
- Static method in interface org.eclipse.kapua.gateway.client.
Transport
Wait for the connection to be established
wrap(byte[])
- Static method in class org.eclipse.kapua.gateway.client.utils.
Buffers
A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2017. All rights reserved.