org.eclipse.kapua.gateway.client.spi

Class AbstractApplication

java.lang.Object

org.eclipse.kapua.gateway.client.spi.AbstractApplication

All Implemented Interfaces:

AutoCloseable, Application

Direct Known Subclasses:

MqttApplication

public abstract class AbstractApplication
extends Object
implements Application

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.kapua.gateway.client.Application

Application.Builder

Field Summary

Fields

Modifier and Type	Field and Description
protected String	applicationId
protected Set<Topic>	subscriptions
protected TransportAsync	transport

Constructor Summary

Constructors

Constructor and Description
AbstractApplication(AbstractClient client, String applicationId, Executor executor)

Method Summary

Modifier and Type	Method and Description
protected void	checkClosed()
void	close()
abstract AbstractData	data(Topic topic) Lookup a data controller to an application topic
protected void	handleConnected()
protected void	handleDisconnected()
protected abstract CompletionStage<?>	internalSubscribe(Topic topic, MessageHandler handler, ErrorHandler<? extends Throwable> errorHandler)
protected abstract void	publish(Topic topic, Payload payload)
CompletionStage<?>	subscribe(Topic topic, MessageHandler handler, ErrorHandler<? extends Throwable> errorHandler)
Transport	transport() Lookup a transport controller

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

subscriptions

protected final Set<Topic> subscriptions

applicationId

protected final String applicationId

transport

protected final TransportAsync transport

Constructor Detail

AbstractApplication

public AbstractApplication(AbstractClient client,
                           String applicationId,
                           Executor executor)

Method Detail

handleConnected

protected void handleConnected()

handleDisconnected

protected void handleDisconnected()

checkClosed

protected void checkClosed()

transport

public Transport transport()

Description copied from interface: Application

Lookup a transport controller

A transport controller for the client's underlying transport mechanism.

Note: Each application has its own instance and thus can set events handler independent of the root client or other applications.

Specified by:

transport in interface Application

Returns:

the transport controller

data

public abstract AbstractData data(Topic topic)

Description copied from interface: Application

Lookup a data controller to an application topic

Specified by:

data in interface Application

Parameters:

topic - the topic the controller is bound to, must never be null

Returns:

the data controller

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

publish

protected abstract void publish(Topic topic,
                                Payload payload)
                         throws Exception

Throws:

Exception

subscribe

public CompletionStage<?> subscribe(Topic topic,
                                    MessageHandler handler,
                                    ErrorHandler<? extends Throwable> errorHandler)
                             throws Exception

Throws:

Exception

internalSubscribe

protected abstract CompletionStage<?> internalSubscribe(Topic topic,
                                                        MessageHandler handler,
                                                        ErrorHandler<? extends Throwable> errorHandler)
                                                 throws Exception

Throws:

Exception