if (trace) { log.trace(this + "(" + (++invokeCount) + ") invoking " + invocationReq); }
// Set up marshaller and unmarshaller.
Marshaller marshaller = null;
UnMarshaller unmarshaller = null;
RemotingClassLoader rcl = null;
synchronized (MicroRemoteClientInvoker.class)
{
marshaller = getMarshaller();
if (marshaller == null)
{
// try by locator (in case marshaller class name specified)
marshaller = MarshalFactory.getMarshaller(getLocator(), getClassLoader());
if (marshaller == null)
{
// need to have a marshaller, so create a default one
marshaller = MarshalFactory.getMarshaller(getDataType(), getSerializationType());
if (marshaller == null)
{
// went as far as possible to find a marshaller, will have to give up
throw new InvalidMarshallingResource(
"Can not find a valid marshaller for data type: " + getDataType());
}
}
setMarshaller(marshaller);
}
unmarshaller = getUnMarshaller();
if (unmarshaller == null)
{
// try by locator (in case unmarshaller class name specified)
unmarshaller = MarshalFactory.getUnMarshaller(getLocator(), getClassLoader());
if (unmarshaller == null)
{
unmarshaller = MarshalFactory.getUnMarshaller(getDataType(), getSerializationType());
if (unmarshaller == null)
{
// went as far as possible to find a unmarshaller, will have to give up
throw new InvalidMarshallingResource(
"Can not find a valid unmarshaller for data type: " + getDataType());
}
}
setUnMarshaller(unmarshaller);
}
// Each unmarshaller gets a RemotingClassloader classloader containing the
// remoting class loader (for remote classloading) and the current thread's
// class loader. This allows to load remoting classes as well as user's
// classes. If possible, will simply reset context classloader on existing
// RemotingClassLoader.
ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
if (unmarshaller instanceof UpdateableClassloaderUnMarshaller)
{
UpdateableClassloaderUnMarshaller uclum = (UpdateableClassloaderUnMarshaller) unmarshaller;
ClassLoader cl = uclum.getClassLoader();
if (cl instanceof RemotingClassLoader)
{
rcl = (RemotingClassLoader) cl;
rcl.setUserClassLoader(contextClassLoader);
}
else
{
rcl = new RemotingClassLoader(getClassLoader(), contextClassLoader);
unmarshaller.setClassLoader(rcl);
}
}
else
{
rcl = new RemotingClassLoader(getClassLoader(), contextClassLoader);
unmarshaller.setClassLoader(rcl);
}
}
// if raw, then send only param of invocation request
Object payload = null;