org.apache.unomi.router.core.context

Class RouterCamelContext

java.lang.Object

org.apache.unomi.router.core.context.RouterCamelContext

All Implemented Interfaces:

IRouterCamelContext

public class RouterCamelContext
extends Object
implements IRouterCamelContext

Created by amidani on 04/05/2017.

Field Summary

Fields

Modifier and Type	Field and Description
static String	EVENT_ID_EXPORT
static String	EVENT_ID_IMPORT
static String	EVENT_ID_REMOVE

Constructor Summary

Constructors

Constructor and Description
RouterCamelContext()

Method Summary

Modifier and Type	Method and Description
void	destroy()
org.apache.camel.CamelContext	getCamelContext()
void	init()
void	killExistingRoute(String routeId, boolean fireEvent)
void	setAllowedEndpoints(String allowedEndpoints)
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setClusterService(ClusterService clusterService)
void	setConfigSharingService(ConfigSharingService configSharingService)
void	setConfigType(String configType)
void	setExecErrReportSize(String execErrReportSize)
void	setExecHistorySize(String execHistorySize)
void	setExportConfigurationService(ImportExportConfigurationService<ExportConfiguration> exportConfigurationService)
void	setExportRouteCompletionProcessor(ExportRouteCompletionProcessor exportRouteCompletionProcessor)
void	setImportConfigByFileNameProcessor(ImportConfigByFileNameProcessor importConfigByFileNameProcessor)
void	setImportConfigurationService(ImportExportConfigurationService<ImportConfiguration> importConfigurationService)
void	setImportRouteCompletionProcessor(ImportRouteCompletionProcessor importRouteCompletionProcessor)
void	setJacksonDataFormat(org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat)
void	setKafkaProps(Map<String,String> kafkaProps)
void	setPersistenceService(PersistenceService persistenceService)
void	setProfileExportService(ProfileExportService profileExportService)
void	setProfileService(ProfileService profileService)
void	setTracing(boolean tracing)
void	setUnomiStorageProcessor(UnomiStorageProcessor unomiStorageProcessor)
void	setUploadDir(String uploadDir)
void	updateProfileExportReaderRoute(String configId, boolean fireEvent)
void	updateProfileImportReaderRoute(String configId, boolean fireEvent)

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_ID_REMOVE

public static String EVENT_ID_REMOVE

EVENT_ID_IMPORT

public static String EVENT_ID_IMPORT

EVENT_ID_EXPORT

public static String EVENT_ID_EXPORT

Constructor Detail

RouterCamelContext

public RouterCamelContext()

Method Detail

setExecHistorySize

public void setExecHistorySize(String execHistorySize)

setExecErrReportSize

public void setExecErrReportSize(String execErrReportSize)

setBundleContext

public void setBundleContext(org.osgi.framework.BundleContext bundleContext)

setConfigSharingService

public void setConfigSharingService(ConfigSharingService configSharingService)

setClusterService

public void setClusterService(ClusterService clusterService)

setTracing

public void setTracing(boolean tracing)

Specified by:

setTracing in interface IRouterCamelContext

init

public void init()
          throws Exception

Throws:

Exception

destroy

public void destroy()
             throws Exception

Throws:

Exception

killExistingRoute

public void killExistingRoute(String routeId,
                              boolean fireEvent)
                       throws Exception

Specified by:

killExistingRoute in interface IRouterCamelContext

Throws:

Exception

updateProfileImportReaderRoute

public void updateProfileImportReaderRoute(String configId,
                                           boolean fireEvent)
                                    throws Exception

Specified by:

updateProfileImportReaderRoute in interface IRouterCamelContext

Throws:

Exception

updateProfileExportReaderRoute

public void updateProfileExportReaderRoute(String configId,
                                           boolean fireEvent)
                                    throws Exception

Specified by:

updateProfileExportReaderRoute in interface IRouterCamelContext

Throws:

Exception

getCamelContext

public org.apache.camel.CamelContext getCamelContext()

setUnomiStorageProcessor

public void setUnomiStorageProcessor(UnomiStorageProcessor unomiStorageProcessor)

setImportRouteCompletionProcessor

public void setImportRouteCompletionProcessor(ImportRouteCompletionProcessor importRouteCompletionProcessor)

setExportRouteCompletionProcessor

public void setExportRouteCompletionProcessor(ExportRouteCompletionProcessor exportRouteCompletionProcessor)

setImportConfigByFileNameProcessor

public void setImportConfigByFileNameProcessor(ImportConfigByFileNameProcessor importConfigByFileNameProcessor)

setImportConfigurationService

public void setImportConfigurationService(ImportExportConfigurationService<ImportConfiguration> importConfigurationService)

setExportConfigurationService

public void setExportConfigurationService(ImportExportConfigurationService<ExportConfiguration> exportConfigurationService)

setPersistenceService

public void setPersistenceService(PersistenceService persistenceService)

setProfileExportService

public void setProfileExportService(ProfileExportService profileExportService)

setProfileService

public void setProfileService(ProfileService profileService)

setJacksonDataFormat

public void setJacksonDataFormat(org.apache.camel.component.jackson.JacksonDataFormat jacksonDataFormat)

setUploadDir

public void setUploadDir(String uploadDir)

setKafkaProps

public void setKafkaProps(Map<String,String> kafkaProps)

setConfigType

public void setConfigType(String configType)

setAllowedEndpoints

public void setAllowedEndpoints(String allowedEndpoints)