org.eclipse.kapua.gateway.client.spi

Class AbstractClient

java.lang.Object

org.eclipse.kapua.gateway.client.spi.AbstractClient

All Implemented Interfaces:

AutoCloseable, Client

Direct Known Subclasses:

MqttClient

public abstract class AbstractClient
extends Object
implements Client

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractClient.Builder<T extends AbstractClient.Builder<T>>

Field Summary

Fields

Modifier and Type	Field and Description
protected ScheduledExecutorService	executor

Constructor Summary

Constructors

Constructor and Description
AbstractClient(ScheduledExecutorService executor, Set<Module> modules)

Method Summary

Modifier and Type	Method and Description
Application.Builder	buildApplication(String applicationId) Create a new application instance
protected void	handleApplicationClosed(String applicationId, AbstractApplication application)
protected void	handleConnected()
protected void	handleDisconnected()
protected AbstractApplication	internalBuildApplication(Application.Builder builder, String applicationId)
protected void	internalCloseApplication(String applicationId, Set<Topic> topics, AbstractApplication application)
protected abstract AbstractApplication	internalCreateApplication(Application.Builder builder, String applicationId)
protected abstract void	internalUnsubscribe(String applicationId, Collection<Topic> topics)
protected void	notifyAddApplication(String applicationId)
protected void	notifyConnected()
protected void	notifyDisconnected()
protected void	notifyRemoveApplication(String applicationId)
Transport	transport() Get control over the transport

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

executor

protected final ScheduledExecutorService executor

Constructor Detail

AbstractClient

public AbstractClient(ScheduledExecutorService executor,
                      Set<Module> modules)

Method Detail

transport

public Transport transport()

Description copied from interface: Client

Get control over the transport

Specified by:

transport in interface Client

Returns:

The transport control instance

notifyAddApplication

protected void notifyAddApplication(String applicationId)

notifyRemoveApplication

protected void notifyRemoveApplication(String applicationId)

notifyConnected

protected void notifyConnected()

notifyDisconnected

protected void notifyDisconnected()

handleConnected

protected void handleConnected()

handleDisconnected

protected void handleDisconnected()

buildApplication

public Application.Builder buildApplication(String applicationId)

Description copied from interface: Client

Create a new application instance

This method only returns a new builder which will create a new instance once Application.Builder.build() is called. Before that the application is not built and no resources are claimed.

Application IDs are unique. If an application ID is already allocated it cannot be allocated a second time. The second call to Application.Builder.build() will fail. However this application ID only allocated once the call to Application.Builder.build() succeeded.

Specified by:

buildApplication in interface Client

Parameters:

applicationId - The ID of the application to create

Returns:

the new Application.Builder instance

internalBuildApplication

protected AbstractApplication internalBuildApplication(Application.Builder builder,
                                                       String applicationId)

internalCreateApplication

protected abstract AbstractApplication internalCreateApplication(Application.Builder builder,
                                                                 String applicationId)

internalUnsubscribe

protected abstract void internalUnsubscribe(String applicationId,
                                            Collection<Topic> topics)
                                     throws Exception

Throws:

Exception

internalCloseApplication

protected void internalCloseApplication(String applicationId,
                                        Set<Topic> topics,
                                        AbstractApplication application)

handleApplicationClosed

protected void handleApplicationClosed(String applicationId,
                                       AbstractApplication application)