javax.wsdl.Message类的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(11.7k)|赞(0)|评价(0)|浏览(248)

本文整理了Java中javax.wsdl.Message类的一些代码示例，展示了Message类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message类的具体详情如下：
包路径：javax.wsdl.Message
类名称：Message

Message介绍

[英]This interface describes a message used for communication with an operation.
[中]此接口描述用于与操作通信的消息。

代码示例

代码示例来源：origin: pentaho/pentaho-kettle

  1. /**
  2.   * Create a WsdlOpFault from the Fault.
  3.   *
  4.   * @param fault
  5.   *          Fault to process.
  6.   * @return WsdlOpFault Result of processing.
  7.   */
  8.  @SuppressWarnings( "unchecked" )
  9.  private WsdlOpFault getFault( Fault fault ) throws KettleStepException {
  10.   Message m = fault.getMessage();
  12.   // a fault should only have one message part.
  13.   Map<?, Part> partMap = m.getParts();
  14.   if ( partMap.size() != 1 ) {
  15.    throw new IllegalArgumentException( "Invalid part count for fault!!" );
  16.   }
  17.   Part faultPart = partMap.values().iterator().next();
  18.   boolean complexType = false;
  20.   // type of fault is specified either in Part's type or element attribute.
  21.   QName type = faultPart.getTypeName();
  22.   if ( type == null ) {
  23.    type = faultPart.getElementName();
  24.    Element schemaElement = _wsdlTypes.findNamedElement( type );
  25.    type = _wsdlTypes.getTypeQName( schemaElement.getAttribute( "type" ) );
  26.    complexType = true;
  27.   }
  28.   return new WsdlOpFault( fault.getName(), type, complexType, _wsdlTypes );
  29.  }
  30. }

代码示例来源：origin: wsdl4j/wsdl4j

  1. if (!message.isUndefined())
  2.  QName name = message.getQName();
  3.               name.getLocalPart(),
  4.               pw);
  5.  printDocumentation(message.getDocumentationElement(), def, pw);
  6.  printParts(message.getOrderedParts(null), def, pw);
  7.  List extElements = message.getExtensibilityElements();

代码示例来源：origin: wsdl4j/wsdl4j

  1. QName messageName = new QName(def.getTargetNamespace(), name);
  2.  msg = def.getMessage(messageName);
  3.   msg = def.createMessage();
  4.   msg.setQName(messageName);
  5. msg.setUndefined(false);
  6.   msg.setDocumentationElement(tempEl);
  7.   msg.addPart(parsePart(tempEl, def));
  8.   msg.addExtensibilityElement(
  9.    parseExtensibilityElement(Message.class, tempEl, def));

代码示例来源：origin: org.apache.ode/ode-jbi

  1. private Message copyMessage(Message defMessage, Definition flat) {
  2.   Message flatMsg = flat.createMessage();
  3.   flatMsg.setUndefined(false);
  4.   if (defMessage.getQName() != null) {
  5.     flatMsg.setQName(new QName(flat.getTargetNamespace(), defMessage.getQName().getLocalPart()));
  6.   }
  7.   for (Iterator itPart = defMessage.getParts().values().iterator(); itPart.hasNext();) {
  8.     Part defPart = (Part) itPart.next();
  9.     Part flatPart = flat.createPart();
  10.     flatPart.setName(defPart.getName());
  11.     flatPart.setElementName(defPart.getElementName());
  12.     flatMsg.addPart(flatPart);
  13.   }
  14.   return flatMsg;
  15. }

代码示例来源：origin: org.n52.amused/amused-core

  1. public static QName getInputPartName(Operation op)
  2. {
  3.   Input input = op.getInput();
  4.   Map parts = input.getMessage().getParts();
  5.   //
  6.   // one message, one part, one XSD element - that's the system
  7.   //
  8.   if (parts.size() != 1)
  9.   {
  10.     Object[] filler = { op.getName() };
  11.     throw new RuntimeException(_MESSAGES.get("NotDocLiteral", filler));
  12.   }
  13.   Part docLiteralPart = (Part)parts.values().iterator().next();
  14.   QName partName = docLiteralPart.getElementName();
  15.   //
  16.   // HACK: this is for Axis/Axiom - they don't handle the default
  17.   // namespace/prefix well, so we always use a prefix
  18.   //
  19.   String prefix = partName.getPrefix();
  20.   if (prefix == null || prefix.length() == 0)
  21.     partName = new QName(partName.getNamespaceURI(), partName.getLocalPart(), "muse-op");
  22.   return partName;
  23. }

代码示例来源：origin: apache/cxf

  1. private void createFaultMessage(QName qname) {
  2.   String exceptionName = qname.getLocalPart();
  3.   // messages
  4.   Message faultMsg = definition.createMessage();
  5.   faultMsg.setQName(new QName(definition.getTargetNamespace(), exceptionName));
  6.   faultMsg.setUndefined(false);
  7.   // message - part
  8.   Part part = definition.createPart();
  9.   part.setName("exception");
  10.   part.setElementName(qname);
  11.   faultMsg.addPart(part);
  12.   //add the fault element namespace to the definition
  13.   String nsURI = qname.getNamespaceURI();
  14.   manager.addWSDLDefinitionNamespace(definition, mapper.mapNSToPrefix(nsURI), nsURI);
  15.   definition.addMessage(faultMsg);
  16. }

代码示例来源：origin: apache/cxf

  1. BindingOperation bindingOperation,
  2.               QName elementQName) {
  3. String exceptionName = corbaType.getQName().getLocalPart();
  4. Definition faultDef = manager.getWSDLDefinition(elementQName.getNamespaceURI());
  5. if (faultDef == null) {
  6.   faultDef = definition;
  7. Message faultMsg = faultDef.getMessage(new QName(faultDef.getTargetNamespace(), exceptionName));
  8. if (faultMsg == null) {
  9.   throw new RuntimeException("Fault message for exception " + exceptionName + " not found");
  10. Fault fault = definition.createFault();
  11. fault.setMessage(faultMsg);
  12. fault.setName(faultMsg.getQName().getLocalPart());
  13. operation.addFault(fault);
  14. BindingFault bindingFault = definition.createBindingFault();
  15. bindingFault.setName(faultMsg.getQName().getLocalPart());
  16. bindingOperation.addBindingFault(bindingFault);

代码示例来源：origin: org.codehaus.xfire/xfire-core

  1. protected void visit(Input input)
  2. {
  3.   if (isWrapped)
  4.   {
  5.     Part part = (Part) input.getMessage().getParts().values().iterator().next();
  6.     MessageInfo info = opInfo.createMessage(new QName(part.getElementName().getNamespaceURI(),
  7.                              input.getMessage().getQName().getLocalPart()));
  8.     winput2msg.put(input, info);
  9.     
  10.     opInfo.setInputMessage(info);
  11.     
  12.     createMessageParts(info, getWrappedSchema(input.getMessage()));
  13.   }
  14.   else
  15.   {
  16.     MessageInfo info = opInfo.createMessage(input.getMessage().getQName());
  17.     winput2msg.put(input, info);
  18.     
  19.     opInfo.setInputMessage(info);
  20.     createMessageParts(info,  input.getMessage());
  21.   }
  22. }

代码示例来源：origin: org.apache.cxf/cxf-common-utilities

  1. public Map getParts(Operation operation, boolean out) {
  2.   Message message = null;
  3.   if (out) {
  4.     Output output = operation.getOutput();
  5.     message = output.getMessage();
  6.   } else {
  7.     Input input = operation.getInput();
  8.     message = input.getMessage();
  9.   }
  10.   return message.getParts() == null ? new HashMap() : message.getParts();
  11. }

代码示例来源：origin: org.wso2.carbon.business-process/org.wso2.carbon.bpel

  1. private static String findHeaderPartName(List<javax.wsdl.extensions.soap.SOAPHeader> headerDefs,
  2.                      Definition wsdl,
  3.                      QName elmtName) {
  4.   for (javax.wsdl.extensions.soap.SOAPHeader headerDef : headerDefs) {
  5.     Message hdrMsg = wsdl.getMessage(headerDef.getMessage());
  6.     for (Object o : hdrMsg.getParts().values()) {
  7.       Part p = (Part) o;
  8.       if (p.getElementName().equals(elmtName)) {
  9.         return p.getName();
  10.       }
  11.     }
  12.   }
  13.   return elmtName.getLocalPart();
  14. }

代码示例来源：origin: org.codehaus.xfire/xfire-core

  1. protected Message createHeaderMessages(WSDLBuilder builder, MessageInfo msgInfo, List headers)
  2. {
  3.   Message msg = builder.getDefinition().createMessage();
  4.   msg.setQName(new QName(builder.getTargetNamespace(), 
  5.               msgInfo.getName().getLocalPart() + "Headers"));
  6.   msg.setUndefined(false);
  7.   for (Iterator itr = headers.iterator(); itr.hasNext();)
  8.   {
  9.     MessagePartInfo header = (MessagePartInfo) itr.next();
  10.     Part part = builder.createPart(header);
  11.     msg.addPart(part);
  12.   }
  13.   return msg;
  14. }

代码示例来源：origin: org.springframework.ws/spring-ws-core

  1. /**
  2.  * Called after the {@link javax.wsdl.Input} has been created, but it's added to the operation. Subclasses can
  3.  * override this method to define the input name.
  4.  *
  5.  * <p>Default implementation sets the input name to the message name.
  6.  *
  7.  * @param definition the WSDL4J {@code Definition}
  8.  * @param input         the WSDL4J {@code Input}
  9.  */
  10. protected void populateInput(Definition definition, Input input) {
  11.   input.setName(input.getMessage().getQName().getLocalPart());
  12. }

代码示例来源：origin: org.codehaus.xfire/xfire-core

  1. private Fault createFault(OperationInfo op, FaultInfo faultInfo)
  2. {
  3.   Message faultMsg = getDefinition().createMessage();
  4.   faultMsg.setQName(new QName(getTargetNamespace(), faultInfo.getName()));
  5.   faultMsg.setUndefined(false);
  6.   getDefinition().addMessage(faultMsg);
  7.   Fault fault = getDefinition().createFault();
  8.   fault.setName(faultInfo.getName());
  9.   fault.setMessage(faultMsg);
  10.   for (Iterator itr = faultInfo.getMessageParts().iterator(); itr.hasNext();)
  11.   {
  12.     MessagePartInfo info = (MessagePartInfo) itr.next();
  13.     String uri = info.getName().getNamespaceURI();
  14.     addNamespace(getNamespacePrefix(uri), uri);
  15.     Part part = createPart(info);
  16.     faultMsg.addPart(part);
  17.   }
  18.   return fault;
  19. }

代码示例来源：origin: apache/cxf

  1. protected void buildMessage(Message message,
  2.               AbstractMessageContainer messageContainer,
  3.               final Definition def) {
  4.   addDocumentation(message, messageContainer.getMessageDocumentation());
  5.   message.setQName(messageContainer.getName());
  6.   message.setUndefined(false);
  7.   def.addMessage(message);
  8.   List<MessagePartInfo> messageParts = messageContainer.getMessageParts();
  9.   Part messagePart = null;
  10.   for (MessagePartInfo messagePartInfo : messageParts) {
  11.     messagePart = def.createPart();
  12.     messagePart.setName(messagePartInfo.getName().getLocalPart());
  13.     if (messagePartInfo.isElement()) {
  14.       messagePart.setElementName(messagePartInfo.getElementQName());
  15.       addNamespace(messagePartInfo.getElementQName().getNamespaceURI(), def);
  16.     } else if (messagePartInfo.getTypeQName() != null) {
  17.       messagePart.setTypeName(messagePartInfo.getTypeQName());
  18.       addNamespace(messagePartInfo.getTypeQName().getNamespaceURI(), def);
  19.     }
  20.     message.addPart(messagePart);
  21.   }
  22. }

代码示例来源：origin: org.objectweb.jonas/jonas-deployment

  1. /**
  2.  * return true if shQName is defined in WSDL services.
  3.  * @param shQName a soap header Qname that could be defined in the WSDL.
  4.  * @return true if SOAP Header has been found in WSDL Definition.
  5.  */
  6. public boolean hasSOAPHeader(QName shQName) {
  7.   Map msgs = def.getMessages();
  8.   for (Iterator m = msgs.values().iterator(); m.hasNext();) {
  9.     Message msg = (Message) m.next();
  10.     if (msg.getQName().getNamespaceURI() == shQName.getNamespaceURI()) {
  11.       Part p = msg.getPart(shQName.getLocalPart());
  12.       if (p != null) {
  13.         return true;
  14.       }
  15.     }
  16.   }
  17.   return false;
  18. }

代码示例来源：origin: jboss-switchyard/components

  1. /**
  2.  * Get the SOAP {@link Operation} instance for the specified message element.
  3.  *
  4.  * @param port The WSDL port.
  5.  * @param elementName The SOAP Body element QName.
  6.  * @param documentStyle true if it is 'document', false if 'rpc'.
  7.  * @return The Operation instance, or null if the operation was not found on the port.
  8.  */
  9. public static Operation getOperationByElement(Port port, QName elementName, Boolean documentStyle) {
  10.   List<Operation> operations = port.getBinding().getPortType().getOperations();
  11.   for (Operation operation : operations) {
  12.     if (!documentStyle && (elementName.getLocalPart().equals(operation.getName()))) {
  13.       return operation;
  14.     } else {
  15.       // Note: WS-I Profile allows only one child under SOAPBody.
  16.       Part part = (Part)operation.getInput().getMessage().getParts().values().iterator().next();
  17.       if ((part.getElementName() != null) && elementName.equals(part.getElementName())
  18.         || (part.getTypeName() != null) && elementName.equals(part.getTypeName())) {
  19.         return operation;
  20.       } else if (elementName.getLocalPart().equals(operation.getName())) {
  21.         return operation;
  22.       }
  23.     }
  24.   }
  25.   return null;
  26. }

代码示例来源：origin: apache/cxf

  1. private XNode getXNode(javax.wsdl.Message msg) {
  2.   XDef xdef = new XDef();
  3.   xdef.setTargetNamespace(msg.getQName().getNamespaceURI());
  4.   XMessage mNode = new XMessage();
  5.   mNode.setName(msg.getQName().getLocalPart());
  6.   mNode.setParentNode(xdef);
  7.   return mNode;
  8. }

代码示例来源：origin: org.codehaus.xfire/xfire-core

  1. private Message createOutputMessage(OperationInfo op)
  2. {
  3.   // response message
  4.   Message res = getDefinition().createMessage();
  5.   res.setQName(new QName(getTargetNamespace(), op.getName() + "Response"));
  6.   res.setUndefined(false);
  7.   if (getService().getServiceInfo().isWrapped())
  8.     createWrappedOutputParts(res, op);
  9.   else
  10.     createOutputParts(res, op);
  11.   return res;
  12. }

代码示例来源：origin: apache/cxf

  1. private Operation generateOperation(String name, Message inputMsg, Message outputMsg) {
  2.   Input input = definition.createInput();
  3.   input.setName(inputMsg.getQName().getLocalPart());
  4.   input.setMessage(inputMsg);
  5.   Output output = definition.createOutput();
  6.   output.setName(outputMsg.getQName().getLocalPart());
  7.   output.setMessage(outputMsg);
  8.   Operation result = definition.createOperation();
  9.   result.setName(name);
  10.   result.setInput(input);
  11.   result.setOutput(output);
  12.   result.setUndefined(false);
  13.   portType.addOperation(result);
  14.   return result;
  15. }

代码示例来源：origin: apache/cxf

  1. public Message generateInputMessage(Operation operation, BindingOperation bindingOperation) {
  2.   Message msg = definition.createMessage();
  3.   QName msgName;
  4.   if (!mapper.isDefaultMapping()) {
  5.     //mangle the message name
  6.     //REVISIT, do we put in the entire scope for mangling
  7.     msgName = new QName(definition.getTargetNamespace(),
  8.               getScope().tail() + "." + operation.getName());
  9.   } else {
  10.     msgName = new QName(definition.getTargetNamespace(), operation.getName());
  11.   }
  12.   msg.setQName(msgName);
  13.   msg.setUndefined(false);
  14.   String inputName = operation.getName() + REQUEST_SUFFIX;
  15.   Input input = definition.createInput();
  16.   input.setName(inputName);
  17.   input.setMessage(msg);
  18.   BindingInput bindingInput = definition.createBindingInput();
  19.   bindingInput.setName(inputName);
  20.   bindingOperation.setBindingInput(bindingInput);
  21.   operation.setInput(input);
  22.   definition.addMessage(msg);
  23.   return msg;
  24. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com