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

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

MessageImpl.介绍

暂无

代码示例

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

LOG.fine("Service http request on thread: " + Thread.currentThread());
Message inMessage = new MessageImpl();
ExchangeImpl exchange = new ExchangeImpl();
exchange.setInMessage(inMessage);

代码示例来源：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: org.apache.cxf/cxf-rt-transports-http

if (inMessage == null) {
LOG.fine("Create a new message for processing");
inMessage = new MessageImpl();
ExchangeImpl exchange = new ExchangeImpl();
exchange.setInMessage(inMessage);

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

Message m = new MessageImpl();
updateResponseHeaders(m);
List authHeaderValues = Headers.getSetProtocolHeaders(m).get("WWW-Authenticate");

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

return false;
Message m = new MessageImpl();
updateResponseHeaders(m);

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

String ct = ds.getContentType();
if (ct.toLowerCase().contains("multipart/related")) {
Message msg = new MessageImpl();
msg.setExchange(message.getExchange());
msg.put(Message.CONTENT_TYPE, ct);

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

m = new org.apache.cxf.message.MessageImpl();
m.setExchange(exchange);
m = ep.getBinding().createMessage(m);
m = new org.apache.cxf.message.MessageImpl();
m.setExchange(exchange);
m = ep.getBinding().createMessage(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

Message inMessage = new MessageImpl();
inMessage.setExchange(exchange);
updateResponseHeaders(inMessage);

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

if (!message.getExchange().isOneWay()) {
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

&& observer != null) {
Endpoint e = message.getExchange().getEndpoint();
Message respOnseMsg= new MessageImpl();
responseMsg.setExchange(message.getExchange());
respOnseMsg= e.getBinding().createMessage(responseMsg);
Endpoint e = message.getExchange().getEndpoint();
if (!message.getExchange().isOneWay()) {
Message respOnseMsg= new MessageImpl();
responseMsg.setExchange(message.getExchange());
respOnseMsg= e.getBinding().createMessage(responseMsg);

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

faultMessage = new MessageImpl();
faultMessage.setExchange(message.getExchange());
faultMessage = exchange.getEndpoint().getBinding().createMessage(faultMessage);

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

private Message setupMessage(String name, String password) {
AuthorizationPolicy policy = new AuthorizationPolicy();
policy.setUserName(name);
policy.setPassword(password);
Message message = new MessageImpl();
message.put(AuthorizationPolicy.class, policy);
return message;
}
}

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

private static Message createMessage(Exchange exchange) {
Endpoint ep = exchange.getEndpoint();
Message msg = null;
if (ep != null) {
msg = new MessageImpl();
msg.setExchange(exchange);
msg = ep.getBinding().createMessage(msg);
}
return msg;
}

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

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: apache/cxf

private MessageImpl createMessage(Endpoint e, Bus b) {
MessageImpl m = new MessageImpl();
Exchange ex = new ExchangeImpl();
m.setExchange(ex);
ex.put(Endpoint.class, e);
ex.put(Bus.class, b);
ex.put(Service.class, e.getService());
return m;
}

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

protected void processStreamIo(IoSession session, InputStream in, OutputStream out) {
final MessageImpl m = new MessageImpl();
final Exchange exchange = new ExchangeImpl();
exchange.setDestination(UDPDestination.this);
m.setDestination(UDPDestination.this);
exchange.setInMessage(m);
m.setContent(InputStream.class, in);
out = new UDPDestinationOutputStream(out);
m.put(OutputStream.class, out);
queue.execute(() -> getMessageObserver().onMessage(m));
}