Upgrading from version 1.x to version 2.0

The getPayloadConvertorName() method in com.diffusiondata.gateway.framework.SourceHandler.SourceServiceProperties has been changed to getPayloadConverterNames(), which returns a list of Strings instead of a single String.

payloadConvertorName(String name) in com.diffusiondata.gateway.framework.SourceHandler.SourceServiceProperties.Builder has been changed to payloadConverter(String name).

The getPayloadConvertorName() method in com.diffusiondata.gateway.framework.SinkHandler.SinkServiceProperties has been changed to getPayloadConverterNames(), which returns a list of Strings instead of a single String.

payloadConvertorName(String name) in com.diffusiondata.gateway.framework.SinkHandler.SinkServiceProperties.Builder has been changed to payloadConverter(String name).

The PayloadConvertor interface has been renamed to PayloadConverter and methods has been changed. See writing payload converter for details on how to implement a PayloadConverter with the changed API.

The InboundPayloadConvertor and OutboundPayloadConvertor interfaces have been removed. So, PayloadConverter interface should be used to implement a payload converter.

com.diffusiondata.gateway.framework.SinkHandler requires a new method valueType().

update method in com.diffusiondata.gateway.framework.SinkHandler has been updated to contain TopicProperties that contains details of the topic from where update is received. This can be used as required or ignored.

The isMetricsEnabled method in GatewayFramework has been moved to ApplicationDefinition.

The getExecutorService method in GatewayFramework has been moved to ApplicationDefinition.

The getParameters() method in ApplicationDefinition has been renamed to getGlobalConfiguration.

The ApplicationDefinition interface has been renamed to ApplicationContext.

The connect method of the GatewayFramework interface has been removed.

The initialize method in DiffusionGatewayFramework has been renamed to start and now returns an instance of GatewayFramework. This method both initializes and starts the application.

The shutdown method of the GatewayFramework interface has been removed. This has been added as a static method in DiffusionGatewayFramework.

Setting topicType in SinkServiceProperties.Builder has been removed, as setting a topic type for Diffusion topic subscription is not required anymore.

Setting consumeJSONSubTypes in SinkServiceProperties.Builder has been removed.

The addSink method in GatewayApplication has been updated to pass Subscriber instance.

The addHybrid method in GatewayApplication has also been updated to pass Subscriber instance.

The option to set the basePath parameter in the topicProperties for the framework configuration of the source service has been removed.

The getGatewayMeterRegistry method has been renamed to initializeGatewayMeterRegistry, which takes a map of global application configuration to initialize the instance of MeterRegistry.

The reportStatus method in the StateHandler is updated to return a CompletableFuture containing the state of the service once the service has completed the state change following a pause or resume based on the supplied status.

Fix the compile errors as defined above.

Remove the META-INF/services folder in resources (if available), as Payload converter instantiation using the Java Service Provider Interface (SPI) mechanism is removed in this release.