You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by gd...@apache.org on 2005/07/11 19:49:08 UTC
svn commit: r210165 [2/20] - in /webservices/axis/trunk/java/modules:
addressing/src/org/apache/axis2/handlers/addressing/
addressing/test/org/apache/axis2/handlers/addressing/
addressing/test/org/apache/axis2/handlers/util/
core/src/org/apache/axis2/a...
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOnlyMEPClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOnlyMEPClient.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOnlyMEPClient.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOnlyMEPClient.java Mon Jul 11 10:48:55 2005
@@ -50,7 +50,8 @@
ConfigurationContext syscontext = serviceContext.getEngineContext();
if (senderTransport == null) {
- senderTransport = inferTransport(messageInformationHeaders.getTo());
+ senderTransport =
+ inferTransport(messageInformationHeaders.getTo());
}
msgctx.setTransportOut(senderTransport);
@@ -59,7 +60,8 @@
AxisConfiguration registry = sysContext.getAxisConfiguration();
AxisEngine engine = new AxisEngine(sysContext);
- msgctx.setOperationContext(axisop.findOperationContext(msgctx, serviceContext));
+ msgctx.setOperationContext(
+ axisop.findOperationContext(msgctx, serviceContext));
engine.send(msgctx);
}
@@ -114,10 +116,13 @@
}
public void engageModule(QName name) throws AxisFault {
- serviceContext.getEngineContext().getAxisConfiguration().engageModule(name);
+ serviceContext.getEngineContext().getAxisConfiguration().engageModule(
+ name);
}
public void setSenderTransport(String senderTransport) throws AxisFault {
- this.senderTransport = serviceContext.getEngineContext().getAxisConfiguration().getTransportOut(new QName(senderTransport));
+ this.senderTransport =
+ serviceContext.getEngineContext().getAxisConfiguration()
+ .getTransportOut(new QName(senderTransport));
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOutMEPClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOutMEPClient.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOutMEPClient.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/InOutMEPClient.java Mon Jul 11 10:48:55 2005
@@ -107,7 +107,8 @@
// throw new UnsupportedOperationException();
// }
- public MessageContext invokeBlocking(OperationDescription axisop, final MessageContext msgctx)
+ public MessageContext invokeBlocking(OperationDescription axisop,
+ final MessageContext msgctx)
throws AxisFault {
verifyInvocation(axisop, msgctx);
if (useSeparateListener) {
@@ -126,7 +127,8 @@
}
}
if (callback.envelope != null) {
- MessageContext resMsgctx = new MessageContext(serviceContext.getEngineContext());
+ MessageContext resMsgctx = new MessageContext(
+ serviceContext.getEngineContext());
resMsgctx.setEnvelope(callback.envelope);
return resMsgctx;
} else {
@@ -147,15 +149,19 @@
ConfigurationContext sysContext = serviceContext.getEngineContext();
AxisConfiguration registry = sysContext.getAxisConfiguration();
- msgctx.setOperationContext(OperationContextFactory.createMEPContext(WSDLConstants.MEP_CONSTANT_IN_OUT,
- axisop,
- serviceContext));
- MessageContext response = TwoChannelBasedSender.send(msgctx, listenerTransport);
+ msgctx.setOperationContext(
+ OperationContextFactory.createMEPContext(
+ WSDLConstants.MEP_CONSTANT_IN_OUT,
+ axisop,
+ serviceContext));
+ MessageContext response = TwoChannelBasedSender.send(msgctx,
+ listenerTransport);
SOAPEnvelope resenvelope = response.getEnvelope();
if (resenvelope.getBody().hasFault()) {
- throw new AxisFault(resenvelope.getBody().getFault().getException());
+ throw new AxisFault(
+ resenvelope.getBody().getFault().getException());
}
return response;
}
@@ -180,15 +186,22 @@
msgctx.setMessageID(messageID);
axisop.setMessageReciever(callbackReceiver);
callbackReceiver.addCallback(messageID, callback);
- msgctx.setReplyTo(ListenerManager.replyToEPR(serviceContext.getServiceConfig().getName().getLocalPart()
- + "/"
- + axisop.getName().getLocalPart(),
- listenerTransport.getName().getLocalPart()));
- msgctx.setOperationContext(axisop.findOperationContext(msgctx, serviceContext));
+ msgctx.setReplyTo(
+ ListenerManager.replyToEPR(
+ serviceContext.getServiceConfig().getName()
+ .getLocalPart()
+ + "/"
+ + axisop.getName().getLocalPart(),
+ listenerTransport.getName().getLocalPart()));
+ msgctx.setOperationContext(
+ axisop.findOperationContext(msgctx, serviceContext));
msgctx.setServiceContext(serviceContext);
engine.send(msgctx);
} else {
- serviceContext.getEngineContext().getThreadPool().addWorker(new NonBlockingInvocationWorker(callback, axisop, msgctx));
+ serviceContext.getEngineContext().getThreadPool().addWorker(
+ new NonBlockingInvocationWorker(callback,
+ axisop,
+ msgctx));
}
} catch (OMException e) {
@@ -228,23 +241,32 @@
throws AxisFault {
if (!useSeparateListener) {
- boolean isTransportsEqual = senderTransport.equals(listenerTransport);
- boolean isATwoWaytransport = Constants.TRANSPORT_HTTP.equals(senderTransport)
+ boolean isTransportsEqual = senderTransport.equals(
+ listenerTransport);
+ boolean isATwoWaytransport = Constants.TRANSPORT_HTTP.equals(
+ senderTransport)
|| Constants.TRANSPORT_TCP.equals(senderTransport)
- || Constants.TRANSPORT_COMMONS_HTTP.equals(senderTransport);
- boolean isCommonsAndHTTP = Constants.TRANSPORT_COMMONS_HTTP.equals(senderTransport)
+ ||
+ Constants.TRANSPORT_COMMONS_HTTP.equals(senderTransport);
+ boolean isCommonsAndHTTP = Constants.TRANSPORT_COMMONS_HTTP.equals(
+ senderTransport)
&& Constants.TRANSPORT_HTTP.equals(listenerTransport);
- if (!isCommonsAndHTTP && (!isTransportsEqual || !isATwoWaytransport)) {
- throw new AxisFault("useSeparateListener = false is only supports by the htpp/tcp and tcp commons transport set as the sender and receiver");
+ if (!isCommonsAndHTTP &&
+ (!isTransportsEqual || !isATwoWaytransport)) {
+ throw new AxisFault(
+ "useSeparateListener = false is only supports by the htpp/tcp and tcp commons transport set as the sender and receiver");
}
} else {
this.useSeparateListener = useSeparateListener;
}
- AxisConfiguration axisConfig = serviceContext.getEngineContext().getAxisConfiguration();
- this.listenerTransport = axisConfig.getTransportIn(new QName(listenerTransport));
- this.senderTransport = axisConfig.getTransportOut(new QName(senderTransport));
+ AxisConfiguration axisConfig = serviceContext.getEngineContext()
+ .getAxisConfiguration();
+ this.listenerTransport =
+ axisConfig.getTransportIn(new QName(listenerTransport));
+ this.senderTransport =
+ axisConfig.getTransportOut(new QName(senderTransport));
if (this.senderTransport == null) {
throw new AxisFault("Unknown transport " + senderTransport);
}
@@ -258,9 +280,11 @@
.getEngineContext()
.getAxisConfiguration()
.isEngaged(new QName(Constants.MODULE_ADDRESSING))) {
- throw new AxisFault("to do two Transport Channels the Addressing Modules must be engeged");
+ throw new AxisFault(
+ "to do two Transport Channels the Addressing Modules must be engeged");
}
- ListenerManager.makeSureStarted(listenerTransport, serviceContext.getEngineContext());
+ ListenerManager.makeSureStarted(listenerTransport,
+ serviceContext.getEngineContext());
}
}
@@ -270,7 +294,8 @@
}
if (listenerTransport == null) {
listenerTransport =
- serviceContext.getEngineContext().getAxisConfiguration().getTransportIn(senderTransport.getName());
+ serviceContext.getEngineContext().getAxisConfiguration()
+ .getTransportIn(senderTransport.getName());
}
if (msgctx.getTransportIn() == null) {
@@ -299,7 +324,8 @@
}
public void engageModule(QName moduleName) throws AxisFault {
- serviceContext.getEngineContext().getAxisConfiguration().engageModule(moduleName);
+ serviceContext.getEngineContext().getAxisConfiguration().engageModule(
+ moduleName);
}
public void close() throws AxisFault {
@@ -323,11 +349,14 @@
public void doWork() {
try {
- msgctx.setOperationContext(OperationContextFactory.createMEPContext(WSDLConstants.MEP_CONSTANT_IN_OUT,
- axisop,
- serviceContext));
+ msgctx.setOperationContext(
+ OperationContextFactory.createMEPContext(
+ WSDLConstants.MEP_CONSTANT_IN_OUT,
+ axisop,
+ serviceContext));
msgctx.setServiceContext(serviceContext);
- MessageContext response = TwoChannelBasedSender.send(msgctx, listenerTransport);
+ MessageContext response = TwoChannelBasedSender.send(msgctx,
+ listenerTransport);
SOAPEnvelope resenvelope = response.getEnvelope();
AsyncResult asyncResult = new AsyncResult(response);
callback.onComplete(asyncResult);
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/ListenerManager.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/ListenerManager.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/ListenerManager.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/ListenerManager.java Mon Jul 11 10:48:55 2005
@@ -37,15 +37,19 @@
public static final void makeSureStarted(String transport,
ConfigurationContext configurationContext)
throws AxisFault {
- if (ListenerManager.configurationContext != null && configurationContext != ListenerManager.configurationContext) {
- throw new AxisFault("Only One ConfigurationContext Instance we support at the Client Side");
+ if (ListenerManager.configurationContext != null &&
+ configurationContext != ListenerManager.configurationContext) {
+ throw new AxisFault(
+ "Only One ConfigurationContext Instance we support at the Client Side");
}
ListenerManager.configurationContext = configurationContext;
- TransportListnerState tsState = (TransportListnerState) listeners.get(transport);
+ TransportListnerState tsState = (TransportListnerState) listeners.get(
+ transport);
if (tsState == null) {
TransportInDescription tranportIn =
- configurationContext.getAxisConfiguration().getTransportIn(new QName(transport));
+ configurationContext.getAxisConfiguration().getTransportIn(
+ new QName(transport));
TransportListener listener = tranportIn.getReciever();
// listener.init(configurationContext, tranportIn);
listener.start();
@@ -56,7 +60,8 @@
}
public static final void stop(String transport) throws AxisFault {
- TransportListnerState tsState = (TransportListnerState) listeners.get(transport);
+ TransportListnerState tsState = (TransportListnerState) listeners.get(
+ transport);
if (tsState != null) {
tsState.waitingCalls--;
if (tsState.waitingCalls == 0) {
@@ -65,14 +70,16 @@
}
}
- public static EndpointReference replyToEPR(String serviceName, String transport)
+ public static EndpointReference replyToEPR(String serviceName,
+ String transport)
throws AxisFault {
- TransportListnerState tsState = (TransportListnerState) listeners.get(transport);
+ TransportListnerState tsState = (TransportListnerState) listeners.get(
+ transport);
if (tsState != null) {
return tsState.listener.replyToEPR(serviceName);
} else {
throw new AxisFault("Calling method before starting the with makeSureStarted(..) Listener transport = "
- + transport);
+ + transport);
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MEPClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MEPClient.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MEPClient.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MEPClient.java Mon Jul 11 10:48:55 2005
@@ -57,19 +57,21 @@
this.mep = mep;
}
- protected void verifyInvocation(OperationDescription axisop, MessageContext msgCtx) throws AxisFault {
+ protected void verifyInvocation(OperationDescription axisop,
+ MessageContext msgCtx) throws AxisFault {
if (axisop == null) {
throw new AxisFault("OperationDescription can not be null");
}
if (mep.equals(axisop.getMessageExchangePattern())) {
throw new AxisFault("This mepClient supports only "
- + mep
- + " And the Axis Operations suppiled supports "
- + axisop.getMessageExchangePattern());
+ + mep
+ + " And the Axis Operations suppiled supports "
+ + axisop.getMessageExchangePattern());
}
- if (serviceContext.getServiceConfig().getOperation(axisop.getName()) == null) {
+ if (serviceContext.getServiceConfig().getOperation(axisop.getName()) ==
+ null) {
serviceContext.getServiceConfig().addOperation(axisop);
}
msgCtx.setDoingREST(doREST);
@@ -79,7 +81,8 @@
}
protected MessageContext prepareTheSystem(OMElement toSend) throws AxisFault {
- MessageContext msgctx = new MessageContext(serviceContext.getEngineContext());
+ MessageContext msgctx = new MessageContext(
+ serviceContext.getEngineContext());
SOAPEnvelope envelope = createDefaultSOAPEnvelope();
envelope.getBody().addChild(toSend);
@@ -98,7 +101,8 @@
}
if (transport != null) {
- return serviceContext.getEngineContext().getAxisConfiguration().getTransportOut(new QName(transport));
+ return serviceContext.getEngineContext().getAxisConfiguration()
+ .getTransportOut(new QName(transport));
} else {
throw new AxisFault("Cannot Infer transport from the URL");
@@ -110,10 +114,12 @@
SOAPFactory fac = null;
if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(soapVersionURI)) {
fac = OMAbstractFactory.getSOAP12Factory();
- } else if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(soapVersionURI)) {
+ } else if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(
+ soapVersionURI)) {
fac = OMAbstractFactory.getSOAP11Factory();
} else {
- throw new AxisFault("Invalid SOAP URI. Axis2 only supports SOAP 1.1 and 1.2");
+ throw new AxisFault(
+ "Invalid SOAP URI. Axis2 only supports SOAP 1.1 and 1.2");
}
return fac.getDefaultEnvelope();
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MessageSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MessageSender.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MessageSender.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/MessageSender.java Mon Jul 11 10:48:55 2005
@@ -43,7 +43,8 @@
}
public void send(String opName, OMElement toSend) throws AxisFault {
- OperationDescription axisOp = serviceContext.getServiceConfig().getOperation(opName);
+ OperationDescription axisOp = serviceContext.getServiceConfig()
+ .getOperation(opName);
if (axisOp == null) {
axisOp = new OperationDescription(new QName(opName));
serviceContext.getServiceConfig().addOperation(axisOp);
@@ -62,9 +63,11 @@
//create new service
QName assumedServiceName = new QName("AnonnoymousService");
- ServiceDescription axisService = new ServiceDescription(assumedServiceName);
+ ServiceDescription axisService = new ServiceDescription(
+ assumedServiceName);
sysContext.getAxisConfiguration().addService(axisService);
- ServiceContext service = sysContext.createServiceContext(assumedServiceName);
+ ServiceContext service = sysContext.createServiceContext(
+ assumedServiceName);
return service;
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/Stub.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/Stub.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/Stub.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/Stub.java Mon Jul 11 10:48:55 2005
@@ -69,18 +69,22 @@
public void _setSessionInfo(String key, Object value) throws java.lang.Exception {
if (!_maintainSession) {
//TODO Comeup with a Exception
- throw new java.lang.Exception("Client is running the session OFF mode: Start session before saving to a session ");
+ throw new java.lang.Exception(
+ "Client is running the session OFF mode: Start session before saving to a session ");
}
- _configurationContext.getServiceContext(_currentSessionId).setProperty(key, value);
+ _configurationContext.getServiceContext(_currentSessionId).setProperty(
+ key, value);
}
public Object _getSessionInfo(String key) throws java.lang.Exception {
if (!_maintainSession) {
//TODO Comeup with a Exception
- throw new java.lang.Exception("Client is running the session OFF mode: Start session before saving to a session ");
+ throw new java.lang.Exception(
+ "Client is running the session OFF mode: Start session before saving to a session ");
}
- return _configurationContext.getServiceContext(_currentSessionId).getProperty(key);
+ return _configurationContext.getServiceContext(_currentSessionId)
+ .getProperty(key);
}
public void _startSession() {
@@ -110,11 +114,16 @@
return env;
}
- protected void setValueRPC(SOAPEnvelope env, String methodNamespaceURI, String methodName, String[] paramNames, Object[] values) {
+ protected void setValueRPC(SOAPEnvelope env,
+ String methodNamespaceURI,
+ String methodName,
+ String[] paramNames,
+ Object[] values) {
SOAPBody body = env.getBody();
OMFactory fac = this.getFactory();
- OMNamespace methodNamespace = fac.createOMNamespace(methodNamespaceURI, "ns1");
+ OMNamespace methodNamespace = fac.createOMNamespace(methodNamespaceURI,
+ "ns1");
OMElement elt = fac.createOMElement(methodName, methodNamespace);
if (paramNames != null) {
//find the relevant object here, convert it and add it to the elt
@@ -122,9 +131,9 @@
String paramName = paramNames[i];
Object value = values[i];
elt.addChild(StubSupporter.createRPCMappedElement(paramName,
- fac.createOMNamespace("", null), //empty namespace
- value,
- fac));
+ fac.createOMNamespace("", null), //empty namespace
+ value,
+ fac));
}
}
body.addChild(elt);
@@ -132,7 +141,8 @@
protected OMElement getElementFromReader(XMLStreamReader reader) {
- StAXOMBuilder builder = OMXMLBuilderFactory.createStAXOMBuilder(OMAbstractFactory.getOMFactory(), reader);
+ StAXOMBuilder builder = OMXMLBuilderFactory.createStAXOMBuilder(
+ OMAbstractFactory.getOMFactory(), reader);
return builder.getDocumentElement();
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/StubSupporter.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/StubSupporter.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/StubSupporter.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/StubSupporter.java Mon Jul 11 10:48:55 2005
@@ -25,28 +25,40 @@
class StubSupporter {
- public static OMElement createRPCMappedElement(String elementName, OMNamespace ns, Object value, OMFactory fac) {
+ public static OMElement createRPCMappedElement(String elementName,
+ OMNamespace ns,
+ Object value,
+ OMFactory fac) {
OMElement returnElement = fac.createOMElement(elementName, ns);
Class inputParamClass = value.getClass();
if (inputParamClass.equals(String.class)) {
- returnElement.addChild(fac.createText(returnElement, value.toString()));
+ returnElement.addChild(
+ fac.createText(returnElement, value.toString()));
} else if (inputParamClass.equals(Integer.class)) {
- returnElement.addChild(fac.createText(returnElement, String.valueOf(((Integer) value).intValue())));
+ returnElement.addChild(
+ fac.createText(returnElement,
+ String.valueOf(((Integer) value).intValue())));
} else if (inputParamClass.equals(Float.class)) {
- returnElement.addChild(fac.createText(returnElement, String.valueOf(((Float) value).floatValue())));
+ returnElement.addChild(
+ fac.createText(returnElement,
+ String.valueOf(((Float) value).floatValue())));
} else if (inputParamClass.equals(Double.class)) {
- returnElement.addChild(fac.createText(returnElement, String.valueOf(((Double) value).doubleValue())));
+ returnElement.addChild(
+ fac.createText(returnElement,
+ String.valueOf(((Double) value).doubleValue())));
//todo this seems to be a long list... need to complete this
} else if (inputParamClass.equals(OMElement.class)) {
returnElement.addChild((OMElement) value);
} else {
- returnElement.addChild(fac.createText(returnElement, value.toString()));
+ returnElement.addChild(
+ fac.createText(returnElement, value.toString()));
}
return returnElement;
}
- public static Object getRPCMappedElementValue(OMElement elt, Class outputTypeClass) {
+ public static Object getRPCMappedElementValue(OMElement elt,
+ Class outputTypeClass) {
Object outputObj = null;
if (outputTypeClass.equals(String.class)) {
outputObj = elt.getText();
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/TwoChannelBasedSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/TwoChannelBasedSender.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/TwoChannelBasedSender.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/clientapi/TwoChannelBasedSender.java Mon Jul 11 10:48:55 2005
@@ -24,7 +24,8 @@
public class TwoChannelBasedSender {
- public static MessageContext send(MessageContext msgctx, TransportInDescription transportIn) throws AxisFault {
+ public static MessageContext send(MessageContext msgctx,
+ TransportInDescription transportIn) throws AxisFault {
AxisEngine engine = new AxisEngine(msgctx.getSystemContext());
@@ -33,11 +34,11 @@
MessageContext response =
new MessageContext(msgctx.getSystemContext(),
- msgctx.getSessionContext(),
- msgctx.getTransportIn(),
- msgctx.getTransportOut());
+ msgctx.getSessionContext(),
+ msgctx.getTransportIn(),
+ msgctx.getTransportOut());
response.setProperty(MessageContext.TRANSPORT_IN,
- msgctx.getProperty(MessageContext.TRANSPORT_IN));
+ msgctx.getProperty(MessageContext.TRANSPORT_IN));
response.setServerSide(false);
response.setOperationContext(msgctx.getOperationContext());
response.setServiceContext(msgctx.getServiceContext());
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContext.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContext.java Mon Jul 11 10:48:55 2005
@@ -85,7 +85,8 @@
axisConfiguration = configuration;
}
- public synchronized void registerOperationContext(String messageID, OperationContext mepContext) {
+ public synchronized void registerOperationContext(String messageID,
+ OperationContext mepContext) {
this.operationContextMap.put(messageID, mepContext);
}
@@ -97,7 +98,8 @@
return this.operationContextMap;
}
- public synchronized void registerServiceContext(String serviceInstanceID, ServiceContext serviceContext) {
+ public synchronized void registerServiceContext(String serviceInstanceID,
+ ServiceContext serviceContext) {
this.serviceContextMap.put(serviceInstanceID, serviceContext);
}
@@ -119,7 +121,8 @@
ServiceContext serviceContext = new ServiceContext(service, this);
return serviceContext;
} else {
- throw new AxisFault("Service not found service name = " + serviceName);
+ throw new AxisFault(
+ "Service not found service name = " + serviceName);
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContextFactory.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContextFactory.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContextFactory.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ConfigurationContextFactory.java Mon Jul 11 10:48:55 2005
@@ -29,7 +29,8 @@
*/
public class ConfigurationContextFactory {
- public ConfigurationContext buildConfigurationContext(String RepositaryName)
+ public ConfigurationContext buildConfigurationContext(
+ String RepositaryName)
throws DeploymentException {
ConfigurationContext configurationContext = null;
try {
@@ -46,7 +47,8 @@
return configurationContext;
}
- public ConfigurationContext buildClientConfigurationContext(String axis2home)
+ public ConfigurationContext buildClientConfigurationContext(
+ String axis2home)
throws DeploymentException {
ConfigurationContext engineContext = null;
try {
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/MessageContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/MessageContext.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/MessageContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/MessageContext.java Mon Jul 11 10:48:55 2005
@@ -18,7 +18,11 @@
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.addressing.MessageInformationHeadersCollection;
import org.apache.axis2.addressing.miheaders.RelatesTo;
-import org.apache.axis2.description.*;
+import org.apache.axis2.description.OperationDescription;
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ServiceDescription;
+import org.apache.axis2.description.TransportInDescription;
+import org.apache.axis2.description.TransportOutDescription;
import org.apache.axis2.engine.AxisConfiguration;
import org.apache.axis2.engine.AxisFault;
import org.apache.axis2.soap.SOAPEnvelope;
@@ -497,7 +501,8 @@
/**
* @param collection
*/
- public void setMessageInformationHeaders(MessageInformationHeadersCollection collection) {
+ public void setMessageInformationHeaders(
+ MessageInformationHeadersCollection collection) {
messageInformationHeaders = collection;
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContext.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContext.java Mon Jul 11 10:48:55 2005
@@ -151,7 +151,7 @@
return outMessageContext;
} else {
throw new AxisFault("Unrecognized message label: '" + messageLabel
- + "'");
+ + "'");
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContextFactory.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContextFactory.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContextFactory.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/OperationContextFactory.java Mon Jul 11 10:48:55 2005
@@ -24,7 +24,8 @@
public class OperationContextFactory implements WSDLConstants {
public static OperationContext createMEPContext(int mepURI,
- OperationDescription axisOp, ServiceContext serviceContext)
+ OperationDescription axisOp,
+ ServiceContext serviceContext)
throws AxisFault {
if (MEP_CONSTANT_IN_OUT == mepURI || MEP_CONSTANT_IN_ONLY == mepURI
|| MEP_CONSTANT_IN_OPTIONAL_OUT == mepURI
@@ -37,7 +38,7 @@
} else {
throw new AxisFault("Cannot handle the MEP " + mepURI
- + " for the current invocation of Operation ");
+ + " for the current invocation of Operation ");
}
}
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ServiceContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ServiceContext.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ServiceContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/context/ServiceContext.java Mon Jul 11 10:48:55 2005
@@ -29,7 +29,8 @@
private String serviceInstanceID;
- public ServiceContext(ServiceDescription serviceConfig, ConfigurationContext engineContext) {
+ public ServiceContext(ServiceDescription serviceConfig,
+ ConfigurationContext engineContext) {
super(engineContext);
this.serviceConfig = serviceConfig;
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentClassLoader.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentClassLoader.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentClassLoader.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentClassLoader.java Mon Jul 11 10:48:55 2005
@@ -1,6 +1,10 @@
package org.apache.axis2.deployment;
-import java.io.*;
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.ArrayList;
@@ -77,7 +81,8 @@
* then those entry name will be added to the arraylist
*/
if (entryName != null && (entryName.startsWith("lib/") ||
- entryName.startsWith("Lib/")) && entryName.endsWith(".jar")) {
+ entryName.startsWith("Lib/")) &&
+ entryName.endsWith(".jar")) {
lib_jars_list.add(entryName);
}
}
@@ -157,7 +162,8 @@
String entryName = "";
while ((entry = zin.getNextEntry()) != null) {
entryName = entry.getName();
- if (entryName != null && entryName.endsWith(completeFileName)) {
+ if (entryName != null &&
+ entryName.endsWith(completeFileName)) {
byte data[] = new byte[2048];
ByteArrayOutputStream out = new ByteArrayOutputStream();
int count;
Modified: webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentEngine.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentEngine.java?rev=210165&r1=210164&r2=210165&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentEngine.java (original)
+++ webservices/axis/trunk/java/modules/core/src/org/apache/axis2/deployment/DeploymentEngine.java Mon Jul 11 10:48:55 2005
@@ -24,7 +24,12 @@
import org.apache.axis2.deployment.scheduler.Scheduler;
import org.apache.axis2.deployment.scheduler.SchedulerTask;
import org.apache.axis2.deployment.util.PhasesInfo;
-import org.apache.axis2.description.*;
+import org.apache.axis2.description.Flow;
+import org.apache.axis2.description.HandlerDescription;
+import org.apache.axis2.description.ModuleDescription;
+import org.apache.axis2.description.OperationDescription;
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ServiceDescription;
import org.apache.axis2.engine.AxisConfiguration;
import org.apache.axis2.engine.AxisConfigurationImpl;
import org.apache.axis2.engine.AxisFault;
@@ -37,8 +42,19 @@
import javax.xml.namespace.QName;
import javax.xml.stream.XMLStreamException;
-import java.io.*;
-import java.util.*;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
public class DeploymentEngine implements DeploymentConstants {
@@ -129,7 +145,8 @@
File serverConf = new File(repository, serverXMLFile);
if (!serverConf.exists()) {
ClassLoader cl = Thread.currentThread().getContextClassLoader();
- InputStream in = cl.getResourceAsStream("org/apache/axis2/deployment/axis2.xml");
+ InputStream in = cl.getResourceAsStream(
+ "org/apache/axis2/deployment/axis2.xml");
if (in != null) {
try {
serverConf.createNewFile();
@@ -148,7 +165,8 @@
} else {
- throw new DeploymentException("can not found org/apache/axis2/deployment/axis2.xml");
+ throw new DeploymentException(
+ "can not found org/apache/axis2/deployment/axis2.xml");
}
}
@@ -175,8 +193,10 @@
*/
private void setDeploymentFeatures() {
String value;
- Parameter parahotdeployment = ((AxisConfigurationImpl) axisConfig).getParameter(HOTDEPLOYMENT);
- Parameter parahotupdate = ((AxisConfigurationImpl) axisConfig).getParameter(HOTUPDATE);
+ Parameter parahotdeployment = ((AxisConfigurationImpl) axisConfig).getParameter(
+ HOTDEPLOYMENT);
+ Parameter parahotupdate = ((AxisConfigurationImpl) axisConfig).getParameter(
+ HOTUPDATE);
if (parahotdeployment != null) {
value = (String) parahotdeployment.getValue();
if ("false".equals(value))
@@ -199,7 +219,8 @@
InputStream in = new FileInputStream(tempfile);
axisConfig = createEngineConfig();
DeploymentParser parser = new DeploymentParser(in, this);
- parser.processGlobalConfig(((AxisConfigurationImpl) axisConfig), AXIS2CONFIG);
+ parser.processGlobalConfig(((AxisConfigurationImpl) axisConfig),
+ AXIS2CONFIG);
} catch (FileNotFoundException e) {
throw new DeploymentException("Exception at deployment", e);
} catch (XMLStreamException e) {
@@ -239,12 +260,15 @@
}
} else {
ClassLoader cl = Thread.currentThread().getContextClassLoader();
- in = cl.getResourceAsStream("org/apache/axis2/deployment/axis2.xml");
+ in =
+ cl.getResourceAsStream(
+ "org/apache/axis2/deployment/axis2.xml");
}
try {
axisConfig = createEngineConfig();
DeploymentParser parser = new DeploymentParser(in, this);
- parser.processGlobalConfig(((AxisConfigurationImpl) axisConfig), AXIS2CONFIG);
+ parser.processGlobalConfig(((AxisConfigurationImpl) axisConfig),
+ AXIS2CONFIG);
} catch (XMLStreamException e) {
throw new DeploymentException(e);
}
@@ -253,7 +277,8 @@
hotUpdate = false;
new RepositoryListenerImpl(folderName, this);
try {
- ((AxisConfigurationImpl) axisConfig).setRepository(axis2repository);
+ ((AxisConfigurationImpl) axisConfig).setRepository(
+ axis2repository);
engagdeModules();
((AxisConfigurationImpl) axisConfig).setPhasesinfo(phasesinfo);
} catch (AxisFault axisFault) {
@@ -279,7 +304,8 @@
File serverConf = new File(repository, clientXML);
if (!serverConf.exists()) {
ClassLoader cl = Thread.currentThread().getContextClassLoader();
- InputStream in = cl.getResourceAsStream("org/apache/axis2/deployment/axis2.xml");
+ InputStream in = cl.getResourceAsStream(
+ "org/apache/axis2/deployment/axis2.xml");
if (in != null) {
try {
serverConf.createNewFile();
@@ -298,7 +324,8 @@
} else {
- throw new DeploymentException("can not found org/apache/axis2/deployment/axis2.xml");
+ throw new DeploymentException(
+ "can not found org/apache/axis2/deployment/axis2.xml");
}
}
@@ -328,12 +355,15 @@
private void validateSystemPredefinedPhases() throws DeploymentException {
ArrayList inPhases = phasesinfo.getINPhases();
//TODO condition checking should be otherway since null value can occur
- if (!(((String) inPhases.get(0)).equals(PhaseMetadata.PHASE_TRANSPORTIN) &&
- ((String) inPhases.get(1)).equals(PhaseMetadata.PHASE_PRE_DISPATCH) &&
+ if (!(((String) inPhases.get(0)).equals(
+ PhaseMetadata.PHASE_TRANSPORTIN) &&
+ ((String) inPhases.get(1)).equals(
+ PhaseMetadata.PHASE_PRE_DISPATCH) &&
((String) inPhases.get(2)).equals(PhaseMetadata.PHASE_DISPATCH) &&
- ((String) inPhases.get(3)).equals(PhaseMetadata.PHASE_POST_DISPATCH))) {
+ ((String) inPhases.get(3)).equals(
+ PhaseMetadata.PHASE_POST_DISPATCH))) {
throw new DeploymentException("Invalid System predefined inphases , phase order dose not" +
- " support\n recheck axis2.xml");
+ " support\n recheck axis2.xml");
}
// ArrayList outPhaes = tempdata.getOutphases();
//TODO do the validation code here
@@ -351,7 +381,8 @@
*/
private void startSearch(DeploymentEngine engine) {
scheduler = new Scheduler();
- scheduler.schedule(new SchedulerTask(engine, folderName), new DeploymentIterator());
+ scheduler.schedule(new SchedulerTask(engine, folderName),
+ new DeploymentIterator());
}
private AxisConfiguration createEngineConfig() {
@@ -367,12 +398,16 @@
ArrayList list = currentArchiveFile.getModules();
for (int i = 0; i < list.size(); i++) {
- ModuleDescription module = axisConfig.getModule((QName) list.get(i));
+ ModuleDescription module = axisConfig.getModule(
+ (QName) list.get(i));
if (module != null) {
serviceMetaData.engageModule(module);
} else {
- throw new DeploymentException("Service " + serviceMetaData.getName().getLocalPart() +
- " Refer to invalide module " + ((QName) list.get(i)).getLocalPart());
+ throw new DeploymentException(
+ "Service " +
+ serviceMetaData.getName().getLocalPart() +
+ " Refer to invalide module " +
+ ((QName) list.get(i)).getLocalPart());
}
}
@@ -387,15 +422,21 @@
if (module != null) {
opDesc.engageModule(module);
} else {
- throw new DeploymentException("Operation " + opDesc.getName().getLocalPart() +
- " Refer to invalide module " + moduleName.getLocalPart());
+ throw new DeploymentException(
+ "Operation " + opDesc.getName().getLocalPart() +
+ " Refer to invalide module " +
+ moduleName.getLocalPart());
}
}
}
///factory.createChains(serviceMetaData, axisConfig, );
- System.out.println("service Description : " + serviceMetaData.getServiceDescription());
- System.out.println("adding new service : " + serviceMetaData.getName().getLocalPart());
+ System.out.println(
+ "service Description : " +
+ serviceMetaData.getServiceDescription());
+ System.out.println(
+ "adding new service : " +
+ serviceMetaData.getName().getLocalPart());
} catch (PhaseException e) {
throw new AxisFault(e);
}
@@ -438,7 +479,10 @@
try {
String readInClass = currentArchiveFile.getModuleClass();
if (readInClass != null && !"".equals(readInClass)) {
- moduleClass = Class.forName(readInClass, true, currentArchiveFile.getClassLoader());
+ moduleClass =
+ Class.forName(readInClass,
+ true,
+ currentArchiveFile.getClassLoader());
module.setModule((Module) moduleClass.newInstance());
}
} catch (Exception e) {
@@ -540,31 +584,52 @@
case SERVICE:
try {
// ServiceDescription service = archiveReader.createService(currentArchiveFile.getAbsolutePath());
- ServiceDescription service = archiveReader.createService(currentArchiveFile);
- archiveReader.readServiceArchive(currentArchiveFile.getAbsolutePath(), this, service);
+ ServiceDescription service = archiveReader.createService(
+ currentArchiveFile);
+ archiveReader.readServiceArchive(
+ currentArchiveFile.getAbsolutePath(),
+ this,
+ service);
addnewService(service);
- log.info("Deployement WS Name " + currentArchiveFile.getName());
+ log.info(
+ "Deployement WS Name " +
+ currentArchiveFile.getName());
} catch (DeploymentException de) {
- log.info("Invalid service" + currentArchiveFile.getName());
+ log.info(
+ "Invalid service" +
+ currentArchiveFile.getName());
log.info("DeploymentException " + de);
- PrintWriter error_ptintWriter = new PrintWriter(errorWriter);
+ PrintWriter error_ptintWriter = new PrintWriter(
+ errorWriter);
de.printStackTrace(error_ptintWriter);
- serviceStatus = "Error:\n" + errorWriter.toString();
+ serviceStatus = "Error:\n" +
+ errorWriter.toString();
} catch (AxisFault axisFault) {
- log.info("Invalid service" + currentArchiveFile.getName());
+ log.info(
+ "Invalid service" +
+ currentArchiveFile.getName());
log.info("AxisFault " + axisFault);
- PrintWriter error_ptintWriter = new PrintWriter(errorWriter);
+ PrintWriter error_ptintWriter = new PrintWriter(
+ errorWriter);
axisFault.printStackTrace(error_ptintWriter);
- serviceStatus = "Error:\n" + errorWriter.toString();
+ serviceStatus = "Error:\n" +
+ errorWriter.toString();
} catch (Exception e) {
- log.info("Invalid service" + currentArchiveFile.getName());
+ log.info(
+ "Invalid service" +
+ currentArchiveFile.getName());
log.info("Exception " + e);
- PrintWriter error_ptintWriter = new PrintWriter(errorWriter);
+ PrintWriter error_ptintWriter = new PrintWriter(
+ errorWriter);
e.printStackTrace(error_ptintWriter);
- serviceStatus = "Error:\n" + errorWriter.toString();
+ serviceStatus = "Error:\n" +
+ errorWriter.toString();
} finally {
if (serviceStatus.startsWith("Error:")) {
- axisConfig.getFaulytServices().put(getAxisServiceName(currentArchiveFile.getName()), serviceStatus);
+ axisConfig.getFaulytServices().put(
+ getAxisServiceName(
+ currentArchiveFile.getName()),
+ serviceStatus);
}
currentArchiveFile = null;
}
@@ -573,24 +638,40 @@
String moduleStatus = "";
try {
ModuleDescription metaData = new ModuleDescription();
- archiveReader.readModuleArchive(currentArchiveFile.getAbsolutePath(), this, metaData);
+ archiveReader.readModuleArchive(
+ currentArchiveFile.getAbsolutePath(),
+ this,
+ metaData);
addNewModule(metaData);
- log.info("Moduel WS Name " + currentArchiveFile.getName() + " modulename :" + metaData.getName());
+ log.info(
+ "Moduel WS Name " +
+ currentArchiveFile.getName() +
+ " modulename :" +
+ metaData.getName());
} catch (DeploymentException e) {
- log.info("Invalid module" + currentArchiveFile.getName());
+ log.info(
+ "Invalid module" +
+ currentArchiveFile.getName());
log.info("DeploymentException " + e);
- PrintWriter error_ptintWriter = new PrintWriter(errorWriter);
+ PrintWriter error_ptintWriter = new PrintWriter(
+ errorWriter);
e.printStackTrace(error_ptintWriter);
moduleStatus = "Error:\n" + errorWriter.toString();
} catch (AxisFault axisFault) {
- log.info("Invalid module" + currentArchiveFile.getName());
+ log.info(
+ "Invalid module" +
+ currentArchiveFile.getName());
log.info("AxisFault " + axisFault);
- PrintWriter error_ptintWriter = new PrintWriter(errorWriter);
+ PrintWriter error_ptintWriter = new PrintWriter(
+ errorWriter);
axisFault.printStackTrace(error_ptintWriter);
moduleStatus = "Error:\n" + errorWriter.toString();
} finally {
if (moduleStatus.startsWith("Error:")) {
- axisConfig.getFaulytModules().put(getAxisServiceName(currentArchiveFile.getName()), moduleStatus);
+ axisConfig.getFaulytModules().put(
+ getAxisServiceName(
+ currentArchiveFile.getName()),
+ moduleStatus);
}
currentArchiveFile = null;
}
@@ -611,7 +692,9 @@
if (wsInfo.getType() == SERVICE) {
serviceName = getAxisServiceName(wsInfo.getFilename());
axisConfig.removeService(new QName(serviceName));
- log.info("UnDeployement WS Name " + wsInfo.getFilename());
+ log.info(
+ "UnDeployement WS Name " +
+ wsInfo.getFilename());
}
axisConfig.getFaulytServices().remove(serviceName);
}
@@ -695,11 +778,14 @@
* @return
* @throws DeploymentException
*/
- public ServiceDescription buildService(ServiceDescription axisService, InputStream serviceInputStream, ClassLoader classLoader) throws DeploymentException {
+ public ServiceDescription buildService(ServiceDescription axisService,
+ InputStream serviceInputStream,
+ ClassLoader classLoader) throws DeploymentException {
try {
currentArchiveFile = new ArchiveFileData(SERVICE, "");
currentArchiveFile.setClassLoader(classLoader);
- DeploymentParser schme = new DeploymentParser(serviceInputStream, this);
+ DeploymentParser schme = new DeploymentParser(serviceInputStream,
+ this);
schme.parseServiceXML(axisService);
loadServiceProperties(axisService);
axisConfig.addService(axisService);
@@ -725,7 +811,8 @@
currentArchiveFile = new ArchiveFileData(modulearchive, MODULE);
axismodule = new ModuleDescription();
ArchiveReader archiveReader = new ArchiveReader();
- archiveReader.readModuleArchive(currentArchiveFile.getAbsolutePath(), this, axismodule);
+ archiveReader.readModuleArchive(
+ currentArchiveFile.getAbsolutePath(), this, axismodule);
currentArchiveFile.setClassLoader();
Flow inflow = axismodule.getInFlow();
if (inflow != null) {