com.diffusiondata.gateway.framework

Interface DiffusionGatewayFramework.Implementation

Enclosing class:

DiffusionGatewayFramework

public static interface DiffusionGatewayFramework.Implementation

Do not use - Use static methods on DiffusionGatewayFramework.

Method Summary

Modifier and Type	Method and Description
String	mapDiffusionTopic(String path, String mappingFunction) Do not use - Use DiffusionGatewayFramework.mapDiffusionTopic(java.lang.String, java.lang.String).
GatewayApplication.ApplicationDetails.Builder	newApplicationDetailsBuilder() Do not use - Use DiffusionGatewayFramework.newApplicationDetailsBuilder().
SinkHandler.SinkServiceProperties.Builder	newSinkServicePropertiesBuilder() Do not use - Use DiffusionGatewayFramework.newSinkServicePropertiesBuilder().
SourceHandler.SourceServiceProperties.Builder	newSourceServicePropertiesBuilder() Do not use - Use DiffusionGatewayFramework.newSourceServicePropertiesBuilder().
CompletableFuture<?>	shutdown() Do not use - Use DiffusionGatewayFramework.shutdown().
GatewayFramework	start(GatewayApplication application) Do not use - Use DiffusionGatewayFramework.start(com.diffusiondata.gateway.framework.GatewayApplication).

Method Detail

start

GatewayFramework start(GatewayApplication application)
                throws ApplicationInitializationException

Do not use - Use DiffusionGatewayFramework.start(com.diffusiondata.gateway.framework.GatewayApplication).

Parameters:

application - the application

Returns:

the framework

Throws:

ApplicationInitializationException

newApplicationDetailsBuilder

GatewayApplication.ApplicationDetails.Builder newApplicationDetailsBuilder()

Do not use - Use DiffusionGatewayFramework.newApplicationDetailsBuilder().

Returns:

new builder

newSourceServicePropertiesBuilder

SourceHandler.SourceServiceProperties.Builder newSourceServicePropertiesBuilder()

Do not use - Use DiffusionGatewayFramework.newSourceServicePropertiesBuilder().

Returns:

new builder

newSinkServicePropertiesBuilder

SinkHandler.SinkServiceProperties.Builder newSinkServicePropertiesBuilder()

Do not use - Use DiffusionGatewayFramework.newSinkServicePropertiesBuilder().

Returns:

new builder

shutdown

CompletableFuture<?> shutdown()

Do not use - Use DiffusionGatewayFramework.shutdown().

Returns:

a CompletableFuture that completes when the application completes shutdown.

mapDiffusionTopic

String mapDiffusionTopic(String path,
                         String mappingFunction)

Do not use - Use DiffusionGatewayFramework.mapDiffusionTopic(java.lang.String, java.lang.String).

Parameters:

path - the topic path to map

mappingFunction - the function to use to map the path to

Returns:

the mapped topic path