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

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

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

Message.setExchange介绍

暂无

代码示例

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

  1. private void updateClientPolicy() {
  2. if (!clientSidePolicyCalced) {
  3. //do no spend time on building Message and Exchange (which basically
  4. //are ConcurrentHashMap instances) if the policy is already available
  5. Message m = new MessageImpl();
  6. m.setExchange(new ExchangeImpl());
  7. m.getExchange().put(EndpointInfo.class, this.endpointInfo);
  8. updateClientPolicy(m);
  9. }
  10. }

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

  1. private Message createResponseMessage(Exchange exchange) {
  2. if (exchange == null) {
  3. return null;
  4. }
  5. Message m = exchange.getOutMessage();
  6. if (m == null && !exchange.isOneWay()) {
  7. Endpoint ep = exchange.getEndpoint();
  8. m = new MessageImpl();
  9. m.setExchange(exchange);
  10. m = ep.getBinding().createMessage(m);
  11. exchange.setOutMessage(m);
  12. }
  13. return m;
  14. }

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

  1. public void setInFaultMessage(Message m) {
  2. inFaultMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. public void setOutMessage(Message m) {
  2. outMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. public void setInFaultMessage(Message m) {
  2. inFaultMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. public void setInMessage(Message m) {
  2. inMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. public void setOutFaultMessage(Message m) {
  2. outFaultMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. public void setOutMessage(Message m) {
  2. outMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. public void setInMessage(Message m) {
  2. inMessage = m;
  3. if (null != m) {
  4. m.setExchange(this);
  5. }
  6. }

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

  1. if (ct.toLowerCase().contains("multipart/related")) {
  2. Message msg = new MessageImpl();
  3. msg.setExchange(message.getExchange());
  4. msg.put(Message.CONTENT_TYPE, ct);
  5. try {

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

  1. Endpoint ep = exchange.getEndpoint();
  2. m = new org.apache.cxf.message.MessageImpl();
  3. m.setExchange(exchange);
  4. m = ep.getBinding().createMessage(m);
  5. exchange.setInMessage(m);
  6. Endpoint ep = exchange.getEndpoint();
  7. m = new org.apache.cxf.message.MessageImpl();
  8. m.setExchange(exchange);
  9. m = ep.getBinding().createMessage(m);
  10. exchange.setOutMessage(m);

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

  1. public OutboundSseEventBodyWriter(final ServerProviderFactory factory, final Exchange exchange) {
  2. this.factory = factory;
  3. this.message = new MessageImpl();
  4. this.message.setExchange(exchange);
  5. }

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

  1. inMessage.setExchange(exchange);
  2. updateResponseHeaders(inMessage);
  3. inMessage.put(Message.RESPONSE_CODE, responseCode);

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

  1. inMessage.setExchange(new ExchangeImpl());
  2. inMessage.getExchange().put(Bus.class, bus);
  3. inMessage.put(Message.DECOUPLED_CHANNEL_MESSAGE, Boolean.TRUE);

代码示例来源: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-frontend-jaxws

  1. Endpoint e = message.getExchange().getEndpoint();
  2. Message responseMsg = new MessageImpl();
  3. responseMsg.setExchange(message.getExchange());
  4. responseMsg = e.getBinding().createMessage(responseMsg);

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

  1. Endpoint e = message.getExchange().getEndpoint();
  2. Message responseMsg = new MessageImpl();
  3. responseMsg.setExchange(message.getExchange());
  4. responseMsg = e.getBinding().createMessage(responseMsg);
  5. if (!message.getExchange().isOneWay()) {
  6. Message responseMsg = new MessageImpl();
  7. responseMsg.setExchange(message.getExchange());
  8. responseMsg = e.getBinding().createMessage(responseMsg);
  9. message.getExchange().setOutMessage(responseMsg);

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

  1. if (null == faultMessage) {
  2. faultMessage = new MessageImpl();
  3. faultMessage.setExchange(message.getExchange());
  4. faultMessage = exchange.getEndpoint().getBinding().createMessage(faultMessage);

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

  1. public Conduit getConduit() {
  2. Message message = new MessageImpl();
  3. Exchange exchange = new ExchangeImpl();
  4. message.setExchange(exchange);
  5. message.putAll(getRequestContext());
  6. setExchangeProperties(exchange, getEndpoint(), null);
  7. return getConduitSelector().selectConduit(message);
  8. }

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

  1. private Message createOutMessage(Message inMessage) {
  2. Endpoint e = inMessage.getExchange().getEndpoint();
  3. Message mout = e.getBinding().createMessage();
  4. mout.setExchange(inMessage.getExchange());
  5. mout.setInterceptorChain(
  6. OutgoingChainInterceptor.getOutInterceptorChain(inMessage.getExchange()));
  7. inMessage.getExchange().setOutMessage(mout);
  8. inMessage.getExchange().put("cxf.io.cacheinput", Boolean.FALSE);
  9. return mout;
  10. }
  11. }

相关文章