org.apache.cxf.common.i18n.Message类的使用及代码示例

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

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

Message介绍

暂无

代码示例

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. private static JAXBContext getJAXBContext() {
  2.     if (jaxbContext == null) {
  3.       try {
  4.         jaxbContext = JAXBContext.newInstance(W3CEndpointReference.class);
  5.       } catch (JAXBException e) {
  6.         throw new WebServiceException(new Message("JAXBCONTEXT_CREATION_FAILED", LOG).toString(), e);
  7.       }
  8.     }
  9.     return jaxbContext;
  10.   }
  11. }

代码示例来源：origin: stackoverflow.com

  1. public class Builder {
  3.   private User sender = null;
  4.   // Other properties
  6.   public Builder sender( User sender ) {
  7.     this.sender = sender;
  8.     return this;
  9.   }
  10.   // Methods for other properties
  12.   public Message build() {
  13.     Message message = new Message();
  14.     message.setSender( sender );
  15.     // Set the other properties
  16.     return message;
  17.   }
  19. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. private HttpServletResponse getHttpResponseFromMessage(Message message) throws IOException {
  2.   Object responseObj = message.get(HTTP_RESPONSE);
  3.   if (responseObj instanceof HttpServletResponse) {
  4.     return (HttpServletResponse)responseObj;
  5.   } else if (null != responseObj) {
  6.     String m = (new org.apache.cxf.common.i18n.Message("UNEXPECTED_RESPONSE_TYPE_MSG",
  7.         LOG, responseObj.getClass())).toString();
  8.     LOG.log(Level.WARNING, m);
  9.     throw new IOException(m);
  10.   } else {
  11.     String m = (new org.apache.cxf.common.i18n.Message("NULL_RESPONSE_MSG", LOG)).toString();
  12.     LOG.log(Level.WARNING, m);
  13.     throw new IOException(m);
  14.   }
  15. }

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

  1. public void handleMessage(Message message) {
  2.   BindingOperationInfo bop = message.getExchange().getBindingOperationInfo();
  3.     XMLStreamWriter xmlWriter = message.getContent(XMLStreamWriter.class);
  4.       messageInfo = bop.getWrappedOperation().getOperationInfo().getInput();
  5.     } else {
  6.       messageInfo = bop.getWrappedOperation().getOperationInfo().getOutput();
  7.     QName name = messageInfo.getFirstMessagePart().getConcreteName();
  8.       Service service = message.getExchange().getService();
  9.       if (service.getDataBinding().getDeclaredNamespaceMappings() != null) {
  10.         pfx = service.getDataBinding().getDeclaredNamespaceMappings().get(name.getNamespaceURI());
  11.         pfx = StaxUtils.getUniquePrefix(xmlWriter, name.getNamespaceURI(), false);
  12.       xmlWriter.setPrefix(pfx, name.getNamespaceURI());
  13.       xmlWriter.writeStartElement(pfx, name.getLocalPart(), name.getNamespaceURI());
  14.       if (StringUtils.isEmpty(pfx)) {
  15.       throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_WRITE_EXC", BUNDLE), e);

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

  1. private void buildMessage(AbstractMessageContainer minfo, Message msg) {
  2.   SchemaCollection schemas = minfo.getOperation().getInterface().getService()
  3.     .getXmlSchemaCollection();
  4.   List<?> orderedParam = msg.getOrderedParts(null);
  5.   for (Part part : cast(orderedParam, Part.class)) {
  6.     MessagePartInfo pi = minfo.addMessagePart(new QName(minfo.getName().getNamespaceURI(), part
  7.       .getName()));
  8.     if (part.getTypeName() != null) {
  9.       pi.setTypeQName(part.getTypeName());
  10.       pi.setElement(false);
  11.       pi.setXmlSchema(schemas.getTypeByQName(part.getTypeName()));
  12.     } else if (part.getElementName() != null) {
  13.       pi.setElementQName(part.getElementName());
  14.       if (null == schemaElement) {
  15.         org.apache.cxf.common.i18n.Message errorMessage =
  16.           new org.apache.cxf.common.i18n.Message("WSDL4J_BAD_ELEMENT_PART",
  17.                               LOG,
  18.                               part.getName(),
  19.     } else {
  20.       org.apache.cxf.common.i18n.Message errorMessage =
  21.         new org.apache.cxf.common.i18n.Message("PART_NO_NAME_NO_TYPE",
  22.                             LOG,
  23.                             part.getName());

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

  1. private void writeMessage(Message message, QName name, boolean executeBare) {
  2.     XMLStreamWriter xmlWriter = message.getContent(XMLStreamWriter.class);
  3.     try {
  4.       String pfx = name.getPrefix();
  5.       if (StringUtils.isEmpty(pfx)) {
  6.         pfx = "ns1";
  7.       }
  8.       StaxUtils.writeStartElement(xmlWriter,
  9.                     pfx,
  10.                     name.getLocalPart(),
  11.                     name.getNamespaceURI());
  12.       if (executeBare) {
  13.         new BareOutInterceptor().handleMessage(message);
  14.       }
  15.       xmlWriter.writeEndElement();
  16.     } catch (XMLStreamException e) {
  17.       throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_WRITE_EXC", BUNDLE, e));
  18.     }
  20.   }
  21. }

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

  1. protected void checkForElement(ServiceInfo serviceInfo, MessagePartInfo mpi) {
  2.   SchemaInfo si = getOrCreateSchema(serviceInfo, mpi.getElementQName().getNamespaceURI(),
  3.                    getQualifyWrapperSchema());
  4.   XmlSchemaElement e = si.getSchema().getElementByName(mpi.getElementQName().getLocalPart());
  5.   if (e != null) {
  6.     mpi.setXmlSchema(e);
  7.     return;
  8.   }
  9.   XmlSchema schema = si.getSchema();
  10.   si.setElement(null); //cached element is now invalid
  11.   XmlSchemaElement el = new XmlSchemaElement(schema, true);
  12.   el.setName(mpi.getElementQName().getLocalPart());
  13.   el.setNillable(true);
  14.   XmlSchemaType tp = (XmlSchemaType)mpi.getXmlSchema();
  15.   if (tp == null) {
  16.     throw new ServiceConstructionException(new Message("INTRACTABLE_PART", LOG,
  17.                               mpi.getName(),
  18.                               mpi.getMessageInfo().getName()));
  19.   }
  20.   el.setSchemaTypeName(tp.getQName());
  21.   mpi.setXmlSchema(el);
  22. }

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. protected void initializeWSDLOperationsForProvider() {
  2.   Class<?> c = getProviderParameterType(getServiceClass());
  3.   if (c == null) {
  4.     throw new ServiceConstructionException(new Message("INVALID_PROVIDER_EXC", LOG));
  5.     QName catchAll = new QName("http://cxf.apache.org/jaxws/provider", "invoke");
  6.           if (bop.isUnwrappedCapable()) {
  7.             bop.getOperationInfo().setUnwrappedOperation(null);
  8.             bop.setUnwrappedOperation(null);
  9.           if (o.getInput() != null) {
  10.             final List<MessagePartInfo> messageParts;
  11.             if (o.getInput().getMessagePartsNumber() == 0) {
  12.               MessagePartInfo inf = o.getInput().addMessagePart(o.getName());
  13.               inf.setConcreteName(o.getName());
  14.               messageParts = o.getInput().getMessageParts();
  15.               bop.getInput().setMessageParts(messageParts);
  16.               inf.setTypeClass(c);
  17.               break;
  18.             if (o.getOutput().getMessagePartsNumber() == 0) {
  19.               MessagePartInfo inf = o.getOutput().addMessagePart(o.getName());
  20.               inf.setConcreteName(new QName(o.getName().getNamespaceURI(),
  21.                              o.getName().getLocalPart() + "Response"));
  22.               messageParts = o.getOutput().getMessageParts();

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

  1. public DomainExpression build(Element element) {
  2.     loadDynamic();
  3.     DomainExpressionBuilder builder;
  5.     QName qname = new QName(element.getNamespaceURI(), element.getLocalName());
  6.     builder = get(qname);
  8.     if (null == builder) {
  9.       throw new PolicyException(new Message("NO_DOMAINEXPRESSIONBUILDER_EXC",
  10.                          BUNDLE, qname.toString()));
  11.     }
  13.     return builder.build(element);
  15.   }
  16. }

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. try {
  2.   Definition def = wsdlManager.getDefinition(wsdlDocumentLocation);
  3.   interfaceName = def.getService(serviceName).getPort(portName.getLocalPart()).getBinding()
  4.     .getPortType().getQName();
  5. } catch (Exception e) {
  6.               JAXWSAConstants.WSA_REFERENCEPARAMETERS_NAME, JAXWSAConstants.NS_WSA);
  7.   for (Element ele : referenceParameters) {
  8.     StaxUtils.writeElement(ele, writer, true);
  9.         ? serviceName.getNamespaceURI() + " " + wsdlDocumentLocation
  10.         : wsdlDocumentLocation;
  11.     writer.writeNamespace(JAXWSAConstants.WSDLI_PFX,
  12.                  JAXWSAConstants.WSAM_INTERFACE_NAME,
  13.                  JAXWSAConstants.NS_WSAM);
  14.     String portTypePrefix = interfaceName.getPrefix();
  15.     if (portTypePrefix == null || portTypePrefix.isEmpty()) {
  16.       portTypePrefix = "ns1";
  17.       StaxUtils.writeElement(e, writer, true);
  18.     StaxUtils.writeElement(e, writer, true);
  19. throw new WebServiceException(new Message("ERROR_UNMARSHAL_ENDPOINTREFERENCE", LOG).toString(),
  20.                e);

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-se

  1. private void writeWrapper(Message message, BindingOperationInfo bop, XMLStreamWriter xmlWriter) {
  2.   if (bop.isUnwrapped()) {
  3.     MessageInfo messageInfo;
  4.     if (isRequestor(message)) {
  5.       messageInfo = bop.getWrappedOperation().getOperationInfo().getInput();
  6.     } else {
  7.       messageInfo = bop.getWrappedOperation().getOperationInfo().getOutput();
  8.     }
  9.     MessagePartInfo outPart = messageInfo.getMessageParts().get(0);
  10.     QName name = outPart.getConcreteName();
  11.     try {
  12.       String pfx = StaxUtils.getUniquePrefix(xmlWriter, name.getNamespaceURI());
  13.       xmlWriter.setPrefix(pfx, name.getNamespaceURI());
  14.       xmlWriter.writeStartElement(pfx, name.getLocalPart(), name.getNamespaceURI());
  15.       xmlWriter.writeNamespace(pfx, name.getNamespaceURI());
  16.     } catch (XMLStreamException e) {
  17.       throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_WRITE_EXC", BUNDLE), e);
  18.     }
  19.   }
  20. }

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. if (portExtensors != null) {
  2.   Iterator<ExtensibilityElement> extensionElements = portExtensors.iterator();
  3.   QName wsaEpr = new QName(Names.WSA_NAMESPACE_NAME, "EndpointReference");
  4.   while (extensionElements.hasNext()) {
  5.     ExtensibilityElement ext = extensionElements.next();
  6.     if (ext instanceof UnknownExtensibilityElement && wsaEpr.equals(ext.getElementType())) {
  7.       Element eprEle = ((UnknownExtensibilityElement)ext).getElement();
  8.       List<Element> addressElements = DOMUtils.getChildrenWithName(eprEle,
  9.   throw new UnsupportedOperationException(new Message("GET_ENDPOINTREFERENCE_UNSUPPORTED_BINDING",
  10.                             LOG, bindingId).toString());

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

  1. return;
  2. Endpoint ep = message.getExchange().getEndpoint();
  3. XMLStreamReader xsr = message.getContent(XMLStreamReader.class);
  4. if (xsr == null) {
  5.   return;
  6. if (!StaxUtils.toNextElement(reader)) {
  7.   throw new Fault(new org.apache.cxf.common.i18n.Message("NO_OPERATION_ELEMENT", LOG));
  8. Exchange ex = message.getExchange();
  9. QName startQName = reader.getName();
  10. if (startQName.getLocalPart().equals(XMLFault.XML_FAULT_ROOT)) {
  11.   message.getInterceptorChain().abort();
  12. BindingOperationInfo boi = ex.getBindingOperationInfo();
  13. boolean isRequestor = isRequestor(message);
  14. if (boi == null) {
  15.       xsr.nextTag();
  16.     } catch (XMLStreamException xse) {
  17.       throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_READ_EXC", LOG));

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. private QName getPortTypeName(Class<?> serviceEndpointInterface) {
  2.   Class<?> seiClass = serviceEndpointInterface;
  3.   if (!serviceEndpointInterface.isAnnotationPresent(WebService.class)) {
  4.     Message msg = new Message("SEI_NO_WEBSERVICE_ANNOTATION", BUNDLE, serviceEndpointInterface
  5.       .getCanonicalName());
  6.     throw new WebServiceException(msg.toString());
  7.         seiClass = Thread.currentThread().getContextClassLoader().loadClass(epi);
  8.       } catch (ClassNotFoundException e) {
  9.         Message msg = new Message("COULD_NOT_LOAD_CLASS", BUNDLE, epi);
  10.         throw new WebServiceException(msg.toString());
  11.         Message msg = new Message("SEI_NO_WEBSERVICE_ANNOTATION", BUNDLE,
  12.                      seiClass.getCanonicalName());
  13.         throw new WebServiceException(msg.toString());
  14.   return new QName(tns, name);

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. String partName = mpi.getConcreteName().getLocalPart();
  2. String ct = (String) mpi.getProperty(Message.CONTENT_TYPE);
  3. int idx = mpi.getIndex();
  4. Object o = outObjects.get(idx);
  5.   throw new Fault(new org.apache.cxf.common.i18n.Message("ATTACHMENT_NOT_SUPPORTED",
  6.                               LOG, o.getClass()));

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

  1. private void processInput(JavaMethod method, MessageInfo inputMessage) throws ToolException {
  2.   if (requireOutOfBandHeader()) {
  3.     try {
  4.       Class.forName("org.apache.cxf.binding.soap.SoapBindingFactory");
  5.     } catch (Exception e) {
  6.       LOG.log(Level.WARNING, new Message("SOAP_MISSING", LOG).toString());
  7.     }
  8.   }
  9.   JAXWSBinding mBinding = inputMessage.getOperation().getExtensor(JAXWSBinding.class);
  10.   for (MessagePartInfo part : inputMessage.getMessageParts()) {
  11.     if (isOutOfBandHeader(part) && !requireOutOfBandHeader()) {
  12.       continue;
  13.     }
  14.     JavaParameter param = getParameterFromPart(method, part, JavaType.Style.IN);
  15.     if (mBinding != null && mBinding.getJaxwsParas() != null) {
  16.       for (JAXWSParameter jwp : mBinding.getJaxwsParas()) {
  17.         if (part.getName().getLocalPart().equals(jwp.getPart())) {
  18.           param.setName(jwp.getName());
  19.         }
  20.       }
  21.     }
  22.     addParameter(part, method, param);
  23.   }
  24. }

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

  1. private void throwMultipleMultipleTypeException(Collection<QName> binds) throws Exception {
  2.   StringBuilder sb = new StringBuilder();
  3.   org.apache.cxf.common.i18n.Message msgDef =
  4.     new org.apache.cxf.common.i18n.Message("Multiple Bindings already defined in the wsdl", LOG);
  5.   sb.append(msgDef.toString());
  6.   Iterator<QName> it2 = binds.iterator();
  7.   int cnt = 0;
  8.   while (it2.hasNext()) {
  9.     cnt++;
  10.     sb.append("  " + cnt + " --> " + it2.next().getLocalPart());
  11.   }
  12.   throw new Exception(sb.toString());
  13. }

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

  1. protected InterfaceInfo getInterfaceInfo() {
  2.   if (getEndpointInfo() != null) {
  3.     return getEndpointInfo().getInterface();
  4.   }
  5.   QName qn = this.getInterfaceName();
  6.   for (ServiceInfo si : getService().getServiceInfos()) {
  7.     if (qn.equals(si.getInterface().getName())) {
  8.       return si.getInterface();
  9.     }
  10.   }
  11.   throw new ServiceConstructionException(new Message("COULD_NOT_FIND_PORTTYPE", LOG, qn));
  12. }

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

  1. protected void waitResponse(Exchange exchange) throws IOException {
  2.   synchronized (exchange) {
  3.     long remaining = synchronousTimeout;
  4.     Long o = PropertyUtils.getLong(exchange.getOutMessage(), SYNC_TIMEOUT);
  5.     if (o != null) {
  6.       remaining = o;
  7.     }
  8.     while (!Boolean.TRUE.equals(exchange.get(FINISHED)) && remaining > 0) {
  9.       long start = System.currentTimeMillis();
  10.       try {
  11.         exchange.wait(remaining);
  12.       } catch (InterruptedException ex) {
  13.         // ignore
  14.       }
  15.       long end = System.currentTimeMillis();
  16.       remaining -= (int)(end - start);
  17.     }
  18.     if (!Boolean.TRUE.equals(exchange.get(FINISHED))) {
  19.       LogUtils.log(LOG, Level.WARNING, "RESPONSE_TIMEOUT",
  20.         exchange.get(OperationInfo.class).getName().toString());
  21.       String msg = new org.apache.cxf.common.i18n.Message("RESPONSE_TIMEOUT", LOG, 
  22.                                 exchange.get(OperationInfo.class)
  23.                                   .getName().toString())
  24.         .toString();
  25.       throw new IOException(msg);
  26.     }
  27.   }
  28. }

代码示例来源：origin: org.apache.servicemix/servicemix-cxf-se

  1. public void handleMessage(JBIMessage message) throws Fault {
  2.   Exchange ex = message.getExchange();
  3.   Endpoint ep = ex.get(Endpoint.class);
  4.   BindingOperationInfo boi = ex.get(BindingOperationInfo.class);
  5.   if (boi == null) {
  6.     if (message.getJbiExchange().getOperation() != null) {
  7.       BindingInfo service = ep.getEndpointInfo().getBinding();
  8.       boi = getBindingOperationInfo(service, message.getJbiExchange().getOperation());
  9.       if (boi == null) {
  10.         throw new Fault(new Message("UNKNOWN_OPERATION", BUNDLE, 
  11.           message.getJbiExchange().getOperation().toString()));
  12.       }
  13.       
  14.     } else {
  15.       throw new Fault(new Message("UNKNOWN_OPERATION", BUNDLE, 
  16.             message.getJbiExchange().getInterfaceName().toString()));
  17.     }
  18.     ex.put(BindingOperationInfo.class, boi);
  19.     ex.put(OperationInfo.class, boi.getOperationInfo());
  20.     ex.setOneWay(boi.getOperationInfo().isOneWay());
  21.     message.put(MessageInfo.class, boi.getInput().getMessageInfo());
  22.   }
  23.   
  24. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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