Java源码示例：com.sun.xml.internal.ws.policy.sourcemodel.PolicySourceModel
示例1
final Collection<Policy> getPolicies() throws PolicyException {
if (null == policyURIs) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1004_POLICY_URIS_CAN_NOT_BE_NULL()));
}
if (null == policyStore) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1010_NO_POLICIES_DEFINED()));
}
final Collection<Policy> result = new ArrayList<Policy>(policyURIs.size());
for (String policyURI : policyURIs) {
final PolicySourceModel sourceModel = policyStore.get(policyURI);
if (sourceModel == null) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1005_POLICY_REFERENCE_DOES_NOT_EXIST(policyURI)));
} else {
result.add(ModelTranslator.getTranslator().translate(sourceModel));
}
}
return result;
}
示例2
/**
* Adds a PolicyReference element that points to the policy of the element,
* if the policy does not have any id or name. Writes policy inside the element otherwise.
*
* @param subject
* PolicySubject to be referenced or marshalled
* @param writer
* A TXW on to which we shall add the PolicyReference
*/
private void writePolicyOrReferenceIt(final PolicySubject subject, final TypedXmlWriter writer) {
final Policy policy;
try {
policy = subject.getEffectivePolicy(merger);
} catch (PolicyException e) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1011_FAILED_TO_RETRIEVE_EFFECTIVE_POLICY_FOR_SUBJECT(subject.toString()), e));
}
if (policy != null) {
if (null == policy.getIdOrName()) {
final PolicyModelGenerator generator = ModelGenerator.getGenerator();
try {
final PolicySourceModel policyInfoset = generator.translate(policy);
marshaller.marshal(policyInfoset, writer);
} catch (PolicyException pe) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1002_UNABLE_TO_MARSHALL_POLICY_OR_POLICY_REFERENCE(), pe));
}
} else {
final TypedXmlWriter policyReference = writer._element(policy.getNamespaceVersion().asQName(XmlToken.PolicyReference), TypedXmlWriter.class);
policyReference._attribute(XmlToken.Uri.toString(), '#' + policy.getIdOrName());
}
}
}
示例3
private Collection<String> getPolicyURIs(
final Collection<PolicyRecordHandler> handlers, final PolicySourceModelContext modelContext) throws PolicyException{
final Collection<String> result = new ArrayList<String>(handlers.size());
String policyUri;
for (PolicyRecordHandler handler : handlers) {
policyUri = handler.handler;
if (HandlerType.AnonymousPolicyId == handler.type) {
final PolicySourceModel policyModel = getAnonymousPolicyModels().get(policyUri);
policyModel.expand(modelContext);
while (getPolicyModels().containsKey(policyUri)) {
policyUri = AnonymnousPolicyIdPrefix.append(anonymousPoliciesCount++).toString();
}
getPolicyModels().put(policyUri,policyModel);
}
result.add(policyUri);
}
return result;
}
示例4
final Collection<Policy> getPolicies() throws PolicyException {
if (null == policyURIs) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1004_POLICY_URIS_CAN_NOT_BE_NULL()));
}
if (null == policyStore) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1010_NO_POLICIES_DEFINED()));
}
final Collection<Policy> result = new ArrayList<Policy>(policyURIs.size());
for (String policyURI : policyURIs) {
final PolicySourceModel sourceModel = policyStore.get(policyURI);
if (sourceModel == null) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1005_POLICY_REFERENCE_DOES_NOT_EXIST(policyURI)));
} else {
result.add(ModelTranslator.getTranslator().translate(sourceModel));
}
}
return result;
}
示例5
/**
* Adds a PolicyReference element that points to the policy of the element,
* if the policy does not have any id or name. Writes policy inside the element otherwise.
*
* @param subject
* PolicySubject to be referenced or marshalled
* @param writer
* A TXW on to which we shall add the PolicyReference
*/
private void writePolicyOrReferenceIt(final PolicySubject subject, final TypedXmlWriter writer) {
final Policy policy;
try {
policy = subject.getEffectivePolicy(merger);
} catch (PolicyException e) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1011_FAILED_TO_RETRIEVE_EFFECTIVE_POLICY_FOR_SUBJECT(subject.toString()), e));
}
if (policy != null) {
if (null == policy.getIdOrName()) {
final PolicyModelGenerator generator = ModelGenerator.getGenerator();
try {
final PolicySourceModel policyInfoset = generator.translate(policy);
marshaller.marshal(policyInfoset, writer);
} catch (PolicyException pe) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1002_UNABLE_TO_MARSHALL_POLICY_OR_POLICY_REFERENCE(), pe));
}
} else {
final TypedXmlWriter policyReference = writer._element(policy.getNamespaceVersion().asQName(XmlToken.PolicyReference), TypedXmlWriter.class);
policyReference._attribute(XmlToken.Uri.toString(), '#' + policy.getIdOrName());
}
}
}
示例6
private Collection<String> getPolicyURIs(
final Collection<PolicyRecordHandler> handlers, final PolicySourceModelContext modelContext) throws PolicyException{
final Collection<String> result = new ArrayList<String>(handlers.size());
String policyUri;
for (PolicyRecordHandler handler : handlers) {
policyUri = handler.handler;
if (HandlerType.AnonymousPolicyId == handler.type) {
final PolicySourceModel policyModel = getAnonymousPolicyModels().get(policyUri);
policyModel.expand(modelContext);
while (getPolicyModels().containsKey(policyUri)) {
policyUri = AnonymnousPolicyIdPrefix.append(anonymousPoliciesCount++).toString();
}
getPolicyModels().put(policyUri,policyModel);
}
result.add(policyUri);
}
return result;
}
示例7
/**
* Adds a PolicyReference element that points to the policy of the element,
* if the policy does not have any id or name. Writes policy inside the element otherwise.
*
* @param subject
* PolicySubject to be referenced or marshalled
* @param writer
* A TXW on to which we shall add the PolicyReference
*/
private void writePolicyOrReferenceIt(final PolicySubject subject, final TypedXmlWriter writer) {
final Policy policy;
try {
policy = subject.getEffectivePolicy(merger);
} catch (PolicyException e) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1011_FAILED_TO_RETRIEVE_EFFECTIVE_POLICY_FOR_SUBJECT(subject.toString()), e));
}
if (policy != null) {
if (null == policy.getIdOrName()) {
final PolicyModelGenerator generator = ModelGenerator.getGenerator();
try {
final PolicySourceModel policyInfoset = generator.translate(policy);
marshaller.marshal(policyInfoset, writer);
} catch (PolicyException pe) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1002_UNABLE_TO_MARSHALL_POLICY_OR_POLICY_REFERENCE(), pe));
}
} else {
final TypedXmlWriter policyReference = writer._element(policy.getNamespaceVersion().asQName(XmlToken.PolicyReference), TypedXmlWriter.class);
policyReference._attribute(XmlToken.Uri.toString(), '#' + policy.getIdOrName());
}
}
}
示例8
final Collection<Policy> getPolicies() throws PolicyException {
if (null == policyURIs) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1004_POLICY_URIS_CAN_NOT_BE_NULL()));
}
if (null == policyStore) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1010_NO_POLICIES_DEFINED()));
}
final Collection<Policy> result = new ArrayList<Policy>(policyURIs.size());
for (String policyURI : policyURIs) {
final PolicySourceModel sourceModel = policyStore.get(policyURI);
if (sourceModel == null) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1005_POLICY_REFERENCE_DOES_NOT_EXIST(policyURI)));
} else {
result.add(ModelTranslator.getTranslator().translate(sourceModel));
}
}
return result;
}
示例9
/**
* Adds a PolicyReference element that points to the policy of the element,
* if the policy does not have any id or name. Writes policy inside the element otherwise.
*
* @param subject
* PolicySubject to be referenced or marshalled
* @param writer
* A TXW on to which we shall add the PolicyReference
*/
private void writePolicyOrReferenceIt(final PolicySubject subject, final TypedXmlWriter writer) {
final Policy policy;
try {
policy = subject.getEffectivePolicy(merger);
} catch (PolicyException e) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1011_FAILED_TO_RETRIEVE_EFFECTIVE_POLICY_FOR_SUBJECT(subject.toString()), e));
}
if (policy != null) {
if (null == policy.getIdOrName()) {
final PolicyModelGenerator generator = ModelGenerator.getGenerator();
try {
final PolicySourceModel policyInfoset = generator.translate(policy);
marshaller.marshal(policyInfoset, writer);
} catch (PolicyException pe) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1002_UNABLE_TO_MARSHALL_POLICY_OR_POLICY_REFERENCE(), pe));
}
} else {
final TypedXmlWriter policyReference = writer._element(policy.getNamespaceVersion().asQName(XmlToken.PolicyReference), TypedXmlWriter.class);
policyReference._attribute(XmlToken.Uri.toString(), '#' + policy.getIdOrName());
}
}
}
示例10
private Collection<String> getPolicyURIs(
final Collection<PolicyRecordHandler> handlers, final PolicySourceModelContext modelContext) throws PolicyException{
final Collection<String> result = new ArrayList<String>(handlers.size());
String policyUri;
for (PolicyRecordHandler handler : handlers) {
policyUri = handler.handler;
if (HandlerType.AnonymousPolicyId == handler.type) {
final PolicySourceModel policyModel = getAnonymousPolicyModels().get(policyUri);
policyModel.expand(modelContext);
while (getPolicyModels().containsKey(policyUri)) {
policyUri = AnonymnousPolicyIdPrefix.append(anonymousPoliciesCount++).toString();
}
getPolicyModels().put(policyUri,policyModel);
}
result.add(policyUri);
}
return result;
}
示例11
final Collection<Policy> getPolicies() throws PolicyException {
if (null == policyURIs) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1004_POLICY_URIS_CAN_NOT_BE_NULL()));
}
if (null == policyStore) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1010_NO_POLICIES_DEFINED()));
}
final Collection<Policy> result = new ArrayList<Policy>(policyURIs.size());
for (String policyURI : policyURIs) {
final PolicySourceModel sourceModel = policyStore.get(policyURI);
if (sourceModel == null) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1005_POLICY_REFERENCE_DOES_NOT_EXIST(policyURI)));
} else {
result.add(ModelTranslator.getTranslator().translate(sourceModel));
}
}
return result;
}
示例12
final Collection<Policy> getPolicies() throws PolicyException {
if (null == policyURIs) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1004_POLICY_URIS_CAN_NOT_BE_NULL()));
}
if (null == policyStore) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1010_NO_POLICIES_DEFINED()));
}
final Collection<Policy> result = new ArrayList<Policy>(policyURIs.size());
for (String policyURI : policyURIs) {
final PolicySourceModel sourceModel = policyStore.get(policyURI);
if (sourceModel == null) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1005_POLICY_REFERENCE_DOES_NOT_EXIST(policyURI)));
} else {
result.add(ModelTranslator.getTranslator().translate(sourceModel));
}
}
return result;
}
示例13
private Collection<String> getPolicyURIs(
final Collection<PolicyRecordHandler> handlers, final PolicySourceModelContext modelContext) throws PolicyException{
final Collection<String> result = new ArrayList<String>(handlers.size());
String policyUri;
for (PolicyRecordHandler handler : handlers) {
policyUri = handler.handler;
if (HandlerType.AnonymousPolicyId == handler.type) {
final PolicySourceModel policyModel = getAnonymousPolicyModels().get(policyUri);
policyModel.expand(modelContext);
while (getPolicyModels().containsKey(policyUri)) {
policyUri = AnonymnousPolicyIdPrefix.append(anonymousPoliciesCount++).toString();
}
getPolicyModels().put(policyUri,policyModel);
}
result.add(policyUri);
}
return result;
}
示例14
/**
* Adds a PolicyReference element that points to the policy of the element,
* if the policy does not have any id or name. Writes policy inside the element otherwise.
*
* @param subject
* PolicySubject to be referenced or marshalled
* @param writer
* A TXW on to which we shall add the PolicyReference
*/
private void writePolicyOrReferenceIt(final PolicySubject subject, final TypedXmlWriter writer) {
final Policy policy;
try {
policy = subject.getEffectivePolicy(merger);
} catch (PolicyException e) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1011_FAILED_TO_RETRIEVE_EFFECTIVE_POLICY_FOR_SUBJECT(subject.toString()), e));
}
if (policy != null) {
if (null == policy.getIdOrName()) {
final PolicyModelGenerator generator = ModelGenerator.getGenerator();
try {
final PolicySourceModel policyInfoset = generator.translate(policy);
marshaller.marshal(policyInfoset, writer);
} catch (PolicyException pe) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1002_UNABLE_TO_MARSHALL_POLICY_OR_POLICY_REFERENCE(), pe));
}
} else {
final TypedXmlWriter policyReference = writer._element(policy.getNamespaceVersion().asQName(XmlToken.PolicyReference), TypedXmlWriter.class);
policyReference._attribute(XmlToken.Uri.toString(), '#' + policy.getIdOrName());
}
}
}
示例15
private Collection<String> getPolicyURIs(
final Collection<PolicyRecordHandler> handlers, final PolicySourceModelContext modelContext) throws PolicyException{
final Collection<String> result = new ArrayList<String>(handlers.size());
String policyUri;
for (PolicyRecordHandler handler : handlers) {
policyUri = handler.handler;
if (HandlerType.AnonymousPolicyId == handler.type) {
final PolicySourceModel policyModel = getAnonymousPolicyModels().get(policyUri);
policyModel.expand(modelContext);
while (getPolicyModels().containsKey(policyUri)) {
policyUri = AnonymnousPolicyIdPrefix.append(anonymousPoliciesCount++).toString();
}
getPolicyModels().put(policyUri,policyModel);
}
result.add(policyUri);
}
return result;
}
示例16
final Collection<Policy> getPolicies() throws PolicyException {
if (null == policyURIs) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1004_POLICY_URIS_CAN_NOT_BE_NULL()));
}
if (null == policyStore) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1010_NO_POLICIES_DEFINED()));
}
final Collection<Policy> result = new ArrayList<Policy>(policyURIs.size());
for (String policyURI : policyURIs) {
final PolicySourceModel sourceModel = policyStore.get(policyURI);
if (sourceModel == null) {
throw LOGGER.logSevereException(new PolicyException(PolicyMessages.WSP_1005_POLICY_REFERENCE_DOES_NOT_EXIST(policyURI)));
} else {
result.add(ModelTranslator.getTranslator().translate(sourceModel));
}
}
return result;
}
示例17
/**
* Adds a PolicyReference element that points to the policy of the element,
* if the policy does not have any id or name. Writes policy inside the element otherwise.
*
* @param subject
* PolicySubject to be referenced or marshalled
* @param writer
* A TXW on to which we shall add the PolicyReference
*/
private void writePolicyOrReferenceIt(final PolicySubject subject, final TypedXmlWriter writer) {
final Policy policy;
try {
policy = subject.getEffectivePolicy(merger);
} catch (PolicyException e) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1011_FAILED_TO_RETRIEVE_EFFECTIVE_POLICY_FOR_SUBJECT(subject.toString()), e));
}
if (policy != null) {
if (null == policy.getIdOrName()) {
final PolicyModelGenerator generator = ModelGenerator.getGenerator();
try {
final PolicySourceModel policyInfoset = generator.translate(policy);
marshaller.marshal(policyInfoset, writer);
} catch (PolicyException pe) {
throw LOGGER.logSevereException(new WebServiceException(PolicyMessages.WSP_1002_UNABLE_TO_MARSHALL_POLICY_OR_POLICY_REFERENCE(), pe));
}
} else {
final TypedXmlWriter policyReference = writer._element(policy.getNamespaceVersion().asQName(XmlToken.PolicyReference), TypedXmlWriter.class);
policyReference._attribute(XmlToken.Uri.toString(), '#' + policy.getIdOrName());
}
}
}
示例18
private Collection<String> getPolicyURIs(
final Collection<PolicyRecordHandler> handlers, final PolicySourceModelContext modelContext) throws PolicyException{
final Collection<String> result = new ArrayList<String>(handlers.size());
String policyUri;
for (PolicyRecordHandler handler : handlers) {
policyUri = handler.handler;
if (HandlerType.AnonymousPolicyId == handler.type) {
final PolicySourceModel policyModel = getAnonymousPolicyModels().get(policyUri);
policyModel.expand(modelContext);
while (getPolicyModels().containsKey(policyUri)) {
policyUri = AnonymnousPolicyIdPrefix.append(anonymousPoliciesCount++).toString();
}
getPolicyModels().put(policyUri,policyModel);
}
result.add(policyUri);
}
return result;
}
示例19
/** Creates a new instance of WSDLServiceScopeBuilderHandler */
BuilderHandlerOperationScope(
Collection<String> policyURIs
, Map<String,PolicySourceModel> policyStore
, Object policySubject
, QName service, QName port, QName operation) {
super(policyURIs, policyStore, policySubject);
this.service = service;
this.port = port;
this.operation = operation;
}
示例20
private void readPolicy(final XMLEventReader reader) throws PolicyException {
final PolicySourceModel policyModel = POLICY_UNMARSHALLER.unmarshalModel(reader);
final PolicyModelTranslator translator = PolicyModelTranslator.getTranslator();
final Policy policy = translator.translate(policyModel);
if (this.currentUri != null) {
map.put(this.currentUri, policy);
this.currentUri = null;
this.currentPolicy = null;
}
else {
this.currentPolicy = policy;
}
}
示例21
/**
* Creates a new instance of BuilderHandlerServiceScope
*/
BuilderHandlerServiceScope(
Collection<String> policyURIs, Map<String,PolicySourceModel> policyStore, Object policySubject, QName service) {
super(policyURIs, policyStore, policySubject);
this.service = service;
}
示例22
/**
* Creates a new instance of BuilderHandlerServiceScope
*/
BuilderHandlerServiceScope(
Collection<String> policyURIs, Map<String,PolicySourceModel> policyStore, Object policySubject, QName service) {
super(policyURIs, policyStore, policySubject);
this.service = service;
}
示例23
private void readPolicy(final XMLEventReader reader) throws PolicyException {
final PolicySourceModel policyModel = POLICY_UNMARSHALLER.unmarshalModel(reader);
final PolicyModelTranslator translator = PolicyModelTranslator.getTranslator();
final Policy policy = translator.translate(policyModel);
if (this.currentUri != null) {
map.put(this.currentUri, policy);
this.currentUri = null;
this.currentPolicy = null;
}
else {
this.currentPolicy = policy;
}
}
示例24
/**
* Creates a new instance of BuilderHandlerServiceScope
*/
BuilderHandlerServiceScope(
Collection<String> policyURIs, Map<String,PolicySourceModel> policyStore, Object policySubject, QName service) {
super(policyURIs, policyStore, policySubject);
this.service = service;
}
示例25
/** Creates a new instance of WSDLServiceScopeBuilderHandler */
BuilderHandlerOperationScope(
Collection<String> policyURIs
, Map<String,PolicySourceModel> policyStore
, Object policySubject
, QName service, QName port, QName operation) {
super(policyURIs, policyStore, policySubject);
this.service = service;
this.port = port;
this.operation = operation;
}
示例26
/** Creates a new instance of WSDLServiceScopeBuilderHandler */
BuilderHandlerMessageScope(
Collection<String> policyURIs
, Map<String,PolicySourceModel> policyStore
, Object policySubject
, Scope scope
, QName service, QName port, QName operation, QName message) {
super(policyURIs, policyStore, policySubject);
this.service = service;
this.port = port;
this.operation = operation;
this.scope = scope;
this.message = message;
}
示例27
/** Creates a new instance of WSDLServiceScopeBuilderHandler */
BuilderHandlerOperationScope(
Collection<String> policyURIs
, Map<String,PolicySourceModel> policyStore
, Object policySubject
, QName service, QName port, QName operation) {
super(policyURIs, policyStore, policySubject);
this.service = service;
this.port = port;
this.operation = operation;
}
示例28
/** Creates a new instance of WSDLServiceScopeBuilderHandler */
BuilderHandlerMessageScope(
Collection<String> policyURIs
, Map<String,PolicySourceModel> policyStore
, Object policySubject
, Scope scope
, QName service, QName port, QName operation, QName message) {
super(policyURIs, policyStore, policySubject);
this.service = service;
this.port = port;
this.operation = operation;
this.scope = scope;
this.message = message;
}
示例29
private void readPolicy(final XMLEventReader reader) throws PolicyException {
final PolicySourceModel policyModel = POLICY_UNMARSHALLER.unmarshalModel(reader);
final PolicyModelTranslator translator = PolicyModelTranslator.getTranslator();
final Policy policy = translator.translate(policyModel);
if (this.currentUri != null) {
map.put(this.currentUri, policy);
this.currentUri = null;
this.currentPolicy = null;
}
else {
this.currentPolicy = policy;
}
}
示例30
/** Creates a new instance of WSDLServiceScopeBuilderHandler */
BuilderHandlerEndpointScope(Collection<String> policyURIs, Map<String,PolicySourceModel> policyStore, Object policySubject, QName service, QName port) {
super(policyURIs, policyStore, policySubject);
this.service = service;
this.port = port;
}
