| /** |
| * ******************************************************************************* |
| * Copyright (c) 2020 Agence spatiale canadienne / Canadian Space Agency |
| * All rights reserved. This program and the accompanying materials |
| * are made available under the terms of the Eclipse Public License v1.0 |
| * which accompanies this distribution, and is available at |
| * http://www.eclipse.org/legal/epl-v10.html |
| * |
| * Contributors: |
| * Pierre Allard - initial API and implementation |
| * |
| * SPDX-License-Identifier: EPL-1.0 |
| * ******************************************************************************* |
| */ |
| package org.eclipse.apogy.addons.mqtt.impl; |
| |
| import java.util.HashMap; |
| import java.util.List; |
| |
| import javax.net.SocketFactory; |
| |
| import org.eclipse.apogy.addons.mqtt.ApogyAddonsMQTTFacade; |
| import org.eclipse.apogy.addons.mqtt.ApogyAddonsMQTTFactory; |
| import org.eclipse.apogy.addons.mqtt.ApogyAddonsMQTTPackage; |
| import org.eclipse.apogy.addons.mqtt.ApogyMQTTRegistry; |
| import org.eclipse.apogy.addons.mqtt.MQTTBrokerConnectionInfo; |
| import org.eclipse.apogy.addons.mqtt.MQTTBrokerConnectionInfoRegistry; |
| import org.eclipse.apogy.addons.mqtt.MQTTClient; |
| import org.eclipse.apogy.addons.mqtt.MQTTClientConnectionOptions; |
| import org.eclipse.apogy.addons.mqtt.MQTTClientState; |
| import org.eclipse.apogy.addons.mqtt.MQTTTopic; |
| import org.eclipse.apogy.addons.mqtt.MQTTTopicState; |
| import org.eclipse.apogy.addons.mqtt.QualityOfService; |
| import org.eclipse.apogy.addons.mqtt.SimpleSSLMQTTClientConnectionOptions; |
| |
| import org.eclipse.apogy.common.emf.ApogyCommonEMFPackage; |
| |
| import org.eclipse.emf.ecore.EAttribute; |
| import org.eclipse.emf.ecore.EClass; |
| import org.eclipse.emf.ecore.EDataType; |
| import org.eclipse.emf.ecore.EEnum; |
| import org.eclipse.emf.ecore.EGenericType; |
| import org.eclipse.emf.ecore.EOperation; |
| import org.eclipse.emf.ecore.EPackage; |
| import org.eclipse.emf.ecore.EReference; |
| import org.eclipse.emf.ecore.EcorePackage; |
| |
| import org.eclipse.emf.ecore.impl.EPackageImpl; |
| |
| import org.eclipse.paho.client.mqttv3.MqttCallback; |
| import org.eclipse.paho.client.mqttv3.MqttConnectOptions; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * An implementation of the model <b>Package</b>. |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| public class ApogyAddonsMQTTPackageImpl extends EPackageImpl implements ApogyAddonsMQTTPackage { |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass mqttClientEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass mqttClientConnectionOptionsEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass mqttBrokerConnectionInfoEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass mqttBrokerConnectionInfoRegistryEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass simpleSSLMQTTClientConnectionOptionsEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass mqttTopicEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass apogyAddonsMQTTFacadeEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EClass apogyMQTTRegistryEClass = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EEnum qualityOfServiceEEnum = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EEnum mqttClientStateEEnum = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EEnum mqttTopicStateEEnum = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType exceptionEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType hashMapEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType listEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType stringArrayEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType integerArrayEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType mqttCallbackEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType mqttConnectOptionsEDataType = null; |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private EDataType socketFactoryEDataType = null; |
| |
| /** |
| * Creates an instance of the model <b>Package</b>, registered with |
| * {@link org.eclipse.emf.ecore.EPackage.Registry EPackage.Registry} by the package |
| * package URI value. |
| * <p>Note: the correct way to create the package is via the static |
| * factory method {@link #init init()}, which also performs |
| * initialization of the package, or returns the registered package, |
| * if one already exists. |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @see org.eclipse.emf.ecore.EPackage.Registry |
| * @see org.eclipse.apogy.addons.mqtt.ApogyAddonsMQTTPackage#eNS_URI |
| * @see #init() |
| * @generated |
| */ |
| private ApogyAddonsMQTTPackageImpl() { |
| super(eNS_URI, ApogyAddonsMQTTFactory.eINSTANCE); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private static boolean isInited = false; |
| |
| /** |
| * Creates, registers, and initializes the <b>Package</b> for this model, and for any others upon which it depends. |
| * |
| * <p>This method is used to initialize {@link ApogyAddonsMQTTPackage#eINSTANCE} when that field is accessed. |
| * Clients should not invoke it directly. Instead, they should simply access that field to obtain the package. |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @see #eNS_URI |
| * @see #createPackageContents() |
| * @see #initializePackageContents() |
| * @generated |
| */ |
| public static ApogyAddonsMQTTPackage init() { |
| if (isInited) return (ApogyAddonsMQTTPackage)EPackage.Registry.INSTANCE.getEPackage(ApogyAddonsMQTTPackage.eNS_URI); |
| |
| // Obtain or create and register package |
| Object registeredApogyAddonsMQTTPackage = EPackage.Registry.INSTANCE.get(eNS_URI); |
| ApogyAddonsMQTTPackageImpl theApogyAddonsMQTTPackage = registeredApogyAddonsMQTTPackage instanceof ApogyAddonsMQTTPackageImpl ? (ApogyAddonsMQTTPackageImpl)registeredApogyAddonsMQTTPackage : new ApogyAddonsMQTTPackageImpl(); |
| |
| isInited = true; |
| |
| // Initialize simple dependencies |
| ApogyCommonEMFPackage.eINSTANCE.eClass(); |
| EcorePackage.eINSTANCE.eClass(); |
| |
| // Create package meta-data objects |
| theApogyAddonsMQTTPackage.createPackageContents(); |
| |
| // Initialize created meta-data |
| theApogyAddonsMQTTPackage.initializePackageContents(); |
| |
| // Mark meta-data to indicate it can't be changed |
| theApogyAddonsMQTTPackage.freeze(); |
| |
| // Update the registry and return the package |
| EPackage.Registry.INSTANCE.put(ApogyAddonsMQTTPackage.eNS_URI, theApogyAddonsMQTTPackage); |
| return theApogyAddonsMQTTPackage; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getMQTTClient() { |
| return mqttClientEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClient_Verbose() { |
| return (EAttribute)mqttClientEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClient_BrokerHostName() { |
| return (EAttribute)mqttClientEClass.getEStructuralFeatures().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClient_Port() { |
| return (EAttribute)mqttClientEClass.getEStructuralFeatures().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClient_EnableServerAutomaticReconnect() { |
| return (EAttribute)mqttClientEClass.getEStructuralFeatures().get(3); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClient_State() { |
| return (EAttribute)mqttClientEClass.getEStructuralFeatures().get(4); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClient_ClientId() { |
| return (EAttribute)mqttClientEClass.getEStructuralFeatures().get(5); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EReference getMQTTClient_ConnectionOptions() { |
| return (EReference)mqttClientEClass.getEStructuralFeatures().get(6); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EReference getMQTTClient_SubscribedTopics() { |
| return (EReference)mqttClientEClass.getEStructuralFeatures().get(7); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTClient__Start() { |
| return mqttClientEClass.getEOperations().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTClient__Stop() { |
| return mqttClientEClass.getEOperations().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTClient__Subscribe__MQTTTopic() { |
| return mqttClientEClass.getEOperations().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTClient__Unsubscribe__MQTTTopic() { |
| return mqttClientEClass.getEOperations().get(3); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTClient__Publish__MQTTTopic_String() { |
| return mqttClientEClass.getEOperations().get(4); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getMQTTClientConnectionOptions() { |
| return mqttClientConnectionOptionsEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_UserName() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_Password() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_KeepAliveInterval() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_MaxInFlight() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(3); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_ConnectionTimeout() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(4); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_CleanSession() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(5); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTClientConnectionOptions_AutomaticReconnect() { |
| return (EAttribute)mqttClientConnectionOptionsEClass.getEStructuralFeatures().get(6); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTClientConnectionOptions__AsMqttConnectOptions() { |
| return mqttClientConnectionOptionsEClass.getEOperations().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getMQTTBrokerConnectionInfo() { |
| return mqttBrokerConnectionInfoEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_Valid() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_RequireValidation() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_BrokerHostName() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_Port() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(3); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_UserName() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(4); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_Password() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(5); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTBrokerConnectionInfo_UseSystemUserName() { |
| return (EAttribute)mqttBrokerConnectionInfoEClass.getEStructuralFeatures().get(6); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTBrokerConnectionInfo__GetUserPassword() { |
| return mqttBrokerConnectionInfoEClass.getEOperations().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTBrokerConnectionInfo__GetEffectiveUserName() { |
| return mqttBrokerConnectionInfoEClass.getEOperations().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTBrokerConnectionInfo__Validate() { |
| return mqttBrokerConnectionInfoEClass.getEOperations().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getMQTTBrokerConnectionInfoRegistry() { |
| return mqttBrokerConnectionInfoRegistryEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EReference getMQTTBrokerConnectionInfoRegistry_BrokersConnnectionInfo() { |
| return (EReference)mqttBrokerConnectionInfoRegistryEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getMQTTBrokerConnectionInfoRegistry__GetMQTTBrokerConnectionInfoByName__String() { |
| return mqttBrokerConnectionInfoRegistryEClass.getEOperations().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getSimpleSSLMQTTClientConnectionOptions() { |
| return simpleSSLMQTTClientConnectionOptionsEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getSimpleSSLMQTTClientConnectionOptions_KeyStoreFilePathURL() { |
| return (EAttribute)simpleSSLMQTTClientConnectionOptionsEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getSimpleSSLMQTTClientConnectionOptions_KeyStorePassword() { |
| return (EAttribute)simpleSSLMQTTClientConnectionOptionsEClass.getEStructuralFeatures().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getSimpleSSLMQTTClientConnectionOptions__CreateSocketFactory() { |
| return simpleSSLMQTTClientConnectionOptionsEClass.getEOperations().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getMQTTTopic() { |
| return mqttTopicEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTTopic_TopicName() { |
| return (EAttribute)mqttTopicEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTTopic_QualityOfService() { |
| return (EAttribute)mqttTopicEClass.getEStructuralFeatures().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTTopic_ExpectedUpdatePeriod() { |
| return (EAttribute)mqttTopicEClass.getEStructuralFeatures().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTTopic_CallBack() { |
| return (EAttribute)mqttTopicEClass.getEStructuralFeatures().get(3); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EAttribute getMQTTTopic_State() { |
| return (EAttribute)mqttTopicEClass.getEStructuralFeatures().get(4); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getApogyAddonsMQTTFacade() { |
| return apogyAddonsMQTTFacadeEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTClient__String_String_int_List() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTClient__String_String_int_List_String_String() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(1); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTClient__String_String_int_List_MQTTClientConnectionOptions() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(2); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTTopic__String_QualityOfService_MqttCallback() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(3); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTTopic__String_QualityOfService_MqttCallback_long() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(4); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTClientConnectionOptions__String_String() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(5); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateSimpleSSLMQTTClientConnectionOptions__String_String_String_String() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(6); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateMQTTClientConnectionOptions__String_String_boolean_boolean() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(7); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__CreateSimpleSSLMQTTClientConnectionOptions__String_String_boolean_boolean_String_String() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(8); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__GetTopicsNames__List() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(9); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EOperation getApogyAddonsMQTTFacade__GetTopicsQualityOfService__List() { |
| return apogyAddonsMQTTFacadeEClass.getEOperations().get(10); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EClass getApogyMQTTRegistry() { |
| return apogyMQTTRegistryEClass; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EReference getApogyMQTTRegistry_ClientList() { |
| return (EReference)apogyMQTTRegistryEClass.getEStructuralFeatures().get(0); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EEnum getQualityOfService() { |
| return qualityOfServiceEEnum; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EEnum getMQTTClientState() { |
| return mqttClientStateEEnum; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EEnum getMQTTTopicState() { |
| return mqttTopicStateEEnum; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getException() { |
| return exceptionEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getHashMap() { |
| return hashMapEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getList() { |
| return listEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getStringArray() { |
| return stringArrayEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getIntegerArray() { |
| return integerArrayEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getMqttCallback() { |
| return mqttCallbackEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getMqttConnectOptions() { |
| return mqttConnectOptionsEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public EDataType getSocketFactory() { |
| return socketFactoryEDataType; |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| @Override |
| public ApogyAddonsMQTTFactory getApogyAddonsMQTTFactory() { |
| return (ApogyAddonsMQTTFactory)getEFactoryInstance(); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private boolean isCreated = false; |
| |
| /** |
| * Creates the meta-model objects for the package. This method is |
| * guarded to have no affect on any invocation but its first. |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| public void createPackageContents() { |
| if (isCreated) return; |
| isCreated = true; |
| |
| // Create classes and their features |
| mqttClientEClass = createEClass(MQTT_CLIENT); |
| createEAttribute(mqttClientEClass, MQTT_CLIENT__VERBOSE); |
| createEAttribute(mqttClientEClass, MQTT_CLIENT__BROKER_HOST_NAME); |
| createEAttribute(mqttClientEClass, MQTT_CLIENT__PORT); |
| createEAttribute(mqttClientEClass, MQTT_CLIENT__ENABLE_SERVER_AUTOMATIC_RECONNECT); |
| createEAttribute(mqttClientEClass, MQTT_CLIENT__STATE); |
| createEAttribute(mqttClientEClass, MQTT_CLIENT__CLIENT_ID); |
| createEReference(mqttClientEClass, MQTT_CLIENT__CONNECTION_OPTIONS); |
| createEReference(mqttClientEClass, MQTT_CLIENT__SUBSCRIBED_TOPICS); |
| createEOperation(mqttClientEClass, MQTT_CLIENT___START); |
| createEOperation(mqttClientEClass, MQTT_CLIENT___STOP); |
| createEOperation(mqttClientEClass, MQTT_CLIENT___SUBSCRIBE__MQTTTOPIC); |
| createEOperation(mqttClientEClass, MQTT_CLIENT___UNSUBSCRIBE__MQTTTOPIC); |
| createEOperation(mqttClientEClass, MQTT_CLIENT___PUBLISH__MQTTTOPIC_STRING); |
| |
| mqttClientConnectionOptionsEClass = createEClass(MQTT_CLIENT_CONNECTION_OPTIONS); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__USER_NAME); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__PASSWORD); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__KEEP_ALIVE_INTERVAL); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__MAX_IN_FLIGHT); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__CONNECTION_TIMEOUT); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__CLEAN_SESSION); |
| createEAttribute(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS__AUTOMATIC_RECONNECT); |
| createEOperation(mqttClientConnectionOptionsEClass, MQTT_CLIENT_CONNECTION_OPTIONS___AS_MQTT_CONNECT_OPTIONS); |
| |
| mqttBrokerConnectionInfoEClass = createEClass(MQTT_BROKER_CONNECTION_INFO); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__VALID); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__REQUIRE_VALIDATION); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__BROKER_HOST_NAME); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__PORT); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__USER_NAME); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__PASSWORD); |
| createEAttribute(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO__USE_SYSTEM_USER_NAME); |
| createEOperation(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO___GET_USER_PASSWORD); |
| createEOperation(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO___GET_EFFECTIVE_USER_NAME); |
| createEOperation(mqttBrokerConnectionInfoEClass, MQTT_BROKER_CONNECTION_INFO___VALIDATE); |
| |
| mqttBrokerConnectionInfoRegistryEClass = createEClass(MQTT_BROKER_CONNECTION_INFO_REGISTRY); |
| createEReference(mqttBrokerConnectionInfoRegistryEClass, MQTT_BROKER_CONNECTION_INFO_REGISTRY__BROKERS_CONNNECTION_INFO); |
| createEOperation(mqttBrokerConnectionInfoRegistryEClass, MQTT_BROKER_CONNECTION_INFO_REGISTRY___GET_MQTT_BROKER_CONNECTION_INFO_BY_NAME__STRING); |
| |
| simpleSSLMQTTClientConnectionOptionsEClass = createEClass(SIMPLE_SSLMQTT_CLIENT_CONNECTION_OPTIONS); |
| createEAttribute(simpleSSLMQTTClientConnectionOptionsEClass, SIMPLE_SSLMQTT_CLIENT_CONNECTION_OPTIONS__KEY_STORE_FILE_PATH_URL); |
| createEAttribute(simpleSSLMQTTClientConnectionOptionsEClass, SIMPLE_SSLMQTT_CLIENT_CONNECTION_OPTIONS__KEY_STORE_PASSWORD); |
| createEOperation(simpleSSLMQTTClientConnectionOptionsEClass, SIMPLE_SSLMQTT_CLIENT_CONNECTION_OPTIONS___CREATE_SOCKET_FACTORY); |
| |
| mqttTopicEClass = createEClass(MQTT_TOPIC); |
| createEAttribute(mqttTopicEClass, MQTT_TOPIC__TOPIC_NAME); |
| createEAttribute(mqttTopicEClass, MQTT_TOPIC__QUALITY_OF_SERVICE); |
| createEAttribute(mqttTopicEClass, MQTT_TOPIC__EXPECTED_UPDATE_PERIOD); |
| createEAttribute(mqttTopicEClass, MQTT_TOPIC__CALL_BACK); |
| createEAttribute(mqttTopicEClass, MQTT_TOPIC__STATE); |
| |
| apogyAddonsMQTTFacadeEClass = createEClass(APOGY_ADDONS_MQTT_FACADE); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_CLIENT__STRING_STRING_INT_LIST); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_CLIENT__STRING_STRING_INT_LIST_STRING_STRING); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_CLIENT__STRING_STRING_INT_LIST_MQTTCLIENTCONNECTIONOPTIONS); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_TOPIC__STRING_QUALITYOFSERVICE_MQTTCALLBACK); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_TOPIC__STRING_QUALITYOFSERVICE_MQTTCALLBACK_LONG); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_CLIENT_CONNECTION_OPTIONS__STRING_STRING); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_SIMPLE_SSLMQTT_CLIENT_CONNECTION_OPTIONS__STRING_STRING_STRING_STRING); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_MQTT_CLIENT_CONNECTION_OPTIONS__STRING_STRING_BOOLEAN_BOOLEAN); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___CREATE_SIMPLE_SSLMQTT_CLIENT_CONNECTION_OPTIONS__STRING_STRING_BOOLEAN_BOOLEAN_STRING_STRING); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___GET_TOPICS_NAMES__LIST); |
| createEOperation(apogyAddonsMQTTFacadeEClass, APOGY_ADDONS_MQTT_FACADE___GET_TOPICS_QUALITY_OF_SERVICE__LIST); |
| |
| apogyMQTTRegistryEClass = createEClass(APOGY_MQTT_REGISTRY); |
| createEReference(apogyMQTTRegistryEClass, APOGY_MQTT_REGISTRY__CLIENT_LIST); |
| |
| // Create enums |
| qualityOfServiceEEnum = createEEnum(QUALITY_OF_SERVICE); |
| mqttClientStateEEnum = createEEnum(MQTT_CLIENT_STATE); |
| mqttTopicStateEEnum = createEEnum(MQTT_TOPIC_STATE); |
| |
| // Create data types |
| exceptionEDataType = createEDataType(EXCEPTION); |
| hashMapEDataType = createEDataType(HASH_MAP); |
| listEDataType = createEDataType(LIST); |
| stringArrayEDataType = createEDataType(STRING_ARRAY); |
| integerArrayEDataType = createEDataType(INTEGER_ARRAY); |
| mqttCallbackEDataType = createEDataType(MQTT_CALLBACK); |
| mqttConnectOptionsEDataType = createEDataType(MQTT_CONNECT_OPTIONS); |
| socketFactoryEDataType = createEDataType(SOCKET_FACTORY); |
| } |
| |
| /** |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| private boolean isInitialized = false; |
| |
| /** |
| * Complete the initialization of the package and its meta-model. This |
| * method is guarded to have no affect on any invocation but its first. |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| public void initializePackageContents() { |
| if (isInitialized) return; |
| isInitialized = true; |
| |
| // Initialize package |
| setName(eNAME); |
| setNsPrefix(eNS_PREFIX); |
| setNsURI(eNS_URI); |
| |
| // Obtain other dependent packages |
| ApogyCommonEMFPackage theApogyCommonEMFPackage = (ApogyCommonEMFPackage)EPackage.Registry.INSTANCE.getEPackage(ApogyCommonEMFPackage.eNS_URI); |
| EcorePackage theEcorePackage = (EcorePackage)EPackage.Registry.INSTANCE.getEPackage(EcorePackage.eNS_URI); |
| |
| // Create type parameters |
| addETypeParameter(hashMapEDataType, "Key"); |
| addETypeParameter(hashMapEDataType, "Value"); |
| addETypeParameter(listEDataType, "T"); |
| |
| // Set bounds for type parameters |
| |
| // Add supertypes to classes |
| mqttClientEClass.getESuperTypes().add(theApogyCommonEMFPackage.getNamed()); |
| mqttBrokerConnectionInfoEClass.getESuperTypes().add(theApogyCommonEMFPackage.getNamedDescribedElement()); |
| simpleSSLMQTTClientConnectionOptionsEClass.getESuperTypes().add(this.getMQTTClientConnectionOptions()); |
| |
| // Initialize classes, features, and operations; add parameters |
| initEClass(mqttClientEClass, MQTTClient.class, "MQTTClient", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEAttribute(getMQTTClient_Verbose(), theEcorePackage.getEBoolean(), "verbose", "false", 0, 1, MQTTClient.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClient_BrokerHostName(), theEcorePackage.getEString(), "brokerHostName", null, 0, 1, MQTTClient.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClient_Port(), theEcorePackage.getEInt(), "port", "1883", 0, 1, MQTTClient.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClient_EnableServerAutomaticReconnect(), theEcorePackage.getEBoolean(), "enableServerAutomaticReconnect", "true", 0, 1, MQTTClient.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClient_State(), this.getMQTTClientState(), "state", "Not Connected", 0, 1, MQTTClient.class, IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClient_ClientId(), theEcorePackage.getEString(), "clientId", null, 0, 1, MQTTClient.class, IS_TRANSIENT, !IS_VOLATILE, !IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEReference(getMQTTClient_ConnectionOptions(), this.getMQTTClientConnectionOptions(), null, "connectionOptions", null, 0, 1, MQTTClient.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, IS_COMPOSITE, !IS_RESOLVE_PROXIES, !IS_UNSETTABLE, IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEReference(getMQTTClient_SubscribedTopics(), this.getMQTTTopic(), null, "subscribedTopics", null, 0, -1, MQTTClient.class, IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_COMPOSITE, IS_RESOLVE_PROXIES, !IS_UNSETTABLE, IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| initEOperation(getMQTTClient__Start(), null, "start", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEOperation(getMQTTClient__Stop(), null, "stop", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| EOperation op = initEOperation(getMQTTClient__Subscribe__MQTTTopic(), null, "subscribe", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getMQTTTopic(), "topic", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getMQTTClient__Unsubscribe__MQTTTopic(), null, "unsubscribe", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getMQTTTopic(), "topic", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getMQTTClient__Publish__MQTTTopic_String(), null, "publish", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getMQTTTopic(), "topic", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "message", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEException(op, this.getException()); |
| |
| initEClass(mqttClientConnectionOptionsEClass, MQTTClientConnectionOptions.class, "MQTTClientConnectionOptions", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEAttribute(getMQTTClientConnectionOptions_UserName(), theEcorePackage.getEString(), "userName", null, 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClientConnectionOptions_Password(), theEcorePackage.getEString(), "password", null, 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClientConnectionOptions_KeepAliveInterval(), theEcorePackage.getEInt(), "keepAliveInterval", "60", 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClientConnectionOptions_MaxInFlight(), theEcorePackage.getEInt(), "maxInFlight", "10", 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClientConnectionOptions_ConnectionTimeout(), theEcorePackage.getEInt(), "connectionTimeout", "30", 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClientConnectionOptions_CleanSession(), theEcorePackage.getEBoolean(), "cleanSession", "true", 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTClientConnectionOptions_AutomaticReconnect(), theEcorePackage.getEBoolean(), "automaticReconnect", "true", 0, 1, MQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| initEOperation(getMQTTClientConnectionOptions__AsMqttConnectOptions(), this.getMqttConnectOptions(), "asMqttConnectOptions", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEClass(mqttBrokerConnectionInfoEClass, MQTTBrokerConnectionInfo.class, "MQTTBrokerConnectionInfo", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEAttribute(getMQTTBrokerConnectionInfo_Valid(), theEcorePackage.getEBoolean(), "valid", "false", 0, 1, MQTTBrokerConnectionInfo.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTBrokerConnectionInfo_RequireValidation(), theEcorePackage.getEBoolean(), "requireValidation", "true", 0, 1, MQTTBrokerConnectionInfo.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTBrokerConnectionInfo_BrokerHostName(), theEcorePackage.getEString(), "brokerHostName", null, 0, 1, MQTTBrokerConnectionInfo.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTBrokerConnectionInfo_Port(), theEcorePackage.getEInt(), "port", null, 0, 1, MQTTBrokerConnectionInfo.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTBrokerConnectionInfo_UserName(), theEcorePackage.getEString(), "userName", null, 0, 1, MQTTBrokerConnectionInfo.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTBrokerConnectionInfo_Password(), theEcorePackage.getEString(), "password", null, 0, 1, MQTTBrokerConnectionInfo.class, IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTBrokerConnectionInfo_UseSystemUserName(), theEcorePackage.getEBoolean(), "useSystemUserName", "false", 0, 1, MQTTBrokerConnectionInfo.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| initEOperation(getMQTTBrokerConnectionInfo__GetUserPassword(), theEcorePackage.getEString(), "getUserPassword", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEOperation(getMQTTBrokerConnectionInfo__GetEffectiveUserName(), theEcorePackage.getEString(), "getEffectiveUserName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEOperation(getMQTTBrokerConnectionInfo__Validate(), theEcorePackage.getEBoolean(), "validate", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEClass(mqttBrokerConnectionInfoRegistryEClass, MQTTBrokerConnectionInfoRegistry.class, "MQTTBrokerConnectionInfoRegistry", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEReference(getMQTTBrokerConnectionInfoRegistry_BrokersConnnectionInfo(), this.getMQTTBrokerConnectionInfo(), null, "brokersConnnectionInfo", null, 0, -1, MQTTBrokerConnectionInfoRegistry.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, IS_COMPOSITE, !IS_RESOLVE_PROXIES, !IS_UNSETTABLE, IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| op = initEOperation(getMQTTBrokerConnectionInfoRegistry__GetMQTTBrokerConnectionInfoByName__String(), this.getMQTTBrokerConnectionInfo(), "getMQTTBrokerConnectionInfoByName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "name", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEClass(simpleSSLMQTTClientConnectionOptionsEClass, SimpleSSLMQTTClientConnectionOptions.class, "SimpleSSLMQTTClientConnectionOptions", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEAttribute(getSimpleSSLMQTTClientConnectionOptions_KeyStoreFilePathURL(), theEcorePackage.getEString(), "keyStoreFilePathURL", null, 0, 1, SimpleSSLMQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getSimpleSSLMQTTClientConnectionOptions_KeyStorePassword(), theEcorePackage.getEString(), "keyStorePassword", null, 0, 1, SimpleSSLMQTTClientConnectionOptions.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| op = initEOperation(getSimpleSSLMQTTClientConnectionOptions__CreateSocketFactory(), this.getSocketFactory(), "createSocketFactory", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEException(op, this.getException()); |
| |
| initEClass(mqttTopicEClass, MQTTTopic.class, "MQTTTopic", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEAttribute(getMQTTTopic_TopicName(), theEcorePackage.getEString(), "topicName", null, 0, 1, MQTTTopic.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTTopic_QualityOfService(), this.getQualityOfService(), "qualityOfService", "At least once", 0, 1, MQTTTopic.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTTopic_ExpectedUpdatePeriod(), theEcorePackage.getELong(), "expectedUpdatePeriod", "-1", 0, 1, MQTTTopic.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTTopic_CallBack(), this.getMqttCallback(), "callBack", null, 0, 1, MQTTTopic.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| initEAttribute(getMQTTTopic_State(), this.getMQTTTopicState(), "state", "Not Initialized", 0, 1, MQTTTopic.class, !IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_UNSETTABLE, !IS_ID, !IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| initEClass(apogyAddonsMQTTFacadeEClass, ApogyAddonsMQTTFacade.class, "ApogyAddonsMQTTFacade", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTClient__String_String_int_List(), this.getMQTTClient(), "createMQTTClient", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "name", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "brokerHostName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEInt(), "port", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| EGenericType g1 = createEGenericType(this.getList()); |
| EGenericType g2 = createEGenericType(this.getMQTTTopic()); |
| g1.getETypeArguments().add(g2); |
| addEParameter(op, g1, "topics", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTClient__String_String_int_List_String_String(), this.getMQTTClient(), "createMQTTClient", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "name", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "brokerHostName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEInt(), "port", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| g1 = createEGenericType(this.getList()); |
| g2 = createEGenericType(this.getMQTTTopic()); |
| g1.getETypeArguments().add(g2); |
| addEParameter(op, g1, "topics", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "username", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "password", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTClient__String_String_int_List_MQTTClientConnectionOptions(), this.getMQTTClient(), "createMQTTClient", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "name", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "brokerHostName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEInt(), "port", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| g1 = createEGenericType(this.getList()); |
| g2 = createEGenericType(this.getMQTTTopic()); |
| g1.getETypeArguments().add(g2); |
| addEParameter(op, g1, "topics", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getMQTTClientConnectionOptions(), "connectionOptions", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTTopic__String_QualityOfService_MqttCallback(), this.getMQTTTopic(), "createMQTTTopic", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "topicName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getQualityOfService(), "qualityOfService", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getMqttCallback(), "callBack", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTTopic__String_QualityOfService_MqttCallback_long(), this.getMQTTTopic(), "createMQTTTopic", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "topicName", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getQualityOfService(), "qualityOfService", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, this.getMqttCallback(), "callBack", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getELong(), "expectedUpdatePeriod", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTClientConnectionOptions__String_String(), this.getMQTTClientConnectionOptions(), "createMQTTClientConnectionOptions", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "username", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "password", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateSimpleSSLMQTTClientConnectionOptions__String_String_String_String(), this.getSimpleSSLMQTTClientConnectionOptions(), "createSimpleSSLMQTTClientConnectionOptions", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "username", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "password", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "keyStoreFilePathURL", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "keyStorePassword", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateMQTTClientConnectionOptions__String_String_boolean_boolean(), this.getMQTTClientConnectionOptions(), "createMQTTClientConnectionOptions", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "username", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "password", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEBoolean(), "cleanSession", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEBoolean(), "automaticReconnect", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__CreateSimpleSSLMQTTClientConnectionOptions__String_String_boolean_boolean_String_String(), this.getSimpleSSLMQTTClientConnectionOptions(), "createSimpleSSLMQTTClientConnectionOptions", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "username", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "password", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEBoolean(), "cleanSession", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEBoolean(), "automaticReconnect", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "keyStoreFilePathURL", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| addEParameter(op, theEcorePackage.getEString(), "keyStorePassword", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__GetTopicsNames__List(), this.getStringArray(), "getTopicsNames", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| g1 = createEGenericType(this.getList()); |
| g2 = createEGenericType(this.getMQTTTopic()); |
| g1.getETypeArguments().add(g2); |
| addEParameter(op, g1, "topics", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| op = initEOperation(getApogyAddonsMQTTFacade__GetTopicsQualityOfService__List(), this.getIntegerArray(), "getTopicsQualityOfService", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| g1 = createEGenericType(this.getList()); |
| g2 = createEGenericType(this.getMQTTTopic()); |
| g1.getETypeArguments().add(g2); |
| addEParameter(op, g1, "topics", 0, 1, !IS_UNIQUE, IS_ORDERED); |
| |
| initEClass(apogyMQTTRegistryEClass, ApogyMQTTRegistry.class, "ApogyMQTTRegistry", !IS_ABSTRACT, !IS_INTERFACE, IS_GENERATED_INSTANCE_CLASS); |
| initEReference(getApogyMQTTRegistry_ClientList(), this.getMQTTClient(), null, "clientList", null, 0, -1, ApogyMQTTRegistry.class, IS_TRANSIENT, !IS_VOLATILE, IS_CHANGEABLE, !IS_COMPOSITE, IS_RESOLVE_PROXIES, !IS_UNSETTABLE, IS_UNIQUE, !IS_DERIVED, IS_ORDERED); |
| |
| // Initialize enums and add enum literals |
| initEEnum(qualityOfServiceEEnum, QualityOfService.class, "QualityOfService"); |
| addEEnumLiteral(qualityOfServiceEEnum, QualityOfService.QOS_0); |
| addEEnumLiteral(qualityOfServiceEEnum, QualityOfService.QOS_1); |
| addEEnumLiteral(qualityOfServiceEEnum, QualityOfService.QOS_2); |
| |
| initEEnum(mqttClientStateEEnum, MQTTClientState.class, "MQTTClientState"); |
| addEEnumLiteral(mqttClientStateEEnum, MQTTClientState.NOT_CONNECTED); |
| addEEnumLiteral(mqttClientStateEEnum, MQTTClientState.CONNECTING); |
| addEEnumLiteral(mqttClientStateEEnum, MQTTClientState.CONNECTED); |
| addEEnumLiteral(mqttClientStateEEnum, MQTTClientState.FAILED); |
| |
| initEEnum(mqttTopicStateEEnum, MQTTTopicState.class, "MQTTTopicState"); |
| addEEnumLiteral(mqttTopicStateEEnum, MQTTTopicState.NOT_INITIALIZED); |
| addEEnumLiteral(mqttTopicStateEEnum, MQTTTopicState.INITIALIZING); |
| addEEnumLiteral(mqttTopicStateEEnum, MQTTTopicState.READY); |
| addEEnumLiteral(mqttTopicStateEEnum, MQTTTopicState.STOPPED); |
| addEEnumLiteral(mqttTopicStateEEnum, MQTTTopicState.FAILED); |
| addEEnumLiteral(mqttTopicStateEEnum, MQTTTopicState.STALLED); |
| |
| // Initialize data types |
| initEDataType(exceptionEDataType, Exception.class, "Exception", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(hashMapEDataType, HashMap.class, "HashMap", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(listEDataType, List.class, "List", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(stringArrayEDataType, String[].class, "StringArray", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(integerArrayEDataType, int[].class, "IntegerArray", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(mqttCallbackEDataType, MqttCallback.class, "MqttCallback", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(mqttConnectOptionsEDataType, MqttConnectOptions.class, "MqttConnectOptions", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| initEDataType(socketFactoryEDataType, SocketFactory.class, "SocketFactory", IS_SERIALIZABLE, !IS_GENERATED_INSTANCE_CLASS); |
| |
| // Create resource |
| createResource(eNS_URI); |
| |
| // Create annotations |
| // http://www.eclipse.org/emf/2002/GenModel |
| createGenModelAnnotations(); |
| // http://www.eclipse.org/apogy |
| createApogyAnnotations(); |
| } |
| |
| /** |
| * Initializes the annotations for <b>http://www.eclipse.org/emf/2002/GenModel</b>. |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| protected void createGenModelAnnotations() { |
| String source = "http://www.eclipse.org/emf/2002/GenModel"; |
| addAnnotation |
| (this, |
| source, |
| new String[] { |
| "prefix", "ApogyAddonsMQTT", |
| "modelName", "ApogyAddonsMQTT", |
| "operationReflection", "true", |
| "childCreationExtenders", "true", |
| "extensibleProviderFactory", "true", |
| "multipleEditorPages", "false", |
| "copyrightText", "*******************************************************************************\nCopyright (c) 2020 Agence spatiale canadienne / Canadian Space Agency \nAll rights reserved. This program and the accompanying materials\nare made available under the terms of the Eclipse Public License v1.0\nwhich accompanies this distribution, and is available at\nhttp://www.eclipse.org/legal/epl-v10.html\n\nContributors:\n Pierre Allard - initial API and implementation \n \nSPDX-License-Identifier: EPL-1.0 \n*******************************************************************************", |
| "suppressGenModelAnnotations", "false", |
| "dynamicTemplates", "true", |
| "templateDirectory", "platform:/plugin/org.eclipse.apogy.common.emf.codegen/templates", |
| "modelDirectory", "/org.eclipse.apogy.addons.mqtt/src-gen", |
| "editDirectory", "/org.eclipse.apogy.addons.mqtt.edit/src-gen", |
| "basePackage", "org.eclipse.apogy.addons" |
| }); |
| addAnnotation |
| (mqttClientEClass, |
| source, |
| new String[] { |
| "documentation", "*\nDefines a MQTT Node which is used to interface to a MQTT Broker." |
| }); |
| addAnnotation |
| (getMQTTClient__Start(), |
| source, |
| new String[] { |
| "documentation", "*\nStarts the MQTT node" |
| }); |
| addAnnotation |
| (getMQTTClient__Stop(), |
| source, |
| new String[] { |
| "documentation", "*\nStops the MQTT node" |
| }); |
| addAnnotation |
| (getMQTTClient__Subscribe__MQTTTopic(), |
| source, |
| new String[] { |
| "documentation", "*\nSubscribe to a specified topic\n@param topic The specified topic." |
| }); |
| addAnnotation |
| (getMQTTClient__Unsubscribe__MQTTTopic(), |
| source, |
| new String[] { |
| "documentation", "*\nUn-subscribe from a specified topic\n@param topic The specified topic." |
| }); |
| addAnnotation |
| (getMQTTClient__Publish__MQTTTopic_String(), |
| source, |
| new String[] { |
| "documentation", "*\nPublish a string on a specified topic.\n@param topic The topic on which to publish.\n@param message The content of the message." |
| }); |
| addAnnotation |
| (getMQTTClient_Verbose(), |
| source, |
| new String[] { |
| "documentation", "*\nWhether or not to log info and warning messages." |
| }); |
| addAnnotation |
| (getMQTTClient_BrokerHostName(), |
| source, |
| new String[] { |
| "documentation", "*\nName of the Broker\'s Host." |
| }); |
| addAnnotation |
| (getMQTTClient_Port(), |
| source, |
| new String[] { |
| "documentation", "*\nPort on which to connect to broker" |
| }); |
| addAnnotation |
| (getMQTTClient_EnableServerAutomaticReconnect(), |
| source, |
| new String[] { |
| "documentation", "*\nEnables auto-reconnection to a server that disconnects." |
| }); |
| addAnnotation |
| (getMQTTClient_State(), |
| source, |
| new String[] { |
| "documentation", "*\nConnection state of the client", |
| "property", "Readonly" |
| }); |
| addAnnotation |
| (getMQTTClient_ClientId(), |
| source, |
| new String[] { |
| "documentation", "*\nClient Id, automatically generated." |
| }); |
| addAnnotation |
| (getMQTTClient_ConnectionOptions(), |
| source, |
| new String[] { |
| "documentation", "*\nConnection options." |
| }); |
| addAnnotation |
| (getMQTTClient_SubscribedTopics(), |
| source, |
| new String[] { |
| "documentation", "*\nTopics to which the client is subscribed." |
| }); |
| addAnnotation |
| (mqttClientConnectionOptionsEClass, |
| source, |
| new String[] { |
| "documentation", "*\nHolds the set of options that control how the client connects to a MQTT server." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions__AsMqttConnectOptions(), |
| source, |
| new String[] { |
| "documentation", "*\nConverts the MQTTClientConnectionOptions to MQTT equivalent." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_UserName(), |
| source, |
| new String[] { |
| "documentation", "*\nUser name required to connect to broker." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_Password(), |
| source, |
| new String[] { |
| "documentation", "*\nPassword required to connect to broker." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_KeepAliveInterval(), |
| source, |
| new String[] { |
| "documentation", "*\nSets the \"keep alive\" interval. This value, measured in seconds, defines the maximum time interval between messages\nsent or received. It enables the client to detect if the server is no longer available, without having to wait for\nthe TCP/IP timeout. The client will ensure that at least one message travels across the network within each keep\nalive period. In the absence of a data-related message during the time period, the client sends a very small \"ping\"\nmessage, which the server will acknowledge. A value of 0 disables keepalive processing in the client." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_MaxInFlight(), |
| source, |
| new String[] { |
| "documentation", "*\nThe max inflight limits to how many messages we can send without receiving acknowledgments. Please increase\nthis value in a high traffic environment." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_ConnectionTimeout(), |
| source, |
| new String[] { |
| "documentation", "*\nConnection timeout. This value, measured in seconds, defines the maximum time interval the client will wait for\nthe network connection to the MQTT server to be established. The default timeout is 30 seconds. A value of 0\ndisables timeout processing meaning the client will wait until the network connection is made successfully or fails." |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_CleanSession(), |
| source, |
| new String[] { |
| "documentation", "*\nSets whether the client and server should remember state across restarts and reconnects.\nIf set to false both the client and server will maintain state across restarts of the client, the server and the connection. As state is maintained:\n Message delivery will be reliable meeting the specified QOS even if the client, server or connection are restarted.\n The server will treat a subscription as durable.\nIf set to true the client and server will not maintain state across restarts of the client, the server or the connection. This means\nMessage delivery to the specified QOS cannot be maintained if the client, server or connection are restarted\nThe server will treat a subscription as non-durable" |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_AutomaticReconnect(), |
| source, |
| new String[] { |
| "documentation", "*\nSets whether the client will automatically attempt to reconnect to the server if the connection is lost.\nIf set to false, the client will not attempt to automatically reconnect to the server in the event that the connection is lost.\n\tIf set to true, in the event that the connection is lost, the client will attempt to reconnect to the server. It will initially\nwait 1 second before it attempts to reconnect, for every failed reconnect attempt, the delay will double until it is at 2 minutes\nat which point the delay will stay at 2 minutes." |
| }); |
| addAnnotation |
| (mqttBrokerConnectionInfoEClass, |
| source, |
| new String[] { |
| "documentation", "*\nConnection options that also includes the broker connection information." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo__GetUserPassword(), |
| source, |
| new String[] { |
| "documentation", "*\nReturns the password. User is prompted to provide the password the first time the password is requested (i.e. when the password is null)." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo__GetEffectiveUserName(), |
| source, |
| new String[] { |
| "documentation", "*\nReturn the user name currently effective. When useSystemUserName is enabled,\nthis is the system user name, when useSystemUserName is disabled, returns userName." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo__Validate(), |
| source, |
| new String[] { |
| "documentation", "*\nAttempts to connect with the broker using the user name + password.\n@return True if the connection was accepted, false otherwise." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_Valid(), |
| source, |
| new String[] { |
| "documentation", "Whether or not the connection have been validated.", |
| "property", "readonly" |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_RequireValidation(), |
| source, |
| new String[] { |
| "documentation", "Whether or not the connection requires to be validated.", |
| "property", "none" |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_BrokerHostName(), |
| source, |
| new String[] { |
| "documentation", "*\nBroker Host Name." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_Port(), |
| source, |
| new String[] { |
| "documentation", "*\nBroker Port." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_UserName(), |
| source, |
| new String[] { |
| "documentation", "*\nUser name required to connect to broker." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_Password(), |
| source, |
| new String[] { |
| "documentation", "*\nPassword required to connect to broker. Not persisted for security reasons." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfo_UseSystemUserName(), |
| source, |
| new String[] { |
| "documentation", "*\nWhether or not to use the system user name as the effective user name. This allows, when enabled, the\nMQTTBrokerConnectionInfo to be shared between users without requiring to change the userName when ever a\ndifferent user uses it." |
| }); |
| addAnnotation |
| (mqttBrokerConnectionInfoRegistryEClass, |
| source, |
| new String[] { |
| "documentation", "*\nRegistry containing a list of MQTTBrokerConnectionInfo. It can be used to shared connection information between\nplugins without explicit dependencies between these plugins.\nIt is persisted between session." |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfoRegistry__GetMQTTBrokerConnectionInfoByName__String(), |
| source, |
| new String[] { |
| "documentation", "*\nFind MQTTBrokerConnectionInfo by name" |
| }); |
| addAnnotation |
| (getMQTTBrokerConnectionInfoRegistry_BrokersConnnectionInfo(), |
| source, |
| new String[] { |
| "documentation", "*\nThe list off all the MQTTClient currently managed." |
| }); |
| addAnnotation |
| (simpleSSLMQTTClientConnectionOptionsEClass, |
| source, |
| new String[] { |
| "documentation", "*\nMQTTClientConnectionOptions that support SSL connections options" |
| }); |
| addAnnotation |
| (getSimpleSSLMQTTClientConnectionOptions__CreateSocketFactory(), |
| source, |
| new String[] { |
| "documentation", "*\nCreate a SocketFactory using the KeyStore." |
| }); |
| addAnnotation |
| (getSimpleSSLMQTTClientConnectionOptions_KeyStoreFilePathURL(), |
| source, |
| new String[] { |
| "documentation", "*\nURL to the keyStore file." |
| }); |
| addAnnotation |
| (getSimpleSSLMQTTClientConnectionOptions_KeyStorePassword(), |
| source, |
| new String[] { |
| "documentation", "*\nKey Store password" |
| }); |
| addAnnotation |
| (getMQTTTopic_TopicName(), |
| source, |
| new String[] { |
| "documentation", "*\nName of the topic." |
| }); |
| addAnnotation |
| (getMQTTTopic_QualityOfService(), |
| source, |
| new String[] { |
| "documentation", "*\nQuality of Service, default is \"At least once\" (1)" |
| }); |
| addAnnotation |
| (getMQTTTopic_ExpectedUpdatePeriod(), |
| source, |
| new String[] { |
| "documentation", "*\nExpected update period, in milliseconds. When no update to topic happens within that period, the topic state will be set to STALLED.\nUse -1 to disable this feature." |
| }); |
| addAnnotation |
| (getMQTTTopic_CallBack(), |
| source, |
| new String[] { |
| "documentation", "*\nCall back to register to the topic.", |
| "property", "None" |
| }); |
| addAnnotation |
| (getMQTTTopic_State(), |
| source, |
| new String[] { |
| "documentation", "*\nState of the topic.", |
| "property", "Readonly" |
| }); |
| addAnnotation |
| (qualityOfServiceEEnum, |
| source, |
| new String[] { |
| "documentation", "*\nMQTT Quality Of Service" |
| }); |
| addAnnotation |
| (mqttClientStateEEnum, |
| source, |
| new String[] { |
| "documentation", "*\nTopic states" |
| }); |
| addAnnotation |
| (mqttTopicStateEEnum, |
| source, |
| new String[] { |
| "documentation", "*\nTopic states" |
| }); |
| addAnnotation |
| (apogyAddonsMQTTFacadeEClass, |
| source, |
| new String[] { |
| "documentation", "*\nFacade for MQTT." |
| }); |
| addAnnotation |
| (apogyMQTTRegistryEClass, |
| source, |
| new String[] { |
| "documentation", "*\nClass representing the list of all MQTTClient currently managed by Apogy." |
| }); |
| addAnnotation |
| (getApogyMQTTRegistry_ClientList(), |
| source, |
| new String[] { |
| "documentation", "*\nThe list off all the MQTTClient currently managed." |
| }); |
| } |
| |
| /** |
| * Initializes the annotations for <b>http://www.eclipse.org/apogy</b>. |
| * <!-- begin-user-doc --> |
| * <!-- end-user-doc --> |
| * @generated |
| */ |
| protected void createApogyAnnotations() { |
| String source = "http://www.eclipse.org/apogy"; |
| addAnnotation |
| (mqttClientEClass, |
| source, |
| new String[] { |
| "hasCustomClass", "true", |
| "hasCustomItemProvider", "true" |
| }); |
| addAnnotation |
| (mqttClientConnectionOptionsEClass, |
| source, |
| new String[] { |
| "hasCustomClass", "true", |
| "hasCustomItemProvider", "true" |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_KeepAliveInterval(), |
| source, |
| new String[] { |
| "units", "s" |
| }); |
| addAnnotation |
| (getMQTTClientConnectionOptions_ConnectionTimeout(), |
| source, |
| new String[] { |
| "units", "s" |
| }); |
| addAnnotation |
| (mqttBrokerConnectionInfoEClass, |
| source, |
| new String[] { |
| "hasCustomClass", "true" |
| }); |
| addAnnotation |
| (mqttBrokerConnectionInfoRegistryEClass, |
| source, |
| new String[] { |
| "isSingleton", "true", |
| "hasCustomClass", "true" |
| }); |
| addAnnotation |
| (simpleSSLMQTTClientConnectionOptionsEClass, |
| source, |
| new String[] { |
| "hasCustomClass", "true" |
| }); |
| addAnnotation |
| (mqttTopicEClass, |
| source, |
| new String[] { |
| "hasCustomItemProvider", "true" |
| }); |
| addAnnotation |
| (getMQTTTopic_ExpectedUpdatePeriod(), |
| source, |
| new String[] { |
| "units", "ms" |
| }); |
| addAnnotation |
| (apogyAddonsMQTTFacadeEClass, |
| source, |
| new String[] { |
| "isSingleton", "true", |
| "hasCustomClass", "true" |
| }); |
| addAnnotation |
| (apogyMQTTRegistryEClass, |
| source, |
| new String[] { |
| "isSingleton", "true", |
| "hasCustomClass", "true" |
| }); |
| } |
| |
| } //ApogyAddonsMQTTPackageImpl |
