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

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

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

Message.get介绍

[英]Retrieve any binary attachments associated with the message.
[中]检索与邮件关联的任何二进制附件。

代码示例

代码示例来源：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: opensourceBIM/BIMserver

  1. @Override
  2.   public void handleMessage(SoapMessage message) throws Fault {
  3.     HttpServletResponse response = (HttpServletResponse) message.getExchange()
  4.         .getInMessage().get(AbstractHTTPDestination.HTTP_RESPONSE);
  5.     response.setStatus(200);
  6. //        message.put(SoapMessage.RESPONSE_CODE, 200);
  7.   }
  8. }

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

  1. @Override
  2. protected void updateMessageForSuspend() {
  3.   Message currentMessage = PhaseInterceptorChain.getCurrentMessage();
  4.   if (currentMessage.get(WriteListener.class) != null) {
  5.     // CXF Continuation WriteListener will likely need to be introduced
  6.     // for NIO supported with non-Servlet specific mechanisms
  7.     getOutputStream().setWriteListener(currentMessage.get(WriteListener.class));
  8.     currentMessage.getInterceptorChain().suspend();
  9.   } else {
  10.     inMessage.getExchange().getInMessage().getInterceptorChain().suspend();
  11.   }
  12. }

代码示例来源：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.     if (inObjects != null) {
  10.       if (!(inObjects == outObjects)) {
  11.     message.put(HolderInInterceptor.CLIENT_HOLDERS, holders);

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

  1. /**
  2.  * While extracting the Message.PROTOCOL_HEADERS property from the Message,
  3.  * this call ensures that the Message.PROTOCOL_HEADERS property is
  4.  * set on the Message. If it is not set, an empty map is placed there, and
  5.  * then returned.
  6.  *
  7.  * @param message The outbound message
  8.  * @return The PROTOCOL_HEADERS map
  9.  */
  10. public static Map<String, List<String>> getSetProtocolHeaders(final Message message) {
  11.   Map<String, List<String>> headers =
  12.     CastUtils.cast((Map<?, ?>)message.get(Message.PROTOCOL_HEADERS));
  13.   if (null == headers) {
  14.     headers = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
  15.   } else if (headers instanceof HashMap) {
  16.     Map<String, List<String>> headers2
  17.       = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
  18.     headers2.putAll(headers);
  19.     headers = headers2;
  20.   }
  21.   message.put(Message.PROTOCOL_HEADERS, headers);
  22.   return headers;
  23. }

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

  1. public String determineContentType() {
  2.   String ct = null;
  3.   List<Object> ctList = CastUtils.cast(headers.get(Message.CONTENT_TYPE));
  4.   if (ctList != null && ctList.size() == 1 && ctList.get(0) != null) {
  5.     ct = ctList.get(0).toString();
  6.   } else {
  7.     ct = (String)message.get(Message.CONTENT_TYPE);
  8.   }
  9.   String enc = (String)message.get(Message.ENCODING);
  10.   if (null != ct) {
  11.     if (enc != null
  12.       && ct.indexOf("charset=") == -1
  13.       && !ct.toLowerCase().contains("multipart/related")) {
  14.       ct = ct + "; charset=" + enc;
  15.     }
  16.   } else if (enc != null) {
  17.     ct = "text/xml; charset=" + enc;
  18.   } else {
  19.     ct = "text/xml";
  20.   }
  21.   return ct;
  22. }

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

  1. public void handleMessage(Message message) throws Fault {
  2.   W3CDOMStreamWriter domWriter = (W3CDOMStreamWriter)message.getContent(XMLStreamWriter.class);
  3.   XMLStreamWriter origWriter = (XMLStreamWriter)message
  4.     .get(LogicalHandlerOutInterceptor.ORIGINAL_WRITER);
  5.   XMLStreamReader reader = (XMLStreamReader)message.get("LogicalHandlerInterceptor.INREADER");
  6.   SOAPMessage origMessage = null;
  7.   if (reader != null) {
  8.     origMessage = message.getContent(SOAPMessage.class);
  9.     message.setContent(XMLStreamReader.class, reader);
  10.     message.removeContent(SOAPMessage.class);
  11.       if (!message.getExchange().isOneWay()) {
  12.         Endpoint e = message.getExchange().getEndpoint();
  13.         Message responseMsg = new MessageImpl();
  14.         responseMsg.setExchange(message.getExchange());
  15.         responseMsg = e.getBinding().createMessage(responseMsg);
  16.             .getContent(XMLStreamReader.class));
  17.           message.getExchange().setInMessage(responseMsg);
  18.           responseMsg.put(InterceptorChain.STARTING_AT_INTERCEPTOR_ID,
  19.                   LogicalHandlerInInterceptor.class.getName());
  20.           observer.onMessage(responseMsg);

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

  1. private org.apache.cxf.security.SecurityContext getInternalSecurityContext() {
  2.     org.apache.cxf.security.SecurityContext sc = m.getContent(org.apache.cxf.security.SecurityContext.class);
  3.     if (sc == null) {
  4.       sc = m.get(org.apache.cxf.security.SecurityContext.class);
  5.     }
  6.     return sc;
  7.   }
  8. }

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

  1. public static Message getContextMessage(Message m) {
  2.   
  3.   Message contextMessage = m.getExchange() != null ? m.getExchange().getInMessage() : m;
  4.   if (contextMessage == null && Boolean.FALSE.equals(m.get(Message.INBOUND_MESSAGE))) {
  5.     contextMessage = m;
  6.   }
  7.   return contextMessage;
  8. }

代码示例来源：origin: org.mule.services/mule-service-soap

  1. private DispatchingRequest getDispatchingRequest(Message message) {
  2.   Exchange exchange = message.getExchange();
  3.   String action = (String) exchange.get(MULE_SOAP_ACTION);
  4.   Map<String, String> headers = new HashMap<>();
  5.   headers.put(SOAP_ACTION, action);
  6.   // It's important that content type is bundled with the headers
  7.   headers.put(CONTENT_TYPE, (String) message.get(CONTENT_TYPE));
  8.   headers.putAll((Map) exchange.get(MULE_TRANSPORT_HEADERS_KEY));
  9.   InputStream content = new ByteArrayInputStream(message.getContent(OutputStream.class).toString().getBytes());
  10.   return new DispatchingRequest(content, (String) exchange.get(MULE_WSC_ADDRESS), headers);
  11.  }
  12. }

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

  1. public void handleMessage(Message message) throws Fault {
  2.   Fault f = (Fault)message.getContent(Exception.class);
  3.   if (f == null) {
  4.     return;
  5.       SoapVersion soapVersion = (SoapVersion)message.get(SoapVersion.class.getName());
  6.       if (soapVersion != null && soapVersion.getVersion() != 1.1) {
  7.         if (f instanceof SoapFault) {
  8.           for (Iterator<QName> it = CastUtils.cast(sf.getFault().getFaultSubcodes()); it.hasNext();) {
  9.             ((SoapFault) f).addSubCode(it.next());
  10.       throw new Fault(new org.apache.cxf.common.i18n.Message("COULD_NOT_INVOKE", BUNDLE), e);
  11.     Service service = message.getExchange().getService();
  12.                                  message.getExchange().getBus());
  13.         writer.setSchema(schema);
  14.       OperationInfo op = message.getExchange().getBindingOperationInfo().getOperationInfo();
  15.       QName faultName = getFaultName(fault, cause.getClass(), op);
  16.       MessagePartInfo part = getFaultMessagePart(faultName, op);
  17.     FaultMode mode = message.get(FaultMode.class);
  18.     if (mode == FaultMode.CHECKED_APPLICATION_FAULT) {

代码示例来源：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) {

代码示例来源：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) {

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

  1. public void handleMessage(Message message) throws Fault {
  2.   BindingOperationInfo bop = message.getExchange().getBindingOperationInfo();
  3.   if (bop != null && !bindingName.equals(bop.getBinding().getName())) {
  4.     return;
  5.   } else if (DataSource.class.isAssignableFrom(type)) {
  6.     MessageContentsList list = (MessageContentsList)message.getContent(List.class);
  7.     DataSource ds = (DataSource)list.get(0);
  8.     String ct = ds.getContentType();
  9.     if (ct.toLowerCase().contains("multipart/related")) {
  10.       Message msg = new MessageImpl();
  11.       msg.setExchange(message.getExchange());
  12.       msg.put(Message.CONTENT_TYPE, ct);
  13.       try {
  14.         msg.setContent(InputStream.class, ds.getInputStream());
  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.       OutputStream out = message.getContent(OutputStream.class);
  19.       message.put(Message.CONTENT_TYPE, ct);
  20.       try {
  21.         InputStream in = ds.getInputStream();

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

  1. public void handleMessage(Message message) throws Fault {
  2.   String method = (String)message.get(Message.HTTP_REQUEST_METHOD);
  3.   String query = (String)message.get(Message.QUERY_STRING);
  4.   if (!"GET".equals(method) || StringUtils.isEmpty(query)) {
  5.     return;
  6.   }
  7.   Endpoint endpoint = message.getExchange().getEndpoint();
  8.   synchronized (endpoint) {
  9.     if (!StringUtils.isEmpty(contextName)) {
  10.       AuthorizationPolicy policy = message.get(AuthorizationPolicy.class);
  11.       if (policy == null) {
  12.         handle401response(message, endpoint);
  13.         return;
  14.       }
  15.       Subject subject = (Subject)authenticate(policy.getUserName(), policy.getPassword());
  16.       if (subject == null) {
  17.         handle401response(message, endpoint);
  18.         return;
  19.       }
  20.     }
  21.   }
  22. }

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

  1. boolean getRequest = "GET".equals(message.get(Message.HTTP_REQUEST_METHOD));
  2.   boolean emptyRequest = getRequest || PropertyUtils.isTrue(message.get(EMPTY_REQUEST_PROPERTY));
  3. Map<String, List<Object>> theHeaders = CastUtils.cast(headers);
  4. logProtocolHeaders(LOG, Level.FINE, theHeaders, logSensitiveHeaders());

代码示例来源：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-api

  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.   
  9.   if (encoding == null) {
  10.     encoding = "UTF-8";
  11.     message.put(Message.ENCODING, encoding);
  12.   }
  13.   return encoding;
  14. }

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

  1. String newURL,
  2.                   Message message) throws IOException {
  3. Map<String, Integer> visitedURLs = CastUtils.cast((Map<?, ?>)message.get(KEY_VISITED_URLS));
  4. if (visitedURLs == null) {
  5.   visitedURLs = new HashMap<>();
  6.   message.put(KEY_VISITED_URLS, visitedURLs);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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