@@ -0,0 +1,1178 @@
+package io.warp10.plugins.quantum;%0A%0Aimport io.warp10.warp.sdk.AbstractWarp10Plugin;%0A%0Aimport java.lang.reflect.Method;%0Aimport java.util.Properties;%0A%0Apublic class QuantumPlugin extends AbstractWarp10Plugin implements Runnable %7B%0A%0A  private static final String QUANTUM_MAIN_CLASS = %22io.warp10.quantum.Main%22;%0A  private static final String CONF_QUANTUM_HOST = %22quantum.host%22;%0A  private static final String CONF_QUANTUM_PORT = %22quantum.port%22;%0A%0A  private Properties properties = null;%0A%0A  @Override%0A  public void init(Properties properties) %7B%0A    String host = properties.getProperty(CONF_QUANTUM_HOST);%0A    String port = properties.getProperty(CONF_QUANTUM_PORT);%0A%0A    this.properties = properties;%0A%0A    Thread t = new Thread(this);%0A    t.setDaemon(true);%0A    t.setName(%22%5BQuantumPlugin %22 + host + %22:%22 + port + %22%5D%22);%0A    t.start();%0A  %7D%0A%0A  @Override%0A  public void run() %7B%0A%0A    try %7B%0A      Class%3C?%3E cls = this.getClass().getClassLoader().loadClass(QUANTUM_MAIN_CLASS);%0A      Object main = cls.newInstance();%0A      Method meth = cls.getMethod(%22init%22, Properties.class);%0A      meth.invoke(main, this.properties);%0A%0A    %7D catch (Exception e) %7B%0A      throw new RuntimeException(e);%0A    %7D%0A  %7D%0A%7D%0A

add QuantumPlugin