2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
6 * Copyright © 2017-2018 Amdocs
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
22 package org.onap.aai.event;
24 import java.io.IOException;
25 import java.io.InputStream;
26 import java.util.Collection;
27 import java.util.List;
29 import java.util.Properties;
30 import java.util.concurrent.ScheduledExecutorService;
31 import java.util.concurrent.TimeUnit;
33 import org.apache.camel.CamelContext;
34 import org.apache.camel.Component;
35 import org.apache.camel.ConsumerTemplate;
36 import org.apache.camel.Endpoint;
37 import org.apache.camel.ErrorHandlerFactory;
38 import org.apache.camel.NoFactoryAvailableException;
39 import org.apache.camel.PollingConsumer;
40 import org.apache.camel.Producer;
41 import org.apache.camel.ProducerTemplate;
42 import org.apache.camel.Route;
43 import org.apache.camel.RoutesBuilder;
44 import org.apache.camel.ServiceStatus;
45 import org.apache.camel.ShutdownRoute;
46 import org.apache.camel.ShutdownRunningTask;
47 import org.apache.camel.StartupListener;
48 import org.apache.camel.TypeConverter;
49 import org.apache.camel.builder.ErrorHandlerBuilder;
50 import org.apache.camel.model.DataFormatDefinition;
51 import org.apache.camel.model.RouteDefinition;
52 import org.apache.camel.model.RoutesDefinition;
53 import org.apache.camel.model.rest.RestDefinition;
54 import org.apache.camel.spi.AsyncProcessorAwaitManager;
55 import org.apache.camel.spi.CamelContextNameStrategy;
56 import org.apache.camel.spi.ClassResolver;
57 import org.apache.camel.spi.DataFormat;
58 import org.apache.camel.spi.DataFormatResolver;
59 import org.apache.camel.spi.Debugger;
60 import org.apache.camel.spi.EndpointRegistry;
61 import org.apache.camel.spi.EndpointStrategy;
62 import org.apache.camel.spi.ExecutorServiceManager;
63 import org.apache.camel.spi.ExecutorServiceStrategy;
64 import org.apache.camel.spi.FactoryFinder;
65 import org.apache.camel.spi.FactoryFinderResolver;
66 import org.apache.camel.spi.InflightRepository;
67 import org.apache.camel.spi.Injector;
68 import org.apache.camel.spi.InterceptStrategy;
69 import org.apache.camel.spi.Language;
70 import org.apache.camel.spi.LifecycleStrategy;
71 import org.apache.camel.spi.ManagementMBeanAssembler;
72 import org.apache.camel.spi.ManagementNameStrategy;
73 import org.apache.camel.spi.ManagementStrategy;
74 import org.apache.camel.spi.ModelJAXBContextFactory;
75 import org.apache.camel.spi.NodeIdFactory;
76 import org.apache.camel.spi.PackageScanClassResolver;
77 import org.apache.camel.spi.ProcessorFactory;
78 import org.apache.camel.spi.Registry;
79 import org.apache.camel.spi.RestConfiguration;
80 import org.apache.camel.spi.RestRegistry;
81 import org.apache.camel.spi.RoutePolicyFactory;
82 import org.apache.camel.spi.RouteStartupOrder;
83 import org.apache.camel.spi.RuntimeEndpointRegistry;
84 import org.apache.camel.spi.ServicePool;
85 import org.apache.camel.spi.ShutdownStrategy;
86 import org.apache.camel.spi.StreamCachingStrategy;
87 import org.apache.camel.spi.TypeConverterRegistry;
88 import org.apache.camel.spi.UnitOfWorkFactory;
89 import org.apache.camel.spi.UuidGenerator;
90 import org.apache.camel.util.LoadPropertiesException;
92 public class TestCamelContext implements CamelContext {
95 public void suspend() throws Exception {
96 // TODO Auto-generated method stub
101 public void resume() throws Exception {
102 // TODO Auto-generated method stub
107 public boolean isSuspended() {
108 // TODO Auto-generated method stub
113 public void setStreamCaching(Boolean cache) {
114 // TODO Auto-generated method stub
119 public Boolean isStreamCaching() {
120 // TODO Auto-generated method stub
125 public void setTracing(Boolean tracing) {
126 // TODO Auto-generated method stub
131 public Boolean isTracing() {
132 // TODO Auto-generated method stub
137 public void setMessageHistory(Boolean messageHistory) {
138 // TODO Auto-generated method stub
143 public Boolean isMessageHistory() {
144 // TODO Auto-generated method stub
149 public void setHandleFault(Boolean handleFault) {
150 // TODO Auto-generated method stub
155 public Boolean isHandleFault() {
156 // TODO Auto-generated method stub
161 public void setDelayer(Long delay) {
162 // TODO Auto-generated method stub
167 public Long getDelayer() {
168 // TODO Auto-generated method stub
173 public void setAutoStartup(Boolean autoStartup) {
174 // TODO Auto-generated method stub
179 public Boolean isAutoStartup() {
180 // TODO Auto-generated method stub
185 public void setShutdownRoute(ShutdownRoute shutdownRoute) {
186 // TODO Auto-generated method stub
191 public ShutdownRoute getShutdownRoute() {
192 // TODO Auto-generated method stub
197 public void setShutdownRunningTask(ShutdownRunningTask shutdownRunningTask) {
198 // TODO Auto-generated method stub
203 public ShutdownRunningTask getShutdownRunningTask() {
204 // TODO Auto-generated method stub
209 public void setAllowUseOriginalMessage(Boolean allowUseOriginalMessage) {
210 // TODO Auto-generated method stub
215 public Boolean isAllowUseOriginalMessage() {
216 // TODO Auto-generated method stub
221 public <T extends CamelContext> T adapt(Class<T> type) {
222 // TODO Auto-generated method stub
227 public void start() throws Exception {
228 // TODO Auto-generated method stub
233 public void stop() throws Exception {
234 // TODO Auto-generated method stub
239 public String getName() {
240 // TODO Auto-generated method stub
245 public CamelContextNameStrategy getNameStrategy() {
246 // TODO Auto-generated method stub
251 public void setNameStrategy(CamelContextNameStrategy nameStrategy) {
252 // TODO Auto-generated method stub
257 public ManagementNameStrategy getManagementNameStrategy() {
258 // TODO Auto-generated method stub
263 public void setManagementNameStrategy(ManagementNameStrategy nameStrategy) {
264 // TODO Auto-generated method stub
269 public String getManagementName() {
270 // TODO Auto-generated method stub
275 public String getVersion() {
276 // TODO Auto-generated method stub
281 public ServiceStatus getStatus() {
282 // TODO Auto-generated method stub
287 public String getUptime() {
288 // TODO Auto-generated method stub
293 public void addService(Object object) throws Exception {
294 // TODO Auto-generated method stub
299 public void addService(Object object, boolean closeOnShutdown) throws Exception {
300 // TODO Auto-generated method stub
305 public boolean removeService(Object object) throws Exception {
306 // TODO Auto-generated method stub
311 public boolean hasService(Object object) {
312 // TODO Auto-generated method stub
317 public <T> T hasService(Class<T> type) {
318 // TODO Auto-generated method stub
323 public void addStartupListener(StartupListener listener) throws Exception {
324 // TODO Auto-generated method stub
329 public void addComponent(String componentName, Component component) {
330 // TODO Auto-generated method stub
335 public Component hasComponent(String componentName) {
336 // TODO Auto-generated method stub
341 public Component getComponent(String componentName) {
342 // TODO Auto-generated method stub
347 public Component getComponent(String name, boolean autoCreateComponents) {
348 // TODO Auto-generated method stub
353 public <T extends Component> T getComponent(String name, Class<T> componentType) {
354 // TODO Auto-generated method stub
359 public List<String> getComponentNames() {
360 // TODO Auto-generated method stub
365 public Component removeComponent(String componentName) {
366 // TODO Auto-generated method stub
371 public EndpointRegistry<String> getEndpointRegistry() {
372 // TODO Auto-generated method stub
377 public Endpoint getEndpoint(String uri) {
378 // TODO Auto-generated method stub
383 public <T extends Endpoint> T getEndpoint(String name, Class<T> endpointType) {
384 // TODO Auto-generated method stub
389 public Collection<Endpoint> getEndpoints() {
390 // TODO Auto-generated method stub
395 public Map<String, Endpoint> getEndpointMap() {
396 // TODO Auto-generated method stub
401 public Endpoint hasEndpoint(String uri) {
402 // TODO Auto-generated method stub
407 public Endpoint addEndpoint(String uri, Endpoint endpoint) throws Exception {
408 // TODO Auto-generated method stub
413 public void removeEndpoint(Endpoint endpoint) throws Exception {
414 // TODO Auto-generated method stub
419 public Collection<Endpoint> removeEndpoints(String pattern) throws Exception {
420 // TODO Auto-generated method stub
425 public void addRegisterEndpointCallback(EndpointStrategy strategy) {
426 // TODO Auto-generated method stub
431 public void setupRoutes(boolean done) {
432 // TODO Auto-generated method stub
437 public List<RouteDefinition> getRouteDefinitions() {
438 // TODO Auto-generated method stub
443 public RouteDefinition getRouteDefinition(String id) {
444 // TODO Auto-generated method stub
449 public List<RestDefinition> getRestDefinitions() {
450 // TODO Auto-generated method stub
455 public void addRestDefinitions(Collection<RestDefinition> restDefinitions) throws Exception {
456 // TODO Auto-generated method stub
461 public void setRestConfiguration(RestConfiguration restConfiguration) {
462 // TODO Auto-generated method stub
467 public RestConfiguration getRestConfiguration() {
468 // TODO Auto-generated method stub
473 public List<RouteStartupOrder> getRouteStartupOrder() {
474 // TODO Auto-generated method stub
479 public List<Route> getRoutes() {
480 // TODO Auto-generated method stub
485 public Route getRoute(String id) {
486 // TODO Auto-generated method stub
491 public void addRoutes(RoutesBuilder builder) throws Exception {
492 // TODO Auto-generated method stub
497 public RoutesDefinition loadRoutesDefinition(InputStream is) throws Exception {
498 // TODO Auto-generated method stub
503 public void addRouteDefinitions(Collection<RouteDefinition> routeDefinitions) throws Exception {
504 // TODO Auto-generated method stub
509 public void addRouteDefinition(RouteDefinition routeDefinition) throws Exception {
510 // TODO Auto-generated method stub
515 public void removeRouteDefinitions(Collection<RouteDefinition> routeDefinitions) throws Exception {
516 // TODO Auto-generated method stub
521 public void removeRouteDefinition(RouteDefinition routeDefinition) throws Exception {
522 // TODO Auto-generated method stub
527 public void startRoute(RouteDefinition route) throws Exception {
528 // TODO Auto-generated method stub
533 public void startAllRoutes() throws Exception {
534 // TODO Auto-generated method stub
539 public void startRoute(String routeId) throws Exception {
540 // TODO Auto-generated method stub
545 public void stopRoute(RouteDefinition route) throws Exception {
546 // TODO Auto-generated method stub
551 public void stopRoute(String routeId) throws Exception {
552 // TODO Auto-generated method stub
557 public void stopRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
558 // TODO Auto-generated method stub
563 public boolean stopRoute(String routeId, long timeout, TimeUnit timeUnit, boolean abortAfterTimeout)
565 // TODO Auto-generated method stub
570 public void shutdownRoute(String routeId) throws Exception {
571 // TODO Auto-generated method stub
576 public void shutdownRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
577 // TODO Auto-generated method stub
582 public boolean removeRoute(String routeId) throws Exception {
583 // TODO Auto-generated method stub
588 public void resumeRoute(String routeId) throws Exception {
589 // TODO Auto-generated method stub
594 public void suspendRoute(String routeId) throws Exception {
595 // TODO Auto-generated method stub
600 public void suspendRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception {
601 // TODO Auto-generated method stub
606 public ServiceStatus getRouteStatus(String routeId) {
607 // TODO Auto-generated method stub
612 public boolean isStartingRoutes() {
613 // TODO Auto-generated method stub
618 public boolean isSetupRoutes() {
619 // TODO Auto-generated method stub
624 public TypeConverter getTypeConverter() {
625 // TODO Auto-generated method stub
630 public TypeConverterRegistry getTypeConverterRegistry() {
631 // TODO Auto-generated method stub
636 public Registry getRegistry() {
637 // TODO Auto-generated method stub
642 public <T> T getRegistry(Class<T> type) {
643 // TODO Auto-generated method stub
648 public Injector getInjector() {
649 // TODO Auto-generated method stub
654 public ManagementMBeanAssembler getManagementMBeanAssembler() {
655 // TODO Auto-generated method stub
660 public List<LifecycleStrategy> getLifecycleStrategies() {
661 // TODO Auto-generated method stub
666 public void addLifecycleStrategy(LifecycleStrategy lifecycleStrategy) {
667 // TODO Auto-generated method stub
672 public Language resolveLanguage(String language) {
673 // TODO Auto-generated method stub
678 public String resolvePropertyPlaceholders(String text) throws Exception {
679 // TODO Auto-generated method stub
684 public String getPropertyPrefixToken() {
685 // TODO Auto-generated method stub
690 public String getPropertySuffixToken() {
691 // TODO Auto-generated method stub
696 public List<String> getLanguageNames() {
697 // TODO Auto-generated method stub
702 public ProducerTemplate createProducerTemplate() {
703 // TODO Auto-generated method stub
708 public ProducerTemplate createProducerTemplate(int maximumCacheSize) {
709 // TODO Auto-generated method stub
714 public ConsumerTemplate createConsumerTemplate() {
715 // TODO Auto-generated method stub
720 public ConsumerTemplate createConsumerTemplate(int maximumCacheSize) {
721 // TODO Auto-generated method stub
726 public void addInterceptStrategy(InterceptStrategy interceptStrategy) {
727 // TODO Auto-generated method stub
732 public List<InterceptStrategy> getInterceptStrategies() {
733 // TODO Auto-generated method stub
738 public ErrorHandlerBuilder getErrorHandlerBuilder() {
739 // TODO Auto-generated method stub
744 public void setErrorHandlerBuilder(ErrorHandlerFactory errorHandlerBuilder) {
745 // TODO Auto-generated method stub
750 public ScheduledExecutorService getErrorHandlerExecutorService() {
751 // TODO Auto-generated method stub
756 public void setDataFormats(Map<String, DataFormatDefinition> dataFormats) {
757 // TODO Auto-generated method stub
762 public Map<String, DataFormatDefinition> getDataFormats() {
763 // TODO Auto-generated method stub
768 public DataFormat resolveDataFormat(String name) {
769 // TODO Auto-generated method stub
774 public DataFormatDefinition resolveDataFormatDefinition(String name) {
775 // TODO Auto-generated method stub
780 public DataFormatResolver getDataFormatResolver() {
781 // TODO Auto-generated method stub
786 public void setDataFormatResolver(DataFormatResolver dataFormatResolver) {
787 // TODO Auto-generated method stub
792 public void setProperties(Map<String, String> properties) {
793 // TODO Auto-generated method stub
798 public Map<String, String> getProperties() {
799 // TODO Auto-generated method stub
804 public String getProperty(String name) {
805 // TODO Auto-generated method stub
810 public FactoryFinder getDefaultFactoryFinder() {
811 // TODO Auto-generated method stub
816 public void setFactoryFinderResolver(FactoryFinderResolver resolver) {
817 // TODO Auto-generated method stub
822 public FactoryFinder getFactoryFinder(String path) throws NoFactoryAvailableException {
823 // TODO Auto-generated method stub
828 public ClassResolver getClassResolver() {
829 // TODO Auto-generated method stub
834 public PackageScanClassResolver getPackageScanClassResolver() {
835 // TODO Auto-generated method stub
840 public void setClassResolver(ClassResolver resolver) {
841 // TODO Auto-generated method stub
846 public void setPackageScanClassResolver(PackageScanClassResolver resolver) {
847 // TODO Auto-generated method stub
852 public void setProducerServicePool(ServicePool<Endpoint, Producer> servicePool) {
853 // TODO Auto-generated method stub
858 public ServicePool<Endpoint, Producer> getProducerServicePool() {
859 // TODO Auto-generated method stub
864 public void setPollingConsumerServicePool(ServicePool<Endpoint, PollingConsumer> servicePool) {
865 // TODO Auto-generated method stub
870 public ServicePool<Endpoint, PollingConsumer> getPollingConsumerServicePool() {
871 // TODO Auto-generated method stub
876 public void setNodeIdFactory(NodeIdFactory factory) {
877 // TODO Auto-generated method stub
882 public NodeIdFactory getNodeIdFactory() {
883 // TODO Auto-generated method stub
888 public ManagementStrategy getManagementStrategy() {
889 // TODO Auto-generated method stub
894 public void setManagementStrategy(ManagementStrategy strategy) {
895 // TODO Auto-generated method stub
900 public InterceptStrategy getDefaultTracer() {
901 // TODO Auto-generated method stub
906 public void setDefaultTracer(InterceptStrategy tracer) {
907 // TODO Auto-generated method stub
912 public InterceptStrategy getDefaultBacklogTracer() {
913 // TODO Auto-generated method stub
918 public void setDefaultBacklogTracer(InterceptStrategy backlogTracer) {
919 // TODO Auto-generated method stub
924 public InterceptStrategy getDefaultBacklogDebugger() {
925 // TODO Auto-generated method stub
930 public void setDefaultBacklogDebugger(InterceptStrategy backlogDebugger) {
931 // TODO Auto-generated method stub
936 public void disableJMX() throws IllegalStateException {
937 // TODO Auto-generated method stub
942 public InflightRepository getInflightRepository() {
943 // TODO Auto-generated method stub
948 public void setInflightRepository(InflightRepository repository) {
949 // TODO Auto-generated method stub
954 public AsyncProcessorAwaitManager getAsyncProcessorAwaitManager() {
955 // TODO Auto-generated method stub
960 public void setAsyncProcessorAwaitManager(AsyncProcessorAwaitManager manager) {
961 // TODO Auto-generated method stub
966 public ClassLoader getApplicationContextClassLoader() {
967 // TODO Auto-generated method stub
972 public void setApplicationContextClassLoader(ClassLoader classLoader) {
973 // TODO Auto-generated method stub
978 public ShutdownStrategy getShutdownStrategy() {
979 // TODO Auto-generated method stub
984 public void setShutdownStrategy(ShutdownStrategy shutdownStrategy) {
985 // TODO Auto-generated method stub
990 public ExecutorServiceManager getExecutorServiceManager() {
991 // TODO Auto-generated method stub
996 public ExecutorServiceStrategy getExecutorServiceStrategy() {
997 // TODO Auto-generated method stub
1002 public void setExecutorServiceManager(ExecutorServiceManager executorServiceManager) {
1003 // TODO Auto-generated method stub
1008 public ProcessorFactory getProcessorFactory() {
1009 // TODO Auto-generated method stub
1014 public void setProcessorFactory(ProcessorFactory processorFactory) {
1015 // TODO Auto-generated method stub
1020 public Debugger getDebugger() {
1021 // TODO Auto-generated method stub
1026 public void setDebugger(Debugger debugger) {
1027 // TODO Auto-generated method stub
1032 public UuidGenerator getUuidGenerator() {
1033 // TODO Auto-generated method stub
1038 public void setUuidGenerator(UuidGenerator uuidGenerator) {
1039 // TODO Auto-generated method stub
1044 public Boolean isLazyLoadTypeConverters() {
1045 // TODO Auto-generated method stub
1050 public void setLazyLoadTypeConverters(Boolean lazyLoadTypeConverters) {
1051 // TODO Auto-generated method stub
1056 public Boolean isTypeConverterStatisticsEnabled() {
1057 // TODO Auto-generated method stub
1062 public void setTypeConverterStatisticsEnabled(Boolean typeConverterStatisticsEnabled) {
1063 // TODO Auto-generated method stub
1068 public Boolean isUseMDCLogging() {
1069 // TODO Auto-generated method stub
1074 public void setUseMDCLogging(Boolean useMDCLogging) {
1075 // TODO Auto-generated method stub
1080 public Boolean isUseBreadcrumb() {
1081 // TODO Auto-generated method stub
1086 public void setUseBreadcrumb(Boolean useBreadcrumb) {
1087 // TODO Auto-generated method stub
1092 public String resolveComponentDefaultName(String javaType) {
1093 // TODO Auto-generated method stub
1098 public Map<String, Properties> findComponents() throws LoadPropertiesException, IOException {
1099 // TODO Auto-generated method stub
1104 public Map<String, Properties> findEips() throws LoadPropertiesException, IOException {
1105 // TODO Auto-generated method stub
1110 public String getComponentDocumentation(String componentName) throws IOException {
1111 // TODO Auto-generated method stub
1116 public String getComponentParameterJsonSchema(String componentName) throws IOException {
1117 // TODO Auto-generated method stub
1122 public String getDataFormatParameterJsonSchema(String dataFormatName) throws IOException {
1123 // TODO Auto-generated method stub
1128 public String getLanguageParameterJsonSchema(String languageName) throws IOException {
1129 // TODO Auto-generated method stub
1134 public String getEipParameterJsonSchema(String eipName) throws IOException {
1135 // TODO Auto-generated method stub
1140 public String explainEipJson(String nameOrId, boolean includeAllOptions) {
1141 // TODO Auto-generated method stub
1146 public String explainComponentJson(String componentName, boolean includeAllOptions) {
1147 // TODO Auto-generated method stub
1152 public String explainEndpointJson(String uri, boolean includeAllOptions) {
1153 // TODO Auto-generated method stub
1158 public String createRouteStaticEndpointJson(String routeId) {
1159 // TODO Auto-generated method stub
1164 public String createRouteStaticEndpointJson(String routeId, boolean includeDynamic) {
1165 // TODO Auto-generated method stub
1170 public StreamCachingStrategy getStreamCachingStrategy() {
1171 // TODO Auto-generated method stub
1176 public void setStreamCachingStrategy(StreamCachingStrategy streamCachingStrategy) {
1177 // TODO Auto-generated method stub
1182 public UnitOfWorkFactory getUnitOfWorkFactory() {
1183 // TODO Auto-generated method stub
1188 public void setUnitOfWorkFactory(UnitOfWorkFactory unitOfWorkFactory) {
1189 // TODO Auto-generated method stub
1194 public RuntimeEndpointRegistry getRuntimeEndpointRegistry() {
1195 // TODO Auto-generated method stub
1200 public void setRuntimeEndpointRegistry(RuntimeEndpointRegistry runtimeEndpointRegistry) {
1201 // TODO Auto-generated method stub
1206 public RestRegistry getRestRegistry() {
1207 // TODO Auto-generated method stub
1212 public void setRestRegistry(RestRegistry restRegistry) {
1213 // TODO Auto-generated method stub
1218 public void addRoutePolicyFactory(RoutePolicyFactory routePolicyFactory) {
1219 // TODO Auto-generated method stub
1224 public List<RoutePolicyFactory> getRoutePolicyFactories() {
1225 // TODO Auto-generated method stub
1230 public ModelJAXBContextFactory getModelJAXBContextFactory() {
1231 // TODO Auto-generated method stub
1236 public void setModelJAXBContextFactory(ModelJAXBContextFactory modelJAXBContextFactory) {
1237 // TODO Auto-generated method stub