com.diffusiondata.gateway.framework

Enum DiffusionGatewayFramework

java.lang.Object

java.lang.Enum<DiffusionGatewayFramework>

com.diffusiondata.gateway.framework.DiffusionGatewayFramework

All Implemented Interfaces:

Serializable, Comparable<DiffusionGatewayFramework>

public enum DiffusionGatewayFramework
extends Enum<DiffusionGatewayFramework>

Provides static methods for use with the Diffusion Gateway Framework.

For full details of the use of the framework see Package Guide.

Author:

DiffusionData Limited

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DiffusionGatewayFramework.Implementation Do not use - Use static methods on DiffusionGatewayFramework.

Enum Constant Summary

Enum Constants

Enum Constant and Description
IMPLEMENTATION Internal type - do not use.

Method Summary

Modifier and Type	Method and Description
static String	mapDiffusionTopic(String path, String mappingFunction) Delegator for mapDiffusionTopic(String, String).
static GatewayApplication.ApplicationDetails.Builder	newApplicationDetailsBuilder() Factory for an GatewayApplication.ApplicationDetails builder.
static SinkHandler.SinkServiceProperties.Builder	newSinkServicePropertiesBuilder() Factory for builders of SinkHandler.SinkServiceProperties.
static SourceHandler.SourceServiceProperties.Builder	newSourceServicePropertiesBuilder() Factory for builders of SourceHandler.SourceServiceProperties.
static void	shutdown() Shuts down the framework.
static GatewayFramework	start(GatewayApplication application) Called by an application to introduce a gateway framework application implementation and start the framework.
static DiffusionGatewayFramework	valueOf(String name) Returns the enum constant of this type with the specified name.
static DiffusionGatewayFramework[]	values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

IMPLEMENTATION

public static final DiffusionGatewayFramework IMPLEMENTATION

Internal type - do not use.

Method Detail

values

public static DiffusionGatewayFramework[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (DiffusionGatewayFramework c : DiffusionGatewayFramework.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static DiffusionGatewayFramework valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null

start

public static GatewayFramework start(GatewayApplication application)
                              throws ApplicationInitializationException

Called by an application to introduce a gateway framework application implementation and start the framework.

This may only be called once per JVM.

When this is called, the framework will call back on the application to determine its application details and then initialize the application.

Once the application is initialized, the GatewayFramework and the application will be started. During the start of the framework, a connection with the Diffusion server will be established, and service types supported by the application will be registered.

After the connection with the Diffusion server, start will be called on the application.

If the connection with the server fails to establish due to a terminal error, such as an authentication error, the framework will throw the corresponding exception and shut down.

Parameters:

application - the application

Returns:

a reference to the framework

Throws:

ApplicationConfigurationException - if the passed configuration or configuration obtained from the server has been found to be invalid or incompatible with the application;

DiffusionSecurityException - if the application principal does not have sufficient permissions to perform the operation;

DiffusionClientException - if some other exception has been returned from the Diffusion server via the Diffusion Client API. The cause will provide more detail.

ApplicationInitializationException - if the connection with the Diffusion server fails for any other reason or if initialization fails for any reason.

shutdown

public static void shutdown()

Shuts down the framework. Closes the session with Diffusion and terminates any running threads or processes.

However, the instance of DiffusionGatewayFramework created in the JVM will not be removed and will be reused if the application is restarted.

This is mostly useful in tests to explicitly clean up resources in the framework.

This method does not need to be called withing the Gateway application, as shutting the application is managed by the framework.

newApplicationDetailsBuilder

public static GatewayApplication.ApplicationDetails.Builder newApplicationDetailsBuilder()

Factory for an GatewayApplication.ApplicationDetails builder.

Returns:

a new application details builder

newSourceServicePropertiesBuilder

public static SourceHandler.SourceServiceProperties.Builder newSourceServicePropertiesBuilder()

Factory for builders of SourceHandler.SourceServiceProperties.

Returns:

a new source service properties builder

newSinkServicePropertiesBuilder

public static SinkHandler.SinkServiceProperties.Builder newSinkServicePropertiesBuilder()

Factory for builders of SinkHandler.SinkServiceProperties.

Returns:

a new sink service properties builder

mapDiffusionTopic

public static String mapDiffusionTopic(String path,
                                       String mappingFunction)

Delegator for mapDiffusionTopic(String, String).

Parameters:

path - the topic path to map

mappingFunction - the function to use to map the path to

Returns:

the mapped topic path