← Back to branch summary

~ubuntu-core-dev/eucalyptus/ubuntu-karmic

« back to all changes in this revision

Viewing changes to clc/modules/axis2-transport/src/edu/ucsb/eucalyptus/transport/Axis2InOutMessageReceiver.java

  • Committer: Dmitrii Zagorodnov
  • Date: 2009-01-27 21:53:41 UTC
  • mfrom: (25.1.112 eucalyptus-main)
  • Revision ID: dmitrii@cs.ucsb.edu-20090127215341-i0f0v6cmbpljmg02
merged with current main

Show diffs side-by-side

added added

removed removed

Lines of Context:
clc/modules/axis2-transport/src/edu/ucsb/eucalyptus/transport/Axis2InOutMessageReceiver.java
37
37
 
38
38
import edu.ucsb.eucalyptus.cloud.EucalyptusCloudException;
39
39
import edu.ucsb.eucalyptus.msgs.*;
40
 
import edu.ucsb.eucalyptus.transport.binding.*;
 
40
import edu.ucsb.eucalyptus.transport.binding.Binding;
 
41
import edu.ucsb.eucalyptus.transport.binding.BindingManager;
41
42
import edu.ucsb.eucalyptus.transport.http.Axis2HttpWorker;
42
 
import edu.ucsb.eucalyptus.transport.query.*;
43
 
import edu.ucsb.eucalyptus.util.*;
 
43
import edu.ucsb.eucalyptus.transport.query.GenericHttpDispatcher;
 
44
import edu.ucsb.eucalyptus.transport.query.HttpRequest;
 
45
import edu.ucsb.eucalyptus.util.BindingUtil;
 
46
import edu.ucsb.eucalyptus.util.WalrusProperties;
44
47
import org.apache.axiom.om.OMElement;
45
 
import org.apache.axiom.soap.*;
 
48
import org.apache.axiom.soap.SOAPEnvelope;
 
49
import org.apache.axiom.soap.SOAPFactory;
46
50
import org.apache.axis2.AxisFault;
47
51
import org.apache.axis2.context.MessageContext;
48
52
import org.apache.axis2.description.AxisOperation;
54
58
import org.apache.log4j.Logger;
55
59
import org.apache.neethi.Policy;
56
60
import org.apache.rampart.RampartMessageData;
57
 
import org.apache.tools.ant.util.DateUtils;
58
61
import org.apache.ws.security.WSSecurityEngineResult;
59
 
import org.apache.ws.security.handler.*;
 
62
import org.apache.ws.security.handler.WSHandlerConstants;
 
63
import org.apache.ws.security.handler.WSHandlerResult;
60
64
import org.jibx.runtime.JiBXException;
61
65
import org.mule.DefaultMuleMessage;
62
 
import org.mule.api.*;
 
66
import org.mule.api.MuleException;
 
67
import org.mule.api.MuleMessage;
63
68
import org.mule.config.ExceptionHelper;
64
69
 
65
70
import java.security.cert.X509Certificate;
66
 
import java.util.*;
 
71
import java.util.List;
 
72
import java.util.Vector;
67
73
 
68
74
public class Axis2InOutMessageReceiver extends AbstractInOutMessageReceiver {
69
75
 
126
132
            return;
127
133
        }
128
134
 
 
135
   /*     if(message.getPayload() instanceof WalrusDeleteResponseType) {
 
136
            msgContext.setProperty(Axis2HttpWorker.HTTP_STATUS, HttpStatus.SC_NO_CONTENT);
 
137
            newMsgContext.setProperty(Axis2HttpWorker.HTTP_STATUS, HttpStatus.SC_NO_CONTENT);
 
138
            return;
 
139
        } */
 
140
 
129
141
        Boolean putType = (Boolean) msgContext.getProperty(WalrusProperties.STREAMING_HTTP_PUT);
130
142
        Boolean getType = (Boolean) msgContext.getProperty(WalrusProperties.STREAMING_HTTP_GET);
131
143
        if(getType != null || putType != null) {
254
266
 
255
267
    private void verifyUser( MessageContext msgContext, EucalyptusMessage msg ) throws EucalyptusCloudException
256
268
    {
257
 
      Vector<WSHandlerResult> wsResults = ( Vector<WSHandlerResult> ) msgContext.getProperty( WSHandlerConstants.RECV_RESULTS );
258
 
      for ( WSHandlerResult wsResult : wsResults )
259
 
        if ( wsResult.getResults() != null )
260
 
          for ( WSSecurityEngineResult engResult : ( Vector<WSSecurityEngineResult> ) wsResult.getResults() )
261
 
            if ( engResult.containsKey( WSSecurityEngineResult.TAG_X509_CERTIFICATE ) )
262
 
            {
263
 
              X509Certificate cert = ( X509Certificate ) engResult.get( WSSecurityEngineResult.TAG_X509_CERTIFICATE );
264
 
              msg = this.msgReceiver.getProperties().getAuthenticator().authenticate( cert, msg );
265
 
            }
 
269
        Vector<WSHandlerResult> wsResults = ( Vector<WSHandlerResult> ) msgContext.getProperty( WSHandlerConstants.RECV_RESULTS );
 
270
        for ( WSHandlerResult wsResult : wsResults )
 
271
            if ( wsResult.getResults() != null )
 
272
                for ( WSSecurityEngineResult engResult : ( Vector<WSSecurityEngineResult> ) wsResult.getResults() )
 
273
                    if ( engResult.containsKey( WSSecurityEngineResult.TAG_X509_CERTIFICATE ) )
 
274
                    {
 
275
                        X509Certificate cert = ( X509Certificate ) engResult.get( WSSecurityEngineResult.TAG_X509_CERTIFICATE );
 
276
                        msg = this.msgReceiver.getProperties().getAuthenticator().authenticate( cert, msg );
 
277
                    }
266
278
    }
267
279
 
268
280
}