org.apache.cxf.message.Message.setContent()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(12.0k)|赞(0)|评价(0)|浏览(212)

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

Message.setContent介绍

[英]Provide the encapsulated content as a particular type (a result type if message is outbound, a source type if message is inbound)
[中]以特定类型提供封装的内容（如果消息是出站的，则为结果类型；如果消息是入站的，则为源类型）

代码示例

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

  1. @Override
  2. public void handleFault(Message message) {
  3.   super.handleFault(message);
  4.   XMLStreamWriter os = (XMLStreamWriter)message.get(ORIGINAL_WRITER);
  5.   if (os != null) {
  6.     message.setContent(XMLStreamWriter.class, os);
  7.   }
  8. }

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

  1. /**
  2.  * Send an outbound message, assumed to contain all the name-value
  3.  * mappings of the corresponding input message (if any).
  4.  *
  5.  * @param message the message to be sent.
  6.  */
  7. public void prepare(Message message) throws IOException {
  8.   message.put(HTTP_RESPONSE, response);
  9.   OutputStream os = message.getContent(OutputStream.class);
  10.   if (os == null) {
  11.     message.setContent(OutputStream.class,
  12.             new WrappedOutputStream(message));
  13.   }
  14. }

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

  1. public void setMessage(SOAPMessage message) {
  2.   if (getWrappedMessage().getContent(Object.class) instanceof SOAPMessage) {
  3.     getWrappedMessage().setContent(Object.class, message);
  4.   } else {
  5.     getWrappedMessage().setContent(SOAPMessage.class, message);
  6.   }
  7. }

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

  1. public Source getPayload() {
  2.   Source source = null;
  3.   Service.Mode mode = msgContext.getWrappedMessage().getExchange().get(Service.Mode.class);
  4.       SOAPMessage msg = message.getContent(SOAPMessage.class);
  5.       XMLStreamReader reader = null;
  6.       if (msg != null) {
  7.           reader = StaxUtils.createXMLStreamReader(source);
  8.         } catch (SOAPException e) {
  9.           throw new Fault(e);
  10.           DocumentFragment doc = DOMUtils.getEmptyDocument().createDocumentFragment();
  11.           W3CDOMStreamWriter writer = new W3CDOMStreamWriter(doc);
  12.           reader = message.getContent(XMLStreamReader.class);
  13.           reader = StaxUtils.createXMLStreamReader(DOMUtils.getFirstElement(doc));
  14.         } catch (XMLStreamException e) {
  15.           throw new Fault(e);
  16.       message.setContent(XMLStreamReader.class, reader);
  17.       message.setContent(Source.class, source);
  18.     } else if (!(source instanceof DOMSource)) {
  19.       W3CDOMStreamWriter writer = new W3CDOMStreamWriter();
  20.       message.setContent(XMLStreamReader.class, reader);
  21.       message.setContent(Source.class, source);

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

  1. XMLStreamReader reader = (XMLStreamReader)message.get("LogicalHandlerInterceptor.INREADER");
  2. SOAPMessage origMessage = null;
  3. if (reader != null) {
  4.   origMessage = message.getContent(SOAPMessage.class);
  5.   message.setContent(XMLStreamReader.class, reader);
  6.   message.removeContent(SOAPMessage.class);
  7. } else if (domWriter.getCurrentFragment() != null) {
  8.   message.setContent(Source.class, source);
  9.   message.setContent(XMLStreamReader.class,
  10.             new W3CDOMStreamReader(domWriter.getCurrentFragment()));
  11. } else if (domWriter.getDocument().getDocumentElement() != null) {
  12.   Source source = new DOMSource(domWriter.getDocument());
  13.   message.setContent(Source.class, source);
  14.   message.setContent(XMLStreamReader.class,
  15.             StaxUtils.createXMLStreamReader(domWriter.getDocument()));
  16.       if (observer != null) {
  17.         responseMsg.setContent(XMLStreamReader.class, message
  18.           .getContent(XMLStreamReader.class));
  19.   message.setContent(SOAPMessage.class, origMessage);
  20.   message.setContent(XMLStreamWriter.class, origWriter);
  21. } catch (XMLStreamException e) {
  22.   throw new Fault(e);

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

  1. public void handleMessage(Message message) throws Fault {
  2.   Exchange ex = message.getExchange();
  3.   BindingOperationInfo boi = ex.getBindingOperationInfo();
  4.   if (Boolean.TRUE.equals(message.get(Message.PARTIAL_RESPONSE_MESSAGE))
  5.     || boi == null) {
  6.     return;
  7.     BindingMessageInfo bmi;
  8.     MessageInfo wrappedMessageInfo = message.get(MessageInfo.class);
  9.     MessageInfo messageInfo;
  10.     if (wrappedMessageInfo == boi.getOperationInfo().getInput()) {
  11.       return;
  12.     message.put(MessageInfo.class, messageInfo);
  13.     message.put(BindingMessageInfo.class, bmi);
  14.     ex.put(BindingOperationInfo.class, boi2);
  15.       Service service = ServiceModelUtil.getService(message.getExchange());
  16.       DataBinding dataBinding = service.getDataBinding();
  17.       if (dataBinding instanceof WrapperCapableDatabinding) {
  18.       throw new Fault(e);
  19.     message.setContent(List.class, newParams);

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

  1. } else if (DataSource.class.isAssignableFrom(type)) {
  2.   MessageContentsList list = (MessageContentsList)message.getContent(List.class);
  3.   DataSource ds = (DataSource)list.get(0);
  4.   String ct = ds.getContentType();
  5.   if (ct.toLowerCase().contains("multipart/related")) {
  6.     Message msg = new MessageImpl();
  7.     msg.setExchange(message.getExchange());
  8.     msg.put(Message.CONTENT_TYPE, ct);
  9.     try {
  10.       msg.setContent(InputStream.class, ds.getInputStream());
  11.       AttachmentDeserializer deser = new AttachmentDeserializer(msg);
  12.       deser.initializeAttachments();
  13.     } catch (IOException ex) {
  14.       throw new Fault(ex);
  15.     final InputStream in = msg.getContent(InputStream.class);
  16.     final String ct2 = (String)msg.get(Message.CONTENT_TYPE);
  17.     list.set(0, new DataSource() {
  18.       out.close();
  19.     } catch (IOException e) {
  20.       throw new Fault(e);
  21.     message.setContent(OutputStream.class, out);
  22.     XMLStreamWriter writer = StaxUtils.createXMLStreamWriter(out);
  23.     message.setContent(XMLStreamWriter.class, writer);

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

  1. public void handleMessage(Message message) throws Fault {
  2.   if (binding.getHandlerChain().isEmpty()) {
  3.     return;
  4.   }
  5.   HandlerChainInvoker invoker = getInvoker(message);
  6.   if (invoker.getLogicalHandlers().isEmpty()) {
  7.     return;
  8.   }
  9.   XMLStreamWriter origWriter = message.getContent(XMLStreamWriter.class);
  10.   Document doc = DOMUtils.newDocument();
  11.   message.setContent(Node.class, doc);
  12.   W3CDOMStreamWriter writer = new W3CDOMStreamWriter(doc);
  13.   // set up the namespace context
  14.   try {
  15.     writer.setNamespaceContext(origWriter.getNamespaceContext());
  16.   } catch (XMLStreamException ex) {
  17.     // don't set the namespaceContext
  18.   }
  19.   // Replace stax writer with DomStreamWriter
  20.   message.setContent(XMLStreamWriter.class, writer);
  21.   message.put(ORIGINAL_WRITER, origWriter);
  22.   message.getInterceptorChain().add(ending);
  23. }

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

  1. public void handleMessage(Message message) throws Fault {
  2.     OutputStream out = message.getContent(OutputStream.class);
  3.     if (out != null) {
  4.       CountingOutputStream newOut = new CountingOutputStream(out);
  5.       message.setContent(OutputStream.class, newOut);
  6.       message.getExchange().put(CountingOutputStream.class, newOut);
  7.     }
  8.   }
  9. }

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

  1. /**
  2.  * Send an outbound message, assumed to contain all the name-value
  3.  * mappings of the corresponding input message (if any). 
  4.  * 
  5.  * @param message the message to be sent.
  6.  */
  7. public void prepare(Message message) throws IOException {
  8.   // setup the message to be send back
  9.   DeliveryChannel dc = channel;
  10.   message.put(MessageExchange.class, inMessage.get(MessageExchange.class));
  11.   message.setContent(OutputStream.class,
  12.             new JBIDestinationOutputStream(inMessage, message, dc));
  13. }

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

  1. private void doFromSoapMessage(Message message, Object sm) {
  2.   SOAPMessage m = (SOAPMessage)sm;
  3.   MessageContentsList list = (MessageContentsList)message.getContent(List.class);
  4.   if (list == null) {
  5.     list = new MessageContentsList();
  6.     message.setContent(List.class, list);
  7.   }
  8.   Object o = m;
  9.   if (StreamSource.class.isAssignableFrom(type)) {
  10.     try {
  11.       try (CachedOutputStream out = new CachedOutputStream()) {
  12.         XMLStreamWriter xsw = StaxUtils.createXMLStreamWriter(out);
  13.         StaxUtils.copy(new DOMSource(m.getSOAPPart()), xsw);
  14.         xsw.close();
  15.         o = new StreamSource(out.getInputStream());
  16.       }
  17.     } catch (Exception e) {
  18.       throw new Fault(e);
  19.     }
  20.   } else if (SAXSource.class.isAssignableFrom(type)) {
  21.     o = new StaxSource(new W3CDOMStreamReader(m.getSOAPPart()));
  22.   } else if (Source.class.isAssignableFrom(type)) {
  23.     o = new DOMSource(m.getSOAPPart());
  24.   }
  25.   list.set(0, o);
  26. }

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

  1. responseMsg.setContent(SOAPMessage.class, soapMessage);
  2.   XMLStreamReader xmlReader = createXMLStreamReaderFromSOAPMessage(soapMessage);
  3.   responseMsg.setContent(XMLStreamReader.class, xmlReader);
  4. responseMsg.put(InterceptorChain.STARTING_AT_INTERCEPTOR_ID,
  5.         SOAPHandlerInterceptor.class.getName());
  6. observer.onMessage(responseMsg);
  7. SOAPMessage soapMessage = ((SOAPMessageContext)context).getMessage();
  8. responseMsg.setContent(SOAPMessage.class, soapMessage);

代码示例来源：origin: org.ow2.petals/petals-se-activiti

  1. @Override
  2. public void prepare(final Message message) throws IOException {
  3.   try {
  4.     final NormalizedMessageOutputStream out = new NormalizedMessageOutputStream(this.sender,
  5.         message.getExchange(), this.asyncCallback, flowAttributes.get());
  6.     message.setContent(OutputStream.class, out);
  7.   } catch (final MessagingException e) {
  8.     throw new IOException(e);
  9.   } catch (final PEtALSCDKException e) {
  10.     throw new IOException(e);
  11.   }
  12. }

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

  1. inMessage.getExchange().put(Bus.class, bus);
  2. inMessage.put(Message.DECOUPLED_CHANNEL_MESSAGE, Boolean.TRUE);
  3. inMessage.put(Message.RESPONSE_CODE, HttpURLConnection.HTTP_OK);
  4.   InputStream in = inMessage.getContent(InputStream.class);
  5.   if (in != null) {
  6.     CachedOutputStream cos = new CachedOutputStream();
  7.     IOUtils.copy(in, cos);
  8.     inMessage.setContent(InputStream.class, cos.getInputStream());

代码示例来源：origin: Talend/tesb-rt-se

  1. public void performTransformation(Message message) {
  2.     Reader transformedReader = null;
  3.     try {
  4.       transformedReader = XSLTUtils.transform(xsltTemplate, getReader());
  5.       IOUtils.copyAndCloseInput(transformedReader, origWriter, IOUtils.DEFAULT_BUFFER_SIZE);
  6.       message.setContent(Writer.class, origWriter);
  7.     } catch (IOException e) {
  8.       throw new Fault("READER_COPY", LOG, e, e.getMessage());
  9.     }
  10.   }
  11. }

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

  1. resp);
  2. final Exchange exchange = inMessage.getExchange();
  3. DelegatingInputStream in = new DelegatingInputStream(req.getInputStream()) {
  4.   public void cacheInput() {
  5. inMessage.setContent(DelegatingInputStream.class, in);
  6. inMessage.setContent(InputStream.class, in);
  7. inMessage.put(HTTP_REQUEST, req);
  8. inMessage.put(HTTP_RESPONSE, resp);
  9. inMessage.put(HTTP_CONTEXT, context);
  10. inMessage.put(HTTP_CONFIG, config);
  11. inMessage.put(HTTP_CONTEXT_MATCH_STRATEGY, contextMatchStrategy);

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

  1. public void handleMessage(Message message) throws Fault {
  2.   if (message.getExchange().get(Throwable.class) != null) {
  3.     return;
  4.   }
  5.   try {
  6.     Document doc = getDomDocument(message);
  7.     if (doc == null) {
  8.       return;
  9.     }
  10.     Document finalDoc = processDocument(message, doc);
  11.     message.setContent(List.class,
  12.       new MessageContentsList(new DOMSource(finalDoc)));
  13.   } catch (Exception ex) {
  14.     StringWriter sw = new StringWriter();
  15.     ex.printStackTrace(new PrintWriter(sw));
  16.     LOG.warning(sw.toString());
  17.     throw new Fault(new RuntimeException(ex.getMessage() + ", stacktrace: " + sw.toString()));
  18.   }
  19. }

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

  1. Service.Mode mode = (Service.Mode)msgContext.getWrappedMessage()
  2.   .getContextualProperty(Service.Mode.class.getName());
  3. SOAPMessage m = message.getContent(SOAPMessage.class);
  4. if (m != null && !MessageUtils.isOutbound(message)) {
  5.   try {
  6.     message.setContent(XMLStreamReader.class, r);
  7.   } catch (Exception e) {
  8.     throw new Fault(e);
  9.         s = new DOMSource(msg.getSOAPPart());
  10.       } catch (Exception e) {
  11.         throw new Fault(e);
  12.   } else if (message instanceof XMLMessage && message.getContent(DataSource.class) != null) {
  13.     throw new Fault(
  14.             new org.apache.cxf.common.i18n.Message(
  15.               "GETPAYLOAD_OF_DATASOURCE_NOT_VALID_XMLHTTPBINDING",
  16.   msgContext.getWrappedMessage().setContent(XMLStreamReader.class, reader);
  17. msgContext.getWrappedMessage().setContent(Source.class, s);

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

  1. public void handleMessage(Message message) throws Fault {
  2.   MessageContentsList inObjects = MessageContentsList.getContentsList(message);
  3.   Exchange exchange = message.getExchange();
  4.   BindingOperationInfo bop = exchange.getBindingOperationInfo();
  5.   if (bop == null) {
  6.   boolean client = Boolean.TRUE.equals(message.get(Message.REQUESTOR_ROLE));
  7.   if (client) {
  8.     List<Holder<?>> outHolders = CastUtils.cast((List<?>)message.getExchange()
  9.       .getOutMessage().get(CLIENT_HOLDERS));
  10.     for (MessagePartInfo part : parts) {
  11.       if (part.getIndex() != 0 && part.getTypeClass() != null) {
  12.           message.setContent(List.class, inObjects);

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

  1. public void run() {
  2.     try {
  3.       handleResponseInternal();
  4.     } catch (Throwable e) {
  5.       ((PhaseInterceptorChain)outMessage.getInterceptorChain()).abort();
  6.       outMessage.setContent(Exception.class, e);
  7.       ((PhaseInterceptorChain)outMessage.getInterceptorChain()).unwind(outMessage);
  8.       MessageObserver mo = outMessage.getInterceptorChain().getFaultObserver();
  9.       if (mo == null) {
  10.         mo = outMessage.getExchange().get(MessageObserver.class);
  11.       }
  12.       mo.onMessage(outMessage);
  13.     }
  14.   }
  15. };

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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