import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public void engageNotify(AxisDescription axisDescription) throws AxisFault {

        if (log.isDebugEnabled()) {
            log.debug("MTOMPolicy module has been engaged to "
                    + axisDescription.getClass().getName());
        }

        AxisService axisService = Utils.locateAxisService(axisDescription);

        if (axisService == null) {
            if (log.isDebugEnabled()) {
                log.debug("MTOMPolicy module couldn't find the Axis Service ");
            }
            return;
        }

        Parameter param = axisService
                .getParameter(Constants.Configuration.ENABLE_MTOM);

        Policy mtomPolicy = Utils.getMTOMPolicy(param);

        if (mtomPolicy != null) {
            Utils.applyPolicyToSOAPBindings(axisService, mtomPolicy);
        }

    }
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
private static ArrayList getHeaderParameterList(AxisDescription axisDescription, String paramName) {        
    Parameter headerQNamesParameter = axisDescription.getParameter(paramName);
    if (headerQNamesParameter == null) {
        if (log.isDebugEnabled()) {
            log.debug("Parameter not on " + axisDescription + "; " 
                      + paramName);
        }
        return null;
    }

    ArrayList understoodHeaderQNames = (ArrayList) headerQNamesParameter.getValue();
    if (understoodHeaderQNames == null || understoodHeaderQNames.isEmpty()) {
        if (log.isDebugEnabled()) {
            log.debug("Parameter value is empty: "  + axisDescription + "; " 
                      + paramName);
        }
        return null;
    }

    return understoodHeaderQNames;
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public static String getAddressingRequirementParemeterValue(AxisDescription axisDescription){
	String value = "";
    if (axisDescription != null) {
        value = Utils.getParameterValue(
        		axisDescription.getParameter(AddressingConstants.ADDRESSING_REQUIREMENT_PARAMETER));
        if(value !=null){
        	value = value.trim();
        }
        if (LoggingControl.debugLoggingAllowed && log.isDebugEnabled()) {
            log.debug("getAddressingRequirementParemeterValue: value: '" + value + "'");
        }
    }

    if (value == null || "".equals(value)) {
        value = AddressingConstants.ADDRESSING_UNSPECIFIED;
    }
    return value;
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
private AxisDescription getUpperLevel(short type, AxisDescription thisLevel) {
    
    switch (type) {
    case AXIS_BINDING_MESSAGE:
        return ((AxisBindingMessage) thisLevel).getAxisBindingOperation();
    case AXIS_BINDING_OPERATION:
        return ((AxisBindingOperation) thisLevel).getAxisBinding();
    case AXIS_BINDING:
        return ((AxisBinding) thisLevel).getAxisEndpoint();
    case AXIS_ENDPOINT:
        return ((AxisEndpoint) thisLevel).getAxisService();
    case AXIS_MESSAGE:
    	return ((AxisMessage) thisLevel).getAxisOperation();
    case AXIS_OPERATION:
    	return ((AxisOperation) thisLevel).getAxisService();
    case AXIS_SERVICE:
        return ((AxisService) thisLevel).getAxisServiceGroup();
    case AXIS_SERVICE_GROUP:
        return ((AxisServiceGroup) thisLevel).getAxisConfiguration();
    default:
        return null;
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
private short getType(AxisDescription description) {
    
    if (description instanceof AxisBindingMessage) {
        return AXIS_BINDING_MESSAGE;
    } else if (description instanceof AxisMessage) {
        return AXIS_MESSAGE;
    } else if (description instanceof AxisBindingOperation) {
        return AXIS_BINDING_OPERATION;
    } else if (description instanceof AxisOperation) {
        return AXIS_OPERATION;
    } else if (description instanceof AxisBinding) {
        return AXIS_BINDING;
    } else if (description instanceof AxisEndpoint) {
        return AXIS_ENDPOINT;
    } else if (description instanceof AxisService) {
        return AXIS_SERVICE;
    } else if (description instanceof AxisServiceGroup) {
        return AXIS_SERVICE_GROUP;
    } else if (description instanceof AxisConfiguration) {
        return AXIS_CONFIGURATION;
    }
    
    return -1;
    
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public void applyPolicy(Policy policy, AxisDescription axisDescription)
        throws AxisFault {
    if (log.isDebugEnabled()) {
        log.debug("applyPolicy() called on MTOMPolicy module");
    }
    
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
/**
 * Extracts the MTOM assertion object if it is exists into the policy based on a given {@link AxisDescription}.
 * 
 * @param axisDescription the {@link AxisDescription} object that should be searched.
 * @return {@link MTOMAssertion}  the {@link MTOMAssertion} found. If it is not found "null" is returned.
 */
public static MTOMAssertion getMTOMAssertion(AxisDescription axisDescription) {

    if (axisDescription == null) {
        if (log.isDebugEnabled()) {
            log.debug("AxisDescription passed as parameter has a \"null\" value.");
        }        	
        return null;
    }

    ArrayList policyList = new ArrayList();
    policyList.addAll(axisDescription.getPolicySubject()
            .getAttachedPolicyComponents());

    Policy policy = PolicyUtil.getMergedPolicy(policyList, axisDescription);

    if (policy == null) {
        return null;
    }

    List<Assertion> list = (List<Assertion>) policy.getAlternatives()
            .next();

    for (Assertion assertion : list) {
        if (assertion instanceof MTOMAssertion) {
            return (MTOMAssertion) assertion;
        }
    }

    return null;

}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
/**
 * Locates the {@link AxisService} object searching up in the hierarchy recursively </br>
 * the {@link AxisDescription} object passed.
 *   
 * @param axisDescription the {@link AxisDescription} object that should be checked.
 * @return the {@link AxisService} object found or "null".
 */
public static AxisService locateAxisService(AxisDescription axisDescription) {

    if (axisDescription == null || axisDescription instanceof AxisService) {
        return (AxisService) axisDescription;
    } else {
        return locateAxisService(axisDescription.getParent());
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
/**
 * Check that if the wsaddressing="required" attribute exists on the service definition
 * (or AddressingFeature on the client) or <wsaw:UsingAddressing wsdl:required="true" />
 * was found in the WSDL (provider side only) that WS-Addressing headers were found on
 * the inbound message.
 */
private void checkUsingAddressing(MessageContext msgContext)
        throws AxisFault {
    String addressingFlag;
    if (!msgContext.isServerSide()) {
        // On client side, get required value from the request message context
        // (set by AddressingConfigurator).
        // We do not use the UsingAddressing required attribute on the
        // client side since it is not generated/processed by java tooling.
        addressingFlag = AddressingHelper.getRequestAddressingRequirementParameterValue(msgContext);
        if (log.isTraceEnabled()) {
            log.trace("checkUsingAddressing: WSAddressingFlag from MessageContext=" + addressingFlag);
        }
    } else {
        // On provider side, get required value from AxisOperation
        // (set by AddressingConfigurator and UsingAddressing WSDL processing).
        AxisDescription ad = msgContext.getAxisService();
        if(msgContext.getAxisOperation()!=null){
    	   ad = msgContext.getAxisOperation();
        }
        addressingFlag =
            AddressingHelper.getAddressingRequirementParemeterValue(ad);
        if (log.isTraceEnabled()) {
            log.trace("checkUsingAddressing: WSAddressingFlag from AxisOperation=" + addressingFlag);
        }
    }
    if (AddressingConstants.ADDRESSING_REQUIRED.equals(addressingFlag)) {
        AddressingFaultsHelper.triggerMessageAddressingRequiredFault(msgContext,
                                                                     AddressingConstants.WSA_ACTION);
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public void onEngage(AxisModule module, AxisDescription engager) throws AxisFault {
    Iterator<AxisServiceGroup> servicegroups = getServiceGroups();
    while (servicegroups.hasNext()) {
        AxisServiceGroup serviceGroup = servicegroups.next();
        serviceGroup.engageModule(module, engager);
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public static void addWSDLDocumentationElement(AxisDescription axisDescription,
                                               OMElement omElement, OMFactory omFactory,
                                               OMNamespace wsdl) {
    OMNode documentationNode = axisDescription.getDocumentationNode();
    OMElement documentation;
    if (documentationNode != null) {
        documentation = omFactory.createOMElement(WSDL2Constants.DOCUMENTATION, wsdl);
        documentation.addChild(documentationNode);
        omElement.addChild(documentation);
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
private static AxisService getAxisService(AxisDescription description) {
	if (description == null || description instanceof AxisService) {
		return (AxisService) description;
	} else {
		return getAxisService(description.getParent());
	}
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public static String generateId(AxisDescription description) {
	PolicyInclude policyInclude = description.getPolicyInclude();
	String identifier = "-policy-1";

	if (description instanceof AxisMessage) {
		identifier = "msg-" + ((AxisMessage) description).getName()
				+ identifier;
		description = description.getParent();
	}

	if (description instanceof AxisOperation) {
		identifier = "op-" + ((AxisOperation) description).getName()
				+ identifier;
		description = description.getParent();
	}

	if (description instanceof AxisService) {
		identifier = "service-" + ((AxisService) description).getName()
				+ identifier;
	}

	/*
	 * Int 49 is the value of the Character '1'. Here we want to change '1'
	 * to '2' or '2' to '3' .. etc. to construct a unique identifier.
	 */
	for (int index = 49; policyInclude.getPolicy(identifier) != null; index++) {
		identifier = identifier.replace((char) index, (char) (index + 1));
	}

	return identifier;
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public static void enguage(AxisDescription axisDescription) throws AxisFault {
    CacheConfiguration cacheConfig;
    PolicySubject policySubject = axisDescription.getPolicySubject();

    if (policySubject != null) {
        try {
            cacheConfig = CachingPolicyProcessor.processCachingPolicy(policySubject);
        } catch (CachingException e) {
            if (log.isDebugEnabled()) {
                log.debug("Unable to engage the caching module:" +
                          "Error in processing caching policy", e);
            }
            throw new AxisFault("Unable to engage the caching module:" +
                                "Error in processing caching policy");
        }
    } else {
        if (log.isDebugEnabled()) {
            log.debug("Using the default initializer for the CacheConfiguration");
        }
        cacheConfig = new CacheConfiguration();
    }

    // if there is a caching policy, set the cache config if not inherited from the parent
    if (cacheConfig != null) {
        axisDescription.addParameter(CachingConstants.CACHE_CONFIGURATION, cacheConfig);
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public void serviceUpdate(AxisEvent axisEvent, AxisService axisService) {
    log.debug("ThrottleObserver notified for a serviceUpdate.");

    AxisDescription axisDescription = axisEvent.getAxisDescription();
    if (axisDescription.isEngaged(axisService.getAxisConfiguration().
            getModule(ThrottleConstants.THROTTLE_MODULE_NAME))) {
        if (axisEvent.getEventType() == AxisEvent.POLICY_ADDED) {
            try {
                ThrottleEnguageUtils.enguage(axisDescription, configctx, defautThrottle);
            } catch (AxisFault axisFault) {
                log.error("Error while re-engaging throttling", axisFault);
            }
        }
    }
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
public void engageNotify(AxisDescription axisDescription) throws AxisFault {
    if (axisDescription instanceof AxisService){
        AxisService axisService = (AxisService) axisDescription;
        System.out.println("Engaged to the service ==> " + axisService.getName());
    } else if (axisDescription instanceof AxisOperation){
        AxisOperation axisOperation = (AxisOperation) axisDescription;
        System.out.println("Engaged to the operation ==> " + axisOperation.getName().getLocalPart());
    }

}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
@Override
public void engageNotify(AxisDescription axisDescription)
        throws AxisFault {
    // Do Nothing
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
@Override
public void applyPolicy(Policy policy, AxisDescription axisDescription) throws AxisFault {
    // Do Nothing
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
@Override
public void engageNotify(final AxisDescription ad) throws AxisFault {
}
 

import org.apache.axis2.description.AxisDescription; //导入依赖的package包/类
@Override
public void applyPolicy(final Policy policy, final AxisDescription ad) throws AxisFault {
    throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}