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

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

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

Message.putAll介绍

暂无

代码示例

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

public void putAll(Map<? extends String, ? extends Object> t) {
  message.putAll(t);
}

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

public void putAll(Map<? extends String, ? extends Object> t) {
  message.putAll(t);
}

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

public void putAll(Map<? extends String, ? extends Object> t) {
  message.putAll(t);
}

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

public void putAll(Map<? extends String, ? extends Object> t) {
  message.putAll(t);
}

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

protected void setContext(Map<String, Object> ctx, Message message) {
  if (ctx != null) {
    message.putAll(ctx);
    if (LOG.isLoggable(Level.FINE)) {
      LOG.fine("set requestContext to message be" + ctx);
    }
  }
}

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

protected void setContext(Map<String, Object> ctx, Message message) {
  if (ctx != null) {
    message.putAll(ctx);
    if (LOG.isLoggable(Level.FINE)) {
      LOG.fine("set requestContext to message be" + ctx);
    }
  }
}

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

protected void setContext(Map<String, Object> ctx, Message message) {
  if (ctx != null) {
    message.putAll(ctx);
    if (LOG.isLoggable(Level.FINE)) {
      LOG.fine("set requestContext to message be" + ctx);
    }
  }
}

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

protected void setContext(Map<String, Object> ctx, Message message) {
  if (ctx != null) {
    message.putAll(ctx);
    if (LOG.isLoggable(Level.FINE)) {
      LOG.fine("set requestContext to message be" + ctx);
    }
  }
}

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

protected void setContexts(Message message, Exchange exchange,
              Map<String, Object> context, boolean proxy) {
  if (context == null) {
    context = new HashMap<>();
  }
  Map<String, Object> reqContext = CastUtils.cast((Map<?, ?>)context.get(REQUEST_CONTEXT));
  Map<String, Object> resContext = CastUtils.cast((Map<?, ?>)context.get(RESPONSE_CONTEXT));
  if (reqContext == null) {
    reqContext = new HashMap<>(cfg.getRequestContext());
    context.put(REQUEST_CONTEXT, reqContext);
  }
  reqContext.put(Message.PROTOCOL_HEADERS, message.get(Message.PROTOCOL_HEADERS));
  reqContext.put(Message.REQUEST_URI, message.get(Message.REQUEST_URI));
  reqContext.put(Message.ENDPOINT_ADDRESS, message.get(Message.ENDPOINT_ADDRESS));
  reqContext.put(PROXY_PROPERTY, proxy);
  if (resContext == null) {
    resContext = new HashMap<>();
    context.put(RESPONSE_CONTEXT, resContext);
  }
  message.put(Message.INVOCATION_CONTEXT, context);
  message.putAll(reqContext);
  exchange.putAll(reqContext);
}

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

protected void setContexts(Message message, Exchange exchange,
              Map<String, Object> context, boolean proxy) {
  if (context == null) {
    context = new HashMap<>();
  }
  Map<String, Object> reqContext = CastUtils.cast((Map<?, ?>)context.get(REQUEST_CONTEXT));
  Map<String, Object> resContext = CastUtils.cast((Map<?, ?>)context.get(RESPONSE_CONTEXT));
  if (reqContext == null) {
    reqContext = new HashMap<>(cfg.getRequestContext());
    context.put(REQUEST_CONTEXT, reqContext);
  }
  reqContext.put(Message.PROTOCOL_HEADERS, message.get(Message.PROTOCOL_HEADERS));
  reqContext.put(Message.REQUEST_URI, message.get(Message.REQUEST_URI));
  reqContext.put(Message.ENDPOINT_ADDRESS, message.get(Message.ENDPOINT_ADDRESS));
  reqContext.put(PROXY_PROPERTY, proxy);
  if (resContext == null) {
    resContext = new HashMap<>();
    context.put(RESPONSE_CONTEXT, resContext);
  }
  message.put(Message.INVOCATION_CONTEXT, context);
  message.putAll(reqContext);
  exchange.putAll(reqContext);
}

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

protected void setContexts(Message message, Exchange exchange, 
              Map<String, Object> context, boolean proxy) {
  Map<String, Object> reqContext = null;
  Map<String, Object> resContext = null;
  if (context == null) {
    context = new HashMap<String, Object>();
  }
  reqContext = CastUtils.cast((Map<?, ?>)context.get(REQUEST_CONTEXT));
  resContext = CastUtils.cast((Map<?, ?>)context.get(RESPONSE_CONTEXT));
  if (reqContext == null) { 
    reqContext = new HashMap<String, Object>(cfg.getRequestContext());
    context.put(REQUEST_CONTEXT, reqContext);
  }
  reqContext.put(Message.PROTOCOL_HEADERS, message.get(Message.PROTOCOL_HEADERS));
  reqContext.put(Message.REQUEST_URI, message.get(Message.REQUEST_URI));
  reqContext.put(Message.ENDPOINT_ADDRESS, message.get(Message.ENDPOINT_ADDRESS));
  reqContext.put(PROXY_PROPERTY, proxy);
  
  if (resContext == null) {
    resContext = new HashMap<String, Object>();
    context.put(RESPONSE_CONTEXT, resContext);
  }
  
  message.put(Message.INVOCATION_CONTEXT, context);
  message.putAll(reqContext);
  exchange.putAll(reqContext);
}

代码示例来源：origin: geoserver/geofence

private Message getOutMessage(Message inMessage) {
  Exchange exchange = inMessage.getExchange();
  Message outMessage = exchange.getOutMessage();
  if (outMessage == null) {
    Endpoint endpoint = exchange.get(Endpoint.class);
    outMessage = endpoint.getBinding().createMessage();
    exchange.setOutMessage(outMessage);
  }
  outMessage.putAll(inMessage);
  return outMessage;
}

代码示例来源：origin: roskart/dropwizard-jaxws

private Message getOutMessage(Message inMessage) {
  Exchange exchange = inMessage.getExchange();
  Message outMessage = exchange.getOutMessage();
  if (outMessage == null) {
    Endpoint endpoint = exchange.get(Endpoint.class);
    outMessage = endpoint.getBinding().createMessage();
    exchange.setOutMessage(outMessage);
  }
  outMessage.putAll(inMessage);
  return outMessage;
}

代码示例来源：origin: geoserver/geofence

/**
 * @param inMessage
 * @return Message
 */
private Message getOutMessage(Message inMessage)
{
  Exchange exchange = inMessage.getExchange();
  Message outMessage = exchange.getOutMessage();
  if (outMessage == null)
  {
    Endpoint endpoint = exchange.get(Endpoint.class);
    outMessage = endpoint.getBinding().createMessage();
    exchange.setOutMessage(outMessage);
  }
  outMessage.putAll(inMessage);
  return outMessage;
}

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

public Conduit getConduit() {
  Message message = new MessageImpl();
  Exchange exchange = new ExchangeImpl();
  message.setExchange(exchange);
  message.putAll(getRequestContext());
  setExchangeProperties(exchange, getEndpoint(), null);
  return getConduitSelector().selectConduit(message);
}

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

public Conduit getConduit() {
  Message message = new MessageImpl();
  Exchange exchange = new ExchangeImpl();
  message.setExchange(exchange);
  message.putAll(getRequestContext());
  setExchangeProperties(exchange, getEndpoint(), null);
  return getConduitSelector().selectConduit(message);
}

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

public Conduit getConduit() {
  Message message = new MessageImpl();
  Exchange exchange = new ExchangeImpl();
  message.setExchange(exchange);
  message.putAll(getRequestContext());
  setExchangeProperties(exchange, getEndpoint(), null);
  return getConduitSelector().selectConduit(message);
}

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

public Conduit getConduit() {
  Message message = new MessageImpl();
  Exchange exchange = new ExchangeImpl();
  message.setExchange(exchange);
  message.putAll(getRequestContext());
  setExchangeProperties(exchange, getEndpoint(), null);
  return getConduitSelector().selectConduit(message);
}

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

protected void invokeInboundChain(Exchange ex, Endpoint ep) {
  Message m = getInBoundMessage(ex);
  Message inMsg = ep.getBinding().createMessage();
  MessageImpl.copyContent(m, inMsg);
  //Copy Response Context to Client inBound Message
  //TODO a Context Filter Strategy required.
  inMsg.putAll(m);
  inMsg.put(Message.REQUESTOR_ROLE, Boolean.TRUE);
  inMsg.put(Message.INBOUND_MESSAGE, Boolean.TRUE);
  inMsg.setExchange(ex);
  Exception exc = inMsg.getContent(Exception.class);
  if (exc != null) {
    ex.setInFaultMessage(inMsg);
    ColocInFaultObserver observer = new ColocInFaultObserver(bus);
    observer.onMessage(inMsg);
  } else {
    //Handle Response
    ex.setInMessage(inMsg);
    PhaseManager pm = bus.getExtension(PhaseManager.class);
    SortedSet<Phase> phases = new TreeSet<>(pm.getInPhases());
    ColocUtil.setPhases(phases, Phase.USER_LOGICAL, Phase.PRE_INVOKE);
    InterceptorChain chain = ColocUtil.getInInterceptorChain(ex, phases);
    inMsg.setInterceptorChain(chain);
    chain.doIntercept(inMsg);
  }
  ex.put(ClientImpl.FINISHED, Boolean.TRUE);
}

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

/**
 * Retrieves/creates the corresponding Outbound Message.
 */
private Message getOutMessage(Message message) {
  Exchange exchange = message.getExchange();
  Message outMessage = exchange.getOutMessage();
  if (outMessage == null) {
    Endpoint endpoint = exchange.getEndpoint();
    outMessage = new MessageImpl();
    outMessage.putAll(message);
    outMessage.remove(Message.PROTOCOL_HEADERS);
    outMessage.setExchange(exchange);
    outMessage = endpoint.getBinding().createMessage(outMessage);
    exchange.setOutMessage(outMessage);
  }
  return outMessage;
}

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

Message

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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