TESB-31044: Data service's endpoint can't be updated if passed as a context variable (#4019)

main/plugins/org.talend.librariesmanager/resources/java/routines/system/BundleUtils.java

@@ -16,6 +16,8 @@ import java.lang.reflect.Method;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.lang.String;
+import java.util.Dictionary;
 
 public final class BundleUtils {
 
@@ -61,6 +63,23 @@ public final class BundleUtils {
         }
     }
 
+    public static Object getService(String svcClass) {
+        if (BUNDLE == null) {
+            return null;
+        }
+        try {
+            Method getBundleContext = BUNDLE.getClass().getMethod("getBundleContext");
+            Object context = getBundleContext.invoke(BUNDLE);
+            Class<?> ctxClass = context.getClass();
+            Method getServiceReference = ctxClass.getMethod("getServiceReference", String.class);
+            Object serviceReference = getServiceReference.invoke(context, svcClass);
+            Method getService = ctxClass.getMethod("getService", SERVICE_REFERENCE_CLASS);
+            return (Object)getService.invoke(context, serviceReference);
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
     public static  <T> T getService(Class<T> svcClass, Object bundleContext) {
         if (BUNDLE_CONTEXT_CLASS == null || bundleContext == null) {
             return null;
@@ -102,7 +121,25 @@ public final class BundleUtils {
             return services;
         }
     }
-    
+
+    public static Dictionary<String, Object> getJobProperties(String jobName) {
+
+        try {
+            Object configAdminObject = getService("org.osgi.service.cm.ConfigurationAdmin");
+
+            Method getConfigurationMethod = configAdminObject.getClass().getMethod("getConfiguration", String.class);
+
+            Object configAdminJobConfiguration = getConfigurationMethod.invoke(configAdminObject, jobName);
+
+            Method getPropertiesMethod = configAdminJobConfiguration.getClass().getMethod("getProperties", null);
+
+            Dictionary<String, Object> jobProperties = (Dictionary<String, Object>)getPropertiesMethod.invoke(configAdminJobConfiguration, null);
+
+            return jobProperties;
+        } catch(Exception e) {
+            return null;
+        }
+    }
 
     public static boolean inOSGi() {
         return BUNDLE != null;