本文整理了Java中org.apache.cxf.message.Message.setExchange()
方法的一些代码示例,展示了Message.setExchange()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.setExchange()
方法的具体详情如下:
包路径:org.apache.cxf.message.Message
类名称:Message
方法名:setExchange
暂无
代码示例来源:origin: org.apache.cxf/cxf-rt-transports-http
private void updateClientPolicy() {
if (!clientSidePolicyCalced) {
//do no spend time on building Message and Exchange (which basically
//are ConcurrentHashMap instances) if the policy is already available
Message m = new MessageImpl();
m.setExchange(new ExchangeImpl());
m.getExchange().put(EndpointInfo.class, this.endpointInfo);
updateClientPolicy(m);
}
}
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
private Message createResponseMessage(Exchange exchange) {
if (exchange == null) {
return null;
}
Message m = exchange.getOutMessage();
if (m == null && !exchange.isOneWay()) {
Endpoint ep = exchange.getEndpoint();
m = new MessageImpl();
m.setExchange(exchange);
m = ep.getBinding().createMessage(m);
exchange.setOutMessage(m);
}
return m;
}
代码示例来源:origin: apache/cxf
public void setInFaultMessage(Message m) {
inFaultMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: org.apache.cxf/cxf-core
public void setOutMessage(Message m) {
outMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: org.apache.cxf/cxf-api
public void setInFaultMessage(Message m) {
inFaultMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: org.apache.cxf/cxf-api
public void setInMessage(Message m) {
inMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: org.apache.cxf/cxf-core
public void setOutFaultMessage(Message m) {
outFaultMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: org.apache.cxf/cxf-api
public void setOutMessage(Message m) {
outMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: apache/cxf
public void setInMessage(Message m) {
inMessage = m;
if (null != m) {
m.setExchange(this);
}
}
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
if (ct.toLowerCase().contains("multipart/related")) {
Message msg = new MessageImpl();
msg.setExchange(message.getExchange());
msg.put(Message.CONTENT_TYPE, ct);
try {
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
Endpoint ep = exchange.getEndpoint();
m = new org.apache.cxf.message.MessageImpl();
m.setExchange(exchange);
m = ep.getBinding().createMessage(m);
exchange.setInMessage(m);
Endpoint ep = exchange.getEndpoint();
m = new org.apache.cxf.message.MessageImpl();
m.setExchange(exchange);
m = ep.getBinding().createMessage(m);
exchange.setOutMessage(m);
代码示例来源:origin: apache/cxf
public OutboundSseEventBodyWriter(final ServerProviderFactory factory, final Exchange exchange) {
this.factory = factory;
this.message = new MessageImpl();
this.message.setExchange(exchange);
}
代码示例来源:origin: org.apache.cxf/cxf-rt-transports-http
inMessage.setExchange(exchange);
updateResponseHeaders(inMessage);
inMessage.put(Message.RESPONSE_CODE, responseCode);
代码示例来源:origin: org.apache.cxf/cxf-rt-transports-http
inMessage.setExchange(new ExchangeImpl());
inMessage.getExchange().put(Bus.class, bus);
inMessage.put(Message.DECOUPLED_CHANNEL_MESSAGE, Boolean.TRUE);
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
private void handleAbort(Message message, W3CDOMStreamWriter writer) {
message.getInterceptorChain().abort();
if (!message.getExchange().isOneWay()) {
//server side inbound
Endpoint e = message.getExchange().getEndpoint();
Message responseMsg = new MessageImpl();
responseMsg.setExchange(message.getExchange());
responseMsg = e.getBinding().createMessage(responseMsg);
message.getExchange().setOutMessage(responseMsg);
XMLStreamReader reader = message.getContent(XMLStreamReader.class);
if (reader == null && writer != null) {
reader = StaxUtils.createXMLStreamReader(writer.getDocument());
}
InterceptorChain chain = OutgoingChainInterceptor
.getOutInterceptorChain(message.getExchange());
responseMsg.setInterceptorChain(chain);
responseMsg.put("LogicalHandlerInterceptor.INREADER", reader);
chain.doIntercept(responseMsg);
}
}
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
Endpoint e = message.getExchange().getEndpoint();
Message responseMsg = new MessageImpl();
responseMsg.setExchange(message.getExchange());
responseMsg = e.getBinding().createMessage(responseMsg);
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
Endpoint e = message.getExchange().getEndpoint();
Message responseMsg = new MessageImpl();
responseMsg.setExchange(message.getExchange());
responseMsg = e.getBinding().createMessage(responseMsg);
if (!message.getExchange().isOneWay()) {
Message responseMsg = new MessageImpl();
responseMsg.setExchange(message.getExchange());
responseMsg = e.getBinding().createMessage(responseMsg);
message.getExchange().setOutMessage(responseMsg);
代码示例来源:origin: org.apache.cxf/cxf-rt-frontend-jaxws
if (null == faultMessage) {
faultMessage = new MessageImpl();
faultMessage.setExchange(message.getExchange());
faultMessage = exchange.getEndpoint().getBinding().createMessage(faultMessage);
代码示例来源: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: apache/cxf
private Message createOutMessage(Message inMessage) {
Endpoint e = inMessage.getExchange().getEndpoint();
Message mout = e.getBinding().createMessage();
mout.setExchange(inMessage.getExchange());
mout.setInterceptorChain(
OutgoingChainInterceptor.getOutInterceptorChain(inMessage.getExchange()));
inMessage.getExchange().setOutMessage(mout);
inMessage.getExchange().put("cxf.io.cacheinput", Boolean.FALSE);
return mout;
}
}
内容来源于网络,如有侵权,请联系作者删除!