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

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

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

Message.getExchange介绍

暂无

代码示例

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

  1. private boolean isResponseRedirected(Message outMessage) {
  2.   Exchange exchange = outMessage.getExchange();
  3.   return exchange != null
  4.       && Boolean.TRUE.equals(exchange.get(REQUEST_REDIRECTED));
  5. }

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

  1. public void run() {
  2.     outMessage.getExchange().put(Executor.class.getName()
  3.                    + ".USING_SPECIFIED", Boolean.TRUE);
  4.     ex2.execute(origRunnable);
  5.   }
  6. };

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

  1. public Servlet3Continuation() {
  2.   req.setAttribute(AbstractHTTPDestination.CXF_CONTINUATION_MESSAGE,
  3.            inMessage.getExchange().getInMessage());
  4.   callback = inMessage.getExchange().get(ContinuationCallback.class);
  5.   blockRestart = PropertyUtils.isTrue(inMessage.getContextualProperty(BLOCK_RESTART));
  6.   context = req.startAsync();
  7.   context.addListener(this);
  8. }

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

  1. @Override
  2. public void handleFault(Message message) {
  3.   Exception ex = message.getContent(Exception.class);
  4.   if (ex instanceof AuthenticationException) {
  5.     HttpServletResponse resp = (HttpServletResponse)message.getExchange()
  6.       .getInMessage().get(AbstractHTTPDestination.HTTP_RESPONSE);
  7.     resp.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
  8.     resp.setHeader("WWW-Authenticate", authenticationType + " realm=\"" + realm + "\"");
  9.     resp.setContentType("text/plain");
  10.     try {
  11.       resp.getOutputStream().write(ex.getMessage().getBytes());
  12.       resp.getOutputStream().flush();
  13.       message.getInterceptorChain().setFaultObserver(null); //avoid return soap fault
  14.       message.getInterceptorChain().abort();
  15.     } catch (IOException e) {
  16.       // TODO
  17.     }
  18.   }
  19. }

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

  1. outMessage.getExchange().put("client.redirect.exception", "true");
  2. throw ex;
  3. outMessage.put("transport.retransmit.url", newURL);
  4. retransmit(newURL);
  5. return true;

代码示例来源：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.   Method method = ex.get(Method.class);
  8.     BindingMessageInfo bmi;
  9.     MessageInfo wrappedMessageInfo = message.get(MessageInfo.class);
  10.     MessageInfo messageInfo;
  11.     if (wrappedMessageInfo == boi.getOperationInfo().getInput()) {
  12.       return;
  13.     message.put(MessageInfo.class, messageInfo);
  14.     message.put(BindingMessageInfo.class, bmi);
  15.     ex.put(BindingOperationInfo.class, boi2);
  16.       Service service = ServiceModelUtil.getService(message.getExchange());
  17.       DataBinding dataBinding = service.getDataBinding();
  18.       if (dataBinding instanceof WrapperCapableDatabinding) {

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

  1. private static SchemaValidationType getOverrideSchemaValidationType(Message message) {
  2.   Object obj = message.get(Message.SCHEMA_VALIDATION_ENABLED);
  3.   if (obj == null && message.getExchange() != null) {
  4.     obj = message.getExchange().get(Message.SCHEMA_VALIDATION_ENABLED);
  5.   }
  6.   if (obj != null) {
  7.     // this method will transform the legacy enabled as well
  8.     return getSchemaValidationType(obj);
  9.   }
  10.   return null;
  11. }

代码示例来源：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.         MessageObserver observer = message.getExchange()
  17.               .get(MessageObserver.class);
  18.         if (observer != null) {
  19.             .getContent(XMLStreamReader.class));
  20.           message.getExchange().setInMessage(responseMsg);
  21.           responseMsg.put(InterceptorChain.STARTING_AT_INTERCEPTOR_ID,
  22.                   LogicalHandlerInInterceptor.class.getName());
  23.           observer.onMessage(responseMsg);

代码示例来源：origin: oasp/oasp4j

  1. @Override
  2. public void handleMessage(Message message) throws Fault {
  3.  Throwable exception = message.getContent(Exception.class);
  4.  if (exception != null) {
  5.   message.getExchange().put("wrap.in.processing.exception", Boolean.FALSE);
  6.   throw new ServiceInvocationFailedException(exception, exception.toString(), "ServiceInvoke", null, this.service);
  7.  }
  8. }

代码示例来源：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(LogicalHandlerFaultOutInterceptor.ORIGINAL_WRITER);
  5.   boolean requestor = isRequestor(message);
  6.   XMLStreamReader reader = (XMLStreamReader)message.get("LogicalHandlerInterceptor.INREADER");
  7.   SOAPMessage origMessage = null;
  8.   if (reader != null) {
  9.     origMessage = message.getContent(SOAPMessage.class);
  10.     message.setContent(XMLStreamReader.class, reader);
  11.     message.removeContent(SOAPMessage.class);
  12.     Exchange exchange = message.getExchange();
  13.     FaultMode mode = message.get(FaultMode.class);
  14.       faultMessage.setExchange(message.getExchange());
  15.       faultMessage = exchange.getEndpoint().getBinding().createMessage(faultMessage);
  16.       faultMessage.put(FaultMode.class, mode);
  17.     reader = message.getContent(XMLStreamReader.class);
  18.     message.removeContent(XMLStreamReader.class);
  19.     if (reader != 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: apache/cxf

  1. @Override
  2.   public void handleFault(Message message) {
  3.     Exchange ex = message.getExchange();
  4.     if (Boolean.TRUE.equals(ex.get("org.apache.cxf.management.counter.enabled"))) {
  5.       FaultMode mode = message.get(FaultMode.class);
  6.       if (mode == null) {
  7.         mode = FaultMode.UNCHECKED_APPLICATION_FAULT;
  8.       }
  9.       ex.put(FaultMode.class, mode);
  10.     }
  11.   }
  12. }

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

  1. boolean exceptionSet = outMessage.getContent(Exception.class) != null;
  2. if (!exceptionSet) {
  3.   try {
  4.     Executor ex = outMessage.getExchange().get(Executor.class);
  5.     if (forceWQ && ex != null) {
  6.       final Executor ex2 = ex;
  7.       WorkQueueManager mgr = outMessage.getExchange().getBus()
  8.         .getExtension(WorkQueueManager.class);
  9.       AutomaticWorkQueue qu = mgr.getNamedWorkQueue("http-conduit");
  10.       outMessage.getExchange().put(Executor.class.getName()
  11.                    + ".USING_SPECIFIED", Boolean.TRUE);
  12.       ex.execute(runnable);

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

  1. protected HandlerChainInvoker getInvoker(T message) {
  2.   Exchange ex = message.getExchange();
  3.   HandlerChainInvoker invoker =
  4.     ex.get(HandlerChainInvoker.class);
  5.   if (null == invoker) {
  6.     invoker = new HandlerChainInvoker(binding.getHandlerChain(),
  7.                      isOutbound(message));
  8.     ex.put(HandlerChainInvoker.class, invoker);
  9.   }
  10.   boolean outbound = isOutbound(message, ex);
  11.   if (outbound) {
  12.     invoker.setOutbound();
  13.   } else {
  14.     invoker.setInbound();
  15.   }
  16.   invoker.setRequestor(isRequestor(message));
  17.   if (ex.isOneWay()
  18.     || ((isRequestor(message) && !outbound)
  19.       || (!isRequestor(message) && outbound))) {
  20.     invoker.setResponseExpected(false);
  21.   } else {
  22.     invoker.setResponseExpected(true);
  23.   }
  24.   return invoker;
  25. }

代码示例来源：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. protected void handleResponseInternal() throws IOException {
  2.   Exchange exchange = outMessage.getExchange();
  3.   int responseCode = doProcessResponseCode();
  4.   inMessage.setExchange(exchange);
  5.   updateResponseHeaders(inMessage);
  6.   inMessage.put(Message.RESPONSE_CODE, responseCode);
  7.   if (MessageUtils.getContextualBoolean(outMessage, SET_HTTP_RESPONSE_MESSAGE, false)) {
  8.     inMessage.put(HTTP_RESPONSE_MESSAGE, getResponseMessage());
  9.       exchange.put("IN_CHAIN_COMPLETE", Boolean.TRUE);
  10.       exchange.setInMessage(inMessage);
  11.       return;
  12.   String charset = HttpHeaderHelper.findCharset((String)inMessage.get(Message.CONTENT_TYPE));
  13.   String normalizedEncoding = HttpHeaderHelper.mapCharset(charset);
  14.   if (normalizedEncoding == null) {
  15.     throw new IOException(m);
  16.   inMessage.put(Message.ENCODING, normalizedEncoding);
  17.   if (in == null) {
  18.     in = getInputStream();

代码示例来源：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.       throw new Fault(new org.apache.cxf.common.i18n.Message("COULD_NOT_INVOKE", BUNDLE), e);
  9.     Service service = message.getExchange().getService();
  10.                                  message.getExchange().getBus());
  11.         writer.setSchema(schema);
  12.       OperationInfo op = message.getExchange().getBindingOperationInfo().getOperationInfo();
  13.       QName faultName = getFaultName(fault, cause.getClass(), op);
  14.       MessagePartInfo part = getFaultMessagePart(faultName, op);
  15.     FaultMode mode = message.get(FaultMode.class);
  16.     if (mode == FaultMode.CHECKED_APPLICATION_FAULT) {

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

  1. @Override
  2.   public void handleMessage(Message message) throws Fault {
  3.     final Map<String, List<String>> headers = CastUtils.cast((Map<?, ?>)message.get(Message.PROTOCOL_HEADERS));
  5.     final TraceScopeHolder<TraceScope> holder = super.startTraceSpan(headers,
  6.       getUri(message), (String)message.get(Message.HTTP_REQUEST_METHOD));
  8.     if (holder != null) {
  9.       message.getExchange().put(TRACE_SPAN, holder);
  10.     }
  11.   }
  12. }

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

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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