Skip navigation links
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 Clients
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

Copyright © 2017. All rights reserved.