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

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

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

Message.put介绍

暂无

代码示例

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

  1. protected void propagateConduit(Exchange exchange, Message in) {
  2.   if (exchange != null) {
  3.     Message out = exchange.getOutMessage();
  4.     if (out != null) {
  5.       in.put(Conduit.class, out.get(Conduit.class));
  6.     }
  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-transports-http

  1. inMessage.setContent(DelegatingInputStream.class, in);
  2. inMessage.setContent(InputStream.class, in);
  3. inMessage.put(HTTP_REQUEST, req);
  4. inMessage.put(HTTP_RESPONSE, resp);
  5. inMessage.put(HTTP_CONTEXT, context);
  6. inMessage.put(HTTP_CONFIG, config);
  7. inMessage.put(HTTP_CONTEXT_MATCH_STRATEGY, contextMatchStrategy);
  8. inMessage.put(Message.HTTP_REQUEST_METHOD, req.getMethod());
  9. String requestURI = req.getRequestURI();
  10. inMessage.put(Message.REQUEST_URI, requestURI);
  11. String requestURL = req.getRequestURL().toString();
  12. inMessage.put(Message.REQUEST_URL, requestURL);
  13. String contextPath = req.getContextPath();
  14. if (contextPath == null) {
  15. String pathInfo = req.getPathInfo();
  16. if (pathInfo != null) {
  17.   inMessage.put(Message.PATH_INFO, contextServletPath + pathInfo);
  18. } else {
  19.   inMessage.put(Message.PATH_INFO, requestURI);
  20.     inMessage.put(HTTP_BASE_PATH, basePathWithContextOnly);
  21.     inMessage.put(HTTP_BASE_PATH, requestURL.substring(0, index));
  22. inMessage.put(Message.CONTENT_TYPE, contentType);
  23. setEncoding(inMessage, req, contentType);

代码示例来源：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: org.apache.cxf/cxf-rt-frontend-jaxws

  1. public void handleMessage(Message message) throws Fault {
  2.   MessageContentsList outObjects = MessageContentsList.getContentsList(message);
  3.   Exchange exchange = message.getExchange();
  4.   OperationInfo op = exchange.getBindingOperationInfo() == null
  5.     ? null
  6.   if (!Boolean.TRUE.equals(message.get(Message.REQUESTOR_ROLE))) {
  7.     List<MessagePartInfo> parts = op.getOutput().getMessageParts();
  8.     MessageContentsList inObjects = MessageContentsList.getContentsList(exchange.getInMessage());
  9.     message.put(HolderInInterceptor.CLIENT_HOLDERS, holders);

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

  1. private void validatePossibleFault(Message message, BindingOperationInfo bop, Node ds) {
  2.   Element el = DOMUtils.getFirstElement(ds);
  3.   if (!"Fault".equals(el.getLocalName())) {
  4.     return;
  5.   }
  6.   message.put(Message.RESPONSE_CODE, 500);
  7.   el = DOMUtils.getFirstElement(el);
  8.   while (el != null && !"detail".equals(el.getLocalName())) {
  9.     el = DOMUtils.getNextElement(el);
  10.   }
  11.   if (el != null) {
  12.     Schema schema = EndpointReferenceUtils.getSchema(message.getExchange().getService()
  13.                              .getServiceInfos().get(0),
  14.                            message.getExchange().getBus());
  15.     try {
  16.       validateFaultDetail(el, schema, bop);
  17.     } catch (Exception e) {
  18.       throw new Fault(e);
  19.     }
  20.     //We validated what we can from a fault standpoint
  21.     message.put(Message.SCHEMA_VALIDATION_ENABLED, Boolean.FALSE);
  22.   }
  23. }
  24. private void validateFaultDetail(Element detail, Schema schema, BindingOperationInfo bop) throws Exception {

代码示例来源：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.     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.     final InputStream in = msg.getContent(InputStream.class);
  14.     final String ct2 = (String)msg.get(Message.CONTENT_TYPE);
  15.     list.set(0, new DataSource() {
  16.     OutputStream out = message.getContent(OutputStream.class);
  17.     message.put(Message.CONTENT_TYPE, ct);
  18.     try {
  19.       InputStream in = ds.getInputStream();
  20.     message.setContent(OutputStream.class, out);
  21.     XMLStreamWriter writer = StaxUtils.createXMLStreamWriter(out);
  22.     message.setContent(XMLStreamWriter.class, writer);

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

  1. public void prepare(Message message) throws IOException {
  2.   message.put(CorbaConstants.ORB, orb);
  3.   message.put(CorbaConstants.CORBA_ENDPOINT_OBJECT, targetObject);
  4.   message.setContent(OutputStream.class, new CorbaOutputStream(message));
  5.   if (message instanceof CorbaMessage) {
  6.     ((CorbaMessage) message).setCorbaTypeMap(typeMap);
  7.   }
  8. }

代码示例来源：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 handleAbort(Message message, W3CDOMStreamWriter writer) {
  2.   message.getInterceptorChain().abort();
  3.   if (!message.getExchange().isOneWay()) {
  4.     //server side inbound
  5.     Endpoint e = message.getExchange().getEndpoint();
  6.     Message responseMsg = new MessageImpl();
  7.     responseMsg.setExchange(message.getExchange());
  8.     responseMsg = e.getBinding().createMessage(responseMsg);
  9.     message.getExchange().setOutMessage(responseMsg);
  10.     XMLStreamReader reader = message.getContent(XMLStreamReader.class);
  11.     if (reader == null && writer != null) {
  12.       reader = StaxUtils.createXMLStreamReader(writer.getDocument());
  13.     }
  14.     InterceptorChain chain = OutgoingChainInterceptor
  15.       .getOutInterceptorChain(message.getExchange());
  16.     responseMsg.setInterceptorChain(chain);
  17.     responseMsg.put("LogicalHandlerInterceptor.INREADER", reader);
  18.     chain.doIntercept(responseMsg);
  19.   }
  20. }

代码示例来源：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: org.apache.cxf/cxf-rt-transports-http

  1. String scheme = (String)message.get("http.scheme");
  2.   final MessageTrustDecider orig = message.get(MessageTrustDecider.class);
  3.   MessageTrustDecider trust = new HttpsMessageTrustDecider(certConstraints, orig);
  4.   message.put(MessageTrustDecider.class, trust);
  5. } else {
  6.   throw new UntrustedURLConnectionIOException(
  7. TLSSessionInfo tlsInfo = message.get(TLSSessionInfo.class);
  8. final Certificate[] certs = tlsInfo.getPeerCertificates();
  9. if (certs == null || certs.length == 0) {

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

  1. @Override
  2. public void handleFault(Message message) {
  4.   FaultMode mode = message.get(FaultMode.class);
  5.   Exception exception = message.getContent(Exception.class);
  7.   if (exception != null && exception.getCause() != null) {
  8.     if (mode != FaultMode.CHECKED_APPLICATION_FAULT) {
  9.       if (exception.getCause() instanceof NotificationFailedException) {
  10.         message.put(FaultMode.class, FaultMode.CHECKED_APPLICATION_FAULT);
  11.       }
  12.     }
  13.   }
  14. }

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

  1. private void doSoap(Message message) {
  2.   MessageContentsList list = (MessageContentsList)message.getContent(List.class);
  3.   if (list == null || list.isEmpty()) {
  4.     return;
  5.       message.put("write.attachments", Boolean.TRUE);
  6.       Object enc = soapMessage.getProperty(SOAPMessage.CHARACTER_SET_ENCODING);
  7.       if (enc instanceof String) {
  8.         message.put(Message.ENCODING, enc);
  9.       if (xmlDec != null) {
  10.         boolean b = PropertyUtils.isTrue(xmlDec);
  11.         message.put(StaxOutInterceptor.FORCE_START_DOCUMENT, b);

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

  1. protected void transformXWriter(Message message, XMLStreamWriter xWriter) {
  2.   CachedWriter writer = new CachedWriter();
  3.   XMLStreamWriter delegate = StaxUtils.createXMLStreamWriter(writer);
  4.   XSLTStreamWriter wrapper = new XSLTStreamWriter(getXSLTTemplate(), writer, delegate, xWriter);
  5.   message.setContent(XMLStreamWriter.class, wrapper);
  6.   message.put(AbstractOutDatabindingInterceptor.DISABLE_OUTPUTSTREAM_OPTIMIZATION,
  7.         Boolean.TRUE);
  8.   TransformationOutEndingInterceptor si = new TransformationOutEndingInterceptor();
  9.   message.getInterceptorChain().add(si);
  10. }

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

  1. @Override
  2. public void handleMessage(final Message message) throws Fault {
  3.   if (message.containsKey(WIRE_TAP_STARTED)) {
  4.     return;
  5.   }
  6.   message.put(WIRE_TAP_STARTED, Boolean.TRUE);
  7.   try {
  8.     InputStream is = message.getContent(InputStream.class);
  9.     if (is != null) {
  10.       handleInputStream(message, is);
  11.     } else {
  12.       Reader reader = message.getContent(Reader.class);
  13.       if (reader != null) {
  14.         handleReader(message, reader);
  15.       }
  16.     }
  17.   } catch (Exception e) {
  18.     throw new Fault(e);
  19.   }
  20. }

代码示例来源：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.   Node nd = message.getContent(Node.class);
  11.   SOAPMessage m = message.getContent(SOAPMessage.class);
  12.   Document document = null;
  13.   if (m != null) {
  14.     document = m.getSOAPPart();
  15.   } else if (nd != null) {
  16.     document = nd.getOwnerDocument();
  17.   } else {
  18.     document = DOMUtils.newDocument();
  19.     message.setContent(Node.class, document);
  20.   }
  21.   W3CDOMStreamWriter writer = new W3CDOMStreamWriter(document.createDocumentFragment());
  22.   // Replace stax writer with DomStreamWriter
  23.   message.setContent(XMLStreamWriter.class, writer);
  24.   message.put(ORIGINAL_WRITER, origWriter);
  25.   message.getInterceptorChain().add(ending);
  26. }
  27. @Override

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

  1. private int getReponseCodeFromMessage(Message message) {
  2.   Integer i = (Integer)message.get(Message.RESPONSE_CODE);
  3.   if (i != null) {
  4.     return i.intValue();
  5.   }
  6.   int code = hasNoResponseContent(message) ? HttpURLConnection.HTTP_ACCEPTED : HttpURLConnection.HTTP_OK;
  7.   // put the code in the message so that others can get it
  8.   message.put(Message.RESPONSE_CODE, code);
  9.   return code;
  10. }

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

  1. private String getEncoding(Message message) {
  2.   Exchange ex = message.getExchange();
  3.   String encoding = (String) message.get(Message.ENCODING);
  4.   if (encoding == null && ex.getInMessage() != null) {
  5.     encoding = (String) ex.getInMessage().get(Message.ENCODING);
  6.     message.put(Message.ENCODING, encoding);
  7.   }
  8.   if (encoding == null) {
  9.     encoding = StandardCharsets.UTF_8.name();
  10.     message.put(Message.ENCODING, encoding);
  11.   }
  12.   return encoding;
  13. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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