Package one.x1f.sip.foundation.core.declarative

Class DeclarationsRegistry

java.lang.Object

one.x1f.sip.foundation.core.declarative.DeclarationsRegistry

All Implemented Interfaces:

DeclarationsRegistryApi

@Service
public final class DeclarationsRegistry
extends Object
implements DeclarationsRegistryApi

Constructor Summary

Constructors

Constructor	Description
DeclarationsRegistry(List<ConnectorGroupDefinition> autowiredConnectorGroups, List<IntegrationScenarioDefinition> autowiredScenarios, List<ConnectorDefinition> autowiredConnectors, List<CompositeProcessDefinition> compositeProcessDefinitions, org.springframework.context.ApplicationContext applicationContext)

Method Summary

Modifier and Type	Method	Description
String	getClassForOnException(org.apache.camel.model.OnExceptionDefinition key)
List<IntegrationScenarioDefinition>	getCompositeProcessConsumerDefinitions(String compositeProcessID)	Returns consumers of the composite process as defined in the annotation CompositeProcess
List<CompositeProcessDefinition>	getCompositeProcessConsumersForScenario(IntegrationScenarioDefinition integrationScenario)	Returns all the processes that are consumers from a scenario.
IntegrationScenarioDefinition	getCompositeProcessProviderDefinition(String compositeProcessID)	Returns provider of the composite process as defined in the annotation CompositeProcess
List<CompositeProcessDefinition>	getCompositeProcessProvidersForScenario(IntegrationScenarioDefinition integrationScenario)	Returns all the processes that are providers for a scenario.
Optional<ConnectorDefinition>	getConnectorById(String connectorId)	Get ConnectorDefinition by its id.
List<IntegrationScenarioConsumerDefinition>	getConsumersForScenario(IntegrationScenarioDefinition integrationScenario)	Returns all the consumers for a scenario, they can be either CompositeProcessDefinition or OutboundConnectorDefinition
List<InboundConnectorDefinition>	getInboundConnectors()	Get list of all InboundConnectorDefinition.
List<InboundConnectorDefinition>	getInboundConnectorsByScenarioId(String scenarioId)	Get list of InboundConnectorDefinition by id of IntegrationScenarioDefinition.
IntegrationScenarioBase	getIntegrationScenarioBase(String compositeProcessID)
List<OutboundConnectorDefinition>	getOutboundConnectors()	Get list of all OutboundConnectorDefinition.
List<OutboundConnectorDefinition>	getOutboundConnectorsByScenarioId(String scenarioId)	Get list of OutboundConnectorDefinition by id of IntegrationScenarioDefinition.
List<IntegrationScenarioProviderDefinition>	getProvidersForScenario(IntegrationScenarioDefinition integrationScenario)	Returns all the providers for a scenario, they can be either CompositeProcessDefinition or InboundConnectorDefinition
IntegrationScenarioDefinition	getScenarioById(String scenarioId)	Get IntegrationScenarioDefinition by its id.
void	registerClassForOnException(org.apache.camel.model.OnExceptionDefinition key, String className)	Registers the class with given className for onException handling

Methods inherited from class java.lang.Object

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

Constructor Details

DeclarationsRegistry

public DeclarationsRegistry(List<ConnectorGroupDefinition> autowiredConnectorGroups,
 List<IntegrationScenarioDefinition> autowiredScenarios,
 List<ConnectorDefinition> autowiredConnectors,
 List<CompositeProcessDefinition> compositeProcessDefinitions,
 org.springframework.context.ApplicationContext applicationContext)

Method Details

getScenarioById

public IntegrationScenarioDefinition getScenarioById(String scenarioId)

Description copied from interface: DeclarationsRegistryApi

Get IntegrationScenarioDefinition by its id.

Specified by:

getScenarioById in interface DeclarationsRegistryApi

Parameters:

scenarioId - is its id

Returns:

Integration scenario

getConnectorById

public Optional<ConnectorDefinition> getConnectorById(String connectorId)

Description copied from interface: DeclarationsRegistryApi

Get ConnectorDefinition by its id.

Specified by:

getConnectorById in interface DeclarationsRegistryApi

Parameters:

connectorId - is its id

Returns:

Optional connector

getInboundConnectors

public List<InboundConnectorDefinition> getInboundConnectors()

Description copied from interface: DeclarationsRegistryApi

Get list of all InboundConnectorDefinition.

Specified by:

getInboundConnectors in interface DeclarationsRegistryApi

Returns:

all inbound connectors

getOutboundConnectors

public List<OutboundConnectorDefinition> getOutboundConnectors()

Description copied from interface: DeclarationsRegistryApi

Get list of all OutboundConnectorDefinition.

Specified by:

getOutboundConnectors in interface DeclarationsRegistryApi

Returns:

all outbound connectors

getInboundConnectorsByScenarioId

public List<InboundConnectorDefinition> getInboundConnectorsByScenarioId(String scenarioId)

Description copied from interface: DeclarationsRegistryApi

Get list of InboundConnectorDefinition by id of IntegrationScenarioDefinition.

Specified by:

getInboundConnectorsByScenarioId in interface DeclarationsRegistryApi

Parameters:

scenarioId - is its id

Returns:

inbound connectors

getOutboundConnectorsByScenarioId

public List<OutboundConnectorDefinition> getOutboundConnectorsByScenarioId(String scenarioId)

Description copied from interface: DeclarationsRegistryApi

Get list of OutboundConnectorDefinition by id of IntegrationScenarioDefinition.

Specified by:

getOutboundConnectorsByScenarioId in interface DeclarationsRegistryApi

Parameters:

scenarioId - is its id

Returns:

outbound connectors

getCompositeProcessConsumerDefinitions

public List<IntegrationScenarioDefinition> getCompositeProcessConsumerDefinitions(String compositeProcessID)

Description copied from interface: DeclarationsRegistryApi

Returns consumers of the composite process as defined in the annotation CompositeProcess

Specified by:

getCompositeProcessConsumerDefinitions in interface DeclarationsRegistryApi

Parameters:

compositeProcessID - id of the process

Returns:

List of IntegrationScenarioDefinition

getCompositeProcessProviderDefinition

public IntegrationScenarioDefinition getCompositeProcessProviderDefinition(String compositeProcessID)

Description copied from interface: DeclarationsRegistryApi

Returns provider of the composite process as defined in the annotation CompositeProcess

Specified by:

getCompositeProcessProviderDefinition in interface DeclarationsRegistryApi

Parameters:

compositeProcessID - id of the process

Returns:

IntegrationScenarioDefinition

getIntegrationScenarioBase

public IntegrationScenarioBase getIntegrationScenarioBase(String compositeProcessID)

Specified by:

getIntegrationScenarioBase in interface DeclarationsRegistryApi

getCompositeProcessProvidersForScenario

public List<CompositeProcessDefinition> getCompositeProcessProvidersForScenario(IntegrationScenarioDefinition integrationScenario)

Description copied from interface: DeclarationsRegistryApi

Returns all the processes that are providers for a scenario.

Specified by:

getCompositeProcessProvidersForScenario in interface DeclarationsRegistryApi

Parameters:

integrationScenario - that the processes provide to

Returns:

List of CompositeProcessDefinition

getCompositeProcessConsumersForScenario

public List<CompositeProcessDefinition> getCompositeProcessConsumersForScenario(IntegrationScenarioDefinition integrationScenario)

Description copied from interface: DeclarationsRegistryApi

Returns all the processes that are consumers from a scenario.

Specified by:

getCompositeProcessConsumersForScenario in interface DeclarationsRegistryApi

Parameters:

integrationScenario - that the processes consumes from

Returns:

List of CompositeProcessDefinition

getProvidersForScenario

public List<IntegrationScenarioProviderDefinition> getProvidersForScenario(IntegrationScenarioDefinition integrationScenario)

Description copied from interface: DeclarationsRegistryApi

Returns all the providers for a scenario, they can be either CompositeProcessDefinition or InboundConnectorDefinition

Specified by:

getProvidersForScenario in interface DeclarationsRegistryApi

Parameters:

integrationScenario - that are being provided to

Returns:

List of IntegrationScenarioProviderDefinition

getConsumersForScenario

public List<IntegrationScenarioConsumerDefinition> getConsumersForScenario(IntegrationScenarioDefinition integrationScenario)

Description copied from interface: DeclarationsRegistryApi

Returns all the consumers for a scenario, they can be either CompositeProcessDefinition or OutboundConnectorDefinition

Specified by:

getConsumersForScenario in interface DeclarationsRegistryApi

Parameters:

integrationScenario - that are being consumed from

Returns:

List of IntegrationScenarioProviderDefinition

registerClassForOnException

public void registerClassForOnException(org.apache.camel.model.OnExceptionDefinition key,
 String className)

Description copied from interface: DeclarationsRegistryApi

Registers the class with given className for onException handling

Specified by:

registerClassForOnException in interface DeclarationsRegistryApi

Parameters:

key - Exception definition key

className - Class to register

getClassForOnException

public String getClassForOnException(org.apache.camel.model.OnExceptionDefinition key)