| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| * |
| */ |
| package org.apache.streampipes.pe.examples.jvm; |
| |
| import org.apache.streampipes.container.init.DeclarersSingleton; |
| import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter; |
| import org.apache.streampipes.dataformat.json.JsonDataFormatFactory; |
| import org.apache.streampipes.messaging.jms.SpJmsProtocolFactory; |
| import org.apache.streampipes.messaging.kafka.SpKafkaProtocolFactory; |
| import org.apache.streampipes.pe.examples.jvm.config.ExamplesJvmConfig; |
| import org.apache.streampipes.pe.examples.jvm.engine.ExampleExternalEngineController; |
| import org.apache.streampipes.pe.examples.jvm.outputstrategy.AppendOutputController; |
| import org.apache.streampipes.pe.examples.jvm.outputstrategy.CustomOutputController; |
| import org.apache.streampipes.pe.examples.jvm.outputstrategy.CustomTransformOutputController; |
| import org.apache.streampipes.pe.examples.jvm.outputstrategy.FixedOutputController; |
| import org.apache.streampipes.pe.examples.jvm.outputstrategy.KeepOutputController; |
| import org.apache.streampipes.pe.examples.jvm.outputstrategy.TransformOutputController; |
| import org.apache.streampipes.pe.examples.jvm.requirements.NestedListRequirementsController; |
| import org.apache.streampipes.pe.examples.jvm.staticproperty.*; |
| |
| public class ExamplesInit extends StandaloneModelSubmitter { |
| |
| public static void main(String[] args) { |
| DeclarersSingleton |
| .getInstance() |
| .add(new TextParameterExampleController()) |
| .add(new NumberParameterExampleController()) |
| .add(new NumberParameterWithRangeExampleController()) |
| .add(new UnaryMappingPropertyExampleController()) |
| .add(new NaryMappingPropertyExampleController()) |
| .add(new SingleValueSelectionExampleController()) |
| .add(new MultiValueSelectionExampleController()) |
| .add(new CollectionExampleController()) |
| .add(new RuntimeResolvableSingleValue()) |
| .add(new RuntimeResolvableAnyStaticPropertyController()) |
| .add(new StaticPropertyAlternativesController()) |
| .add(new SecretStaticPropertyExampleController()) |
| .add(new CodeInputExampleController()) |
| .add(new ColorPickerExampleController()) |
| .add(new CollectionMappingExample()) |
| .add(new NestedListRequirementsController()) |
| .add(new TwoStreamsMappingExample()) |
| |
| .add(new AppendOutputController()) |
| .add(new CustomOutputController()) |
| .add(new FixedOutputController()) |
| .add(new CustomTransformOutputController()) |
| .add(new TransformOutputController()) |
| .add(new KeepOutputController()) |
| .add(new CollectionMappingGroupExample()) |
| |
| .add(new ExampleExternalEngineController()); |
| |
| DeclarersSingleton.getInstance().registerDataFormat(new JsonDataFormatFactory()); |
| DeclarersSingleton.getInstance().registerProtocol(new SpKafkaProtocolFactory()); |
| DeclarersSingleton.getInstance().registerProtocol(new SpJmsProtocolFactory()); |
| |
| new ExamplesInit().init(ExamplesJvmConfig.INSTANCE); |
| } |
| } |