org.eclipse.kura.camel.camelcloud

Class DefaultCamelCloudService

java.lang.Object

org.eclipse.kura.camel.camelcloud.DefaultCamelCloudService

All Implemented Interfaces:

CamelCloudService, CloudService

public class DefaultCamelCloudService
extends Object
implements CamelCloudService

A default implementation of the CamelCloudService

Constructor Summary

Constructors

Constructor and Description
DefaultCamelCloudService(org.apache.camel.CamelContext camelContext)

Method Summary

Modifier and Type	Method and Description
void	dispose()
String[]	getCloudApplicationIdentifiers() Returns the application identifiers for which a CloudClient instance was created.
boolean	isConnected() Returns true if the underlying DataService is currently connected to the remote server.
CloudClient	newCloudClient(String applicationId) Returns a new instance of the CloudClient for the given application Id.
void	registerBaseEndpoint(String applicationId, String baseEndpoint)
void	release(String applicationId)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCamelCloudService

public DefaultCamelCloudService(org.apache.camel.CamelContext camelContext)

Method Detail

newCloudClient

public CloudClient newCloudClient(String applicationId)
                           throws KuraException

Description copied from interface: CloudService

Returns a new instance of the CloudClient for the given application Id. The CloudClient is designed to be used by single application bundles. CloudClient instances are acquired from the CloudService and they are released when the work is completed. Generally, a CloudClient is acquired during the activation phase of a bundle and it is released through the CloudClient.release() method during the bundle deactivation phase.
CloudClient will clean-up the subscriptions and the callback registrations when the CloudClient.release() method is called.
If the bundle using the CloudClient relies on subscriptions, it is responsibility of the application to implement the CloudClientListener.onConnectionEstablished() callback method in the CloudCallbackHandler to restore the subscriptions it needs.

Specified by:

newCloudClient in interface CloudService

Parameters:

applicationId - A String object specifying a unique application ID.

Returns:

CloudClient instance

Throws:

KuraException

getCloudApplicationIdentifiers

public String[] getCloudApplicationIdentifiers()

Description copied from interface: CloudService

Returns the application identifiers for which a CloudClient instance was created.

Specified by:

getCloudApplicationIdentifiers in interface CloudService

Returns:

An array of application identifiers

isConnected

public boolean isConnected()

Description copied from interface: CloudService

Returns true if the underlying DataService is currently connected to the remote server.

Specified by:

isConnected in interface CloudService

Returns:

registerBaseEndpoint

public void registerBaseEndpoint(String applicationId,
                                 String baseEndpoint)

Specified by:

registerBaseEndpoint in interface CamelCloudService

release

public void release(String applicationId)

Specified by:

release in interface CamelCloudService

dispose

public void dispose()