Skip to content

Commit

Permalink
Add DllDispatcherManager to interface with DLL's on the classpath
Browse files Browse the repository at this point in the history 
The DLL must have two main functions:
getServices(): to retreive a list of possible services that can be registered in the DllDispatchermanager.
processMessage(serviceName, correlationId, requestMessage): to call a service in the DLL.
  • Loading branch information
@nielsm5
nielsm5 committed Jul 17, 2017
1 parent e189107 commit f759f89
Show file tree
Hide file tree
Showing 5 changed files with 321 additions and 126 deletions.
14 changes: 14 additions & 0 deletions servicedispatcher/src/main/java/DllDispatcherManager.java
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
import nl.nn.adapterframework.dispatcher.DllDispatcherManagerInterface;

public class DllDispatcherManager implements DllDispatcherManagerInterface {

@Override
native public String processRequest(String functionName, String correlationId, String requestMessage);

@Override
native public String getServices();

static {
System.loadLibrary("Wrapper");
}
}
16 changes: 12 additions & 4 deletions ...edispatcher/src/main/java/nl/nn/adapterframework/dispatcher/DispatcherManagerFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
See the License for the specific language governing permissions and
limitations under the License.
*/
package nl.nn.adapterframework.dispatcher;
package nl.nn.adapterframework.dispatcher;

/**
* Factory to obtain an instance of the {@link DispatcherManager}.
Expand All @@ -26,8 +26,16 @@ public class DispatcherManagerFactory {

/**
* Obtain an instance of the {@link DispatcherManager}.
*/
public static DispatcherManager getDispatcherManager() throws DispatcherException {
return DispatcherManagerImpl.getInstance();
*/
public static DispatcherManager getDispatcherManager() throws DispatcherException {
return DispatcherManagerImpl.getInstance();
}

public static DispatcherManager getDispatcherManager(String dispatcherType) throws DispatcherException {
if(dispatcherType.equalsIgnoreCase("dll")) {
return DllDispatcherManagerImpl.getInstance();
}
else
return getDispatcherManager();
}
}
244 changes: 122 additions & 122 deletions servicedispatcher/src/main/java/nl/nn/adapterframework/dispatcher/DispatcherManagerImpl.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,127 +12,127 @@
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 nl.nn.adapterframework.dispatcher;

import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.HashMap;

/**
* Actual implementation of {@link DispatcherManager}.
*
* @author Gerrit van Brakel
* @version $Id: DispatcherManagerImpl.java,v 1.3 2011/07/18 08:33:01 L190409 Exp $
*/
class DispatcherManagerImpl implements DispatcherManager {

private static final boolean DEBUG=true;

/**
* This is effectively an instance of this class (although actually it may be instead a
* java.lang.reflect.Proxy wrapping an instance from the original classloader).
*/
private static DispatcherManager instance = null;

/*
* There can be only one - ie. even if the class is loaded in several different classloaders,
* there will be only one instance of the object.
*/
static DispatcherManager getInstance(ClassLoader classLoader) throws DispatcherException {
DispatcherManager result = null;
ClassLoader parentclassLoader = classLoader.getParent();
// search for an instance as high in the classloader hierarchy as possible
if (parentclassLoader != null) {
result = getInstance(parentclassLoader);
if (result == null) {
ClassLoader myClassLoader = DispatcherManagerImpl.class.getClassLoader();
Class classInstance;
try {
classInstance = parentclassLoader.loadClass(DispatcherManagerImpl.class.getName());
// And call its getInstance method - this gives the correct
// instance of ourself
Method getInstanceMethod = classInstance.getDeclaredMethod("getInstance", new Class[] {});
Object otherDispatcherManager = getInstanceMethod.invoke(null,new Object[] {});
// But, we can't cast it to our own interface directly because classes loaded from
// different classloaders implement different versions of an interface.
// So instead, we use java.lang.reflect.Proxy to wrap it in an object that *does*
// support our interface, and the proxy will use reflection to pass through all calls
// to the object.
result = (DispatcherManager) Proxy.newProxyInstance(myClassLoader, new Class[] { DispatcherManager.class },
new PassThroughProxyHandler(otherDispatcherManager));
if (DEBUG) System.out.println("DispatcherManagerImpl INFO created DispatcherManager using ClassLoader ["+ parentclassLoader.getClass().getName() + "] that is parent of ["+ classLoader.getClass().getName() + "]");
} catch (Exception e) {
if (DEBUG) System.out.println("DispatcherManagerImpl DEBUG "+ e.getClass().getName()+ " when trying to load DispatcherManager using ClassLoader ["+ parentclassLoader.getClass().getName() + "] that is parent of ["+ classLoader.getClass().getName() + "]: "+ e.getMessage());
return null;
}
}
}
return result;
}

/**
* Retrieve an instance of DispatcherManager from the original classloader. This is a true
* Singleton, in that there will only be one instance of this object in the virtual machine,
* even though there may be several copies of its class file loaded in different classloaders.
*/
synchronized static DispatcherManager getInstance() throws DispatcherException {
if (instance==null) {
ClassLoader myClassLoader = DispatcherManagerImpl.class.getClassLoader();
if (myClassLoader!=null) {
instance = getInstance(myClassLoader);
} else {
System.out.println("DispatcherManagerImpl WARN could not obtain ClassLoader for ["+ DispatcherManagerImpl.class.getName() + "], instantiated DispatcherManager might be too low in class path tree (not on a common branch)");
}
if (instance==null) {
instance = new DispatcherManagerImpl();
}
}
return instance;
}

*/
package nl.nn.adapterframework.dispatcher;

import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.HashMap;

/**
* Actual implementation of {@link DispatcherManager}.
*
* @author Gerrit van Brakel
* @version $Id: DispatcherManagerImpl.java,v 1.3 2011/07/18 08:33:01 L190409 Exp $
*/
class DispatcherManagerImpl implements DispatcherManager {

private static final boolean DEBUG=true;

/**
* This is effectively an instance of this class (although actually it may be instead a
* java.lang.reflect.Proxy wrapping an instance from the original classloader).
*/
private static DispatcherManager instance = null;

/*
* There can be only one - ie. even if the class is loaded in several different classloaders,
* there will be only one instance of the object.
*/
static DispatcherManager getInstance(ClassLoader classLoader) throws DispatcherException {
DispatcherManager result = null;
ClassLoader parentclassLoader = classLoader.getParent();
// search for an instance as high in the classloader hierarchy as possible
if (parentclassLoader != null) {
result = getInstance(parentclassLoader);
if (result == null) {
ClassLoader myClassLoader = DispatcherManagerImpl.class.getClassLoader();
Class classInstance;
try {
classInstance = parentclassLoader.loadClass(DispatcherManagerImpl.class.getName());
// And call its getInstance method - this gives the correct
// instance of ourself
Method getInstanceMethod = classInstance.getDeclaredMethod("getInstance", new Class[] {});
Object otherDispatcherManager = getInstanceMethod.invoke(null,new Object[] {});
// But, we can't cast it to our own interface directly because classes loaded from
// different classloaders implement different versions of an interface.
// So instead, we use java.lang.reflect.Proxy to wrap it in an object that *does*
// support our interface, and the proxy will use reflection to pass through all calls
// to the object.
result = (DispatcherManager) Proxy.newProxyInstance(myClassLoader, new Class[] { DispatcherManager.class },
new PassThroughProxyHandler(otherDispatcherManager));
if (DEBUG) System.out.println("DispatcherManagerImpl INFO created DispatcherManager using ClassLoader ["+ parentclassLoader.getClass().getName() + "] that is parent of ["+ classLoader.getClass().getName() + "]");
} catch (Exception e) {
if (DEBUG) System.out.println("DispatcherManagerImpl DEBUG "+ e.getClass().getName()+ " when trying to load DispatcherManager using ClassLoader ["+ parentclassLoader.getClass().getName() + "] that is parent of ["+ classLoader.getClass().getName() + "]: "+ e.getMessage());
return null;
}
}
}
return result;
}

/**
* Retrieve an instance of DispatcherManager from the original classloader. This is a true
* Singleton, in that there will only be one instance of this object in the virtual machine,
* even though there may be several copies of its class file loaded in different classloaders.
*/
synchronized static DispatcherManager getInstance() throws DispatcherException {
if (instance==null) {
ClassLoader myClassLoader = DispatcherManagerImpl.class.getClassLoader();
if (myClassLoader!=null) {
instance = getInstance(myClassLoader);
} else {
System.out.println("DispatcherManagerImpl WARN could not obtain ClassLoader for ["+ DispatcherManagerImpl.class.getName() + "], instantiated DispatcherManager might be too low in class path tree (not on a common branch)");
}
if (instance==null) {
instance = new DispatcherManagerImpl();
}
}
return instance;
}

private DispatcherManagerImpl() {
}

private HashMap requestProcessorMap = new HashMap();

public String processRequest(String clientName, String message) throws DispatcherException, RequestProcessorException{
return processRequest(clientName, null, message, null);
}

public String processRequest(String clientName, String message, HashMap requestContext) throws DispatcherException, RequestProcessorException{
return processRequest(clientName, null, message, requestContext);
}

public String processRequest(String clientName, String correlationId, String message, HashMap requestContext) throws DispatcherException, RequestProcessorException {
}

private HashMap requestProcessorMap = new HashMap();

public String processRequest(String serviceName, String message) throws DispatcherException, RequestProcessorException{
return processRequest(serviceName, null, message, null);
}

public String processRequest(String serviceName, String message, HashMap requestContext) throws DispatcherException, RequestProcessorException{
return processRequest(serviceName, null, message, requestContext);
}

public String processRequest(String serviceName, String correlationId, String message, HashMap requestContext) throws DispatcherException, RequestProcessorException {
RequestProcessor listener=null;

synchronized (requestProcessorMap) {
listener = (RequestProcessor)requestProcessorMap.get(clientName);
}
if (listener==null) {
throw new DispatcherException("no RequestProcessor registered for ["+clientName+"]");
}
try {
ClassLoader callersClassLoader = Thread.currentThread().getContextClassLoader();
try {
// set contextClassLoader, in order to really switch to the application called.
// This enables new classes to be loaded from proxy's own classpath, enabling
// Xalan extension functions, like 'build-node()'
Thread.currentThread().setContextClassLoader(listener.getClass().getClassLoader());
return listener.processRequest(correlationId,message,requestContext);
} finally {
Thread.currentThread().setContextClassLoader(callersClassLoader);
}
} catch (Throwable t) {
throw new RequestProcessorException("RequestProcessor ["+clientName+"] caught exception",t);
}
}

public void register(String name, RequestProcessor listener) throws DispatcherException {
synchronized (requestProcessorMap) {
requestProcessorMap.put(name, listener);
}
}
}

synchronized (requestProcessorMap) {
listener = (RequestProcessor)requestProcessorMap.get(serviceName);
}
if (listener==null) {
throw new DispatcherException("no RequestProcessor registered for ["+serviceName+"]");
}
try {
ClassLoader callersClassLoader = Thread.currentThread().getContextClassLoader();
try {
// set contextClassLoader, in order to really switch to the application called.
// This enables new classes to be loaded from proxy's own classpath, enabling
// Xalan extension functions, like 'build-node()'
Thread.currentThread().setContextClassLoader(listener.getClass().getClassLoader());
return listener.processRequest(correlationId,message,requestContext);
} finally {
Thread.currentThread().setContextClassLoader(callersClassLoader);
}
} catch (Throwable t) {
throw new RequestProcessorException("RequestProcessor ["+serviceName+"] caught exception",t);
}
}

public void register(String name, RequestProcessor listener) throws DispatcherException {
synchronized (requestProcessorMap) {
requestProcessorMap.put(name, listener);
}
}
}

Loading

0 comments on commit f759f89

Please sign in to comment.