本文整理了Java中org.apache.axis2.context.MessageContext.setProperty()
方法的一些代码示例,展示了MessageContext.setProperty()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MessageContext.setProperty()
方法的具体详情如下:
包路径:org.apache.axis2.context.MessageContext
类名称:MessageContext
方法名:setProperty
暂无
代码示例来源:origin: net.exogeni.orca.core/shirako
/**
* Attaches the auth token of a caller to the message context
* @param context context
* @param authToken authToken
*/
public static void setClientAuthToken(MessageContext context, AuthToken authToken)
{
context.setProperty(AUTHTOKEN_CLIENT, authToken);
}
代码示例来源:origin: org.apache.sandesha2/sandesha2-core
public boolean setProperty(String key, Object val) {
if (msgContext == null)
return false;
msgContext.setProperty(key, val);
return true;
}
代码示例来源:origin: org.apache.sandesha2/sandesha2-core
public InvocationResponse invoke(MessageContext msgContext) {
msgContext.setProperty("IsAddressingProcessed", Boolean.FALSE);
return InvocationResponse.CONTINUE;
}
}
代码示例来源:origin: net.exogeni.orca.core/shirako
/**
* Attaches the authtoken of an actor that is about to send a message to
* another actor to the specified call
* @param context context
* @param authToken authToken
*/
public static void setMyAuthToken(MessageContext context, AuthToken authToken)
{
context.setProperty(AUTHTOKEN_MINE, authToken);
}
代码示例来源:origin: stackoverflow.com
MessageContext responseMessageContext =
MessageContext.getCurrentMessageContext().getOperationContext().getMessageContext(
WSDLConstants.MESSAGE_LABEL_OUT_VALUE);
List headers = new ArrayList();
headers.add(new Header(HTTPConstants.HEADER_CONTENT_ENCODING, "identity"));
responseMessageContext.setProperty(HTTPConstants.HTTP_HEADERS, headers);
代码示例来源:origin: org.apache.axis2/axis2-adb
@Override
protected void invokeBusinessLogic(MessageContext messageCtx) throws AxisFault {
messageCtx.setProperty(DO_ASYNC, Boolean.TRUE);
super.receive(messageCtx);
}
}
代码示例来源:origin: org.apache.axis2/axis2-transport-http
public RestRequestProcessor(String httpMethodString,
HttpServletRequest request,
HttpServletResponse response) throws IOException {
this.request = request;
this.response = response;
messageContext = createMessageContext(this.request, this.response, false);
messageContext.setProperty(org.apache.axis2.transport.http.HTTPConstants.HTTP_METHOD,
httpMethodString);
}
代码示例来源:origin: org.apache.synapse/synapse-samples
protected void setSessionID(MessageContext axis2MessageContext, String value) {
if (value == null) {
return;
}
Map map = (Map) axis2MessageContext.getProperty(HTTPConstants.HTTP_HEADERS);
if (map == null) {
map = new HashMap();
axis2MessageContext.setProperty(HTTPConstants.HTTP_HEADERS, map);
}
map.put(COOKIE, value);
}
代码示例来源:origin: stackoverflow.com
public class IteratorCounter extends AbstractMediator{
@Override
public boolean mediate(MessageContext ctx) {
String msgSeq = (String) ctx.getProperty("messageSequence.it1");
String count = msgSeq.split("/")[0];
ctx.setProperty("msgNo", count);
return true;
}
}
代码示例来源:origin: org.apache.axis2/axis2-transport-jms
/**
* Read the transport headers from the JMS Message and set them to the axis2 message context
*
* @param message the JMS Message received
* @param responseMsgCtx the axis message context
* @throws AxisFault on error
*/
public static void loadTransportHeaders(Message message, MessageContext responseMsgCtx)
throws AxisFault {
responseMsgCtx.setProperty(MessageContext.TRANSPORT_HEADERS, getTransportHeaders(message));
}
代码示例来源:origin: wso2/wso2-synapse
private void handleSpecialProperties(Object resultValue,
org.apache.axis2.context.MessageContext axis2MessageCtx) {
axis2MessageCtx.setProperty(org.apache.axis2.Constants.Configuration.CONTENT_TYPE, resultValue);
Object o = axis2MessageCtx.getProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS);
Map headers = (Map) o;
if (headers != null) {
headers.remove(HTTP.CONTENT_TYPE);
headers.put(HTTP.CONTENT_TYPE, resultValue);
}
}
代码示例来源:origin: org.apache.axis2.transport/axis2-transport-xmpp
/**
* This method will be triggered, when a message is arrived at client side
*/
public void processPacket(Packet packet) {
Message message = (Message)packet;
String xml = StringEscapeUtils.unescapeXml(message.getBody());
log.info("Client received message : "+xml);
this.responseReceived = true;
InputStream inputStream = new ByteArrayInputStream(xml.getBytes());
messageContext.setProperty(MessageContext.TRANSPORT_IN, inputStream);
}
代码示例来源:origin: wso2/wso2-synapse
public void writeTo(MessageContext messageContext, OMOutputFormat format,
OutputStream out, boolean preserve) throws AxisFault {
if (preserve) {
messageContext.setProperty(JsonUtil.PRESERVE_JSON_STREAM, true);
}
JsonUtil.writeAsJson(messageContext, out);
if (logger.isDebugEnabled()) {
logger.debug("#writeTo. Wrote JSON payload to output stream. MessageID: " + messageContext.getMessageID());
}
}
代码示例来源:origin: org.apache.synapse/synapse-core
public void setDoingGET(boolean b) {
if(b) {
axis2MessageContext.setDoingREST(b);
axis2MessageContext.setProperty(Constants.Configuration.HTTP_METHOD,
Constants.Configuration.HTTP_METHOD_GET);
} else {
axis2MessageContext.removeProperty(Constants.Configuration.HTTP_METHOD);
}
}
代码示例来源:origin: org.apache.axis2/axis2-transport-base
public void setParameters(MessageContext msgCtx) {
for (Parameter p : parameters) {
msgCtx.setProperty(p.getName(), p.getValue());
}
}
}
代码示例来源:origin: org.apache.sandesha2/sandesha2-core
private static void setTransportProperties(MessageContext returnMessage, RMMsgContext makeConnectionMessage) {
returnMessage.setProperty(MessageContext.TRANSPORT_OUT, makeConnectionMessage.getProperty(MessageContext.TRANSPORT_OUT));
returnMessage.setProperty(Constants.OUT_TRANSPORT_INFO, makeConnectionMessage.getProperty(Constants.OUT_TRANSPORT_INFO));
Object contentType = makeConnectionMessage.getProperty(Constants.Configuration.CONTENT_TYPE);
returnMessage.setProperty(Constants.Configuration.CONTENT_TYPE, contentType);
returnMessage.setTransportOut(makeConnectionMessage.getMessageContext().getTransportOut());
}
}
代码示例来源:origin: org.apache.synapse/synapse-core
public InvocationResponse invoke(MessageContext msgContext) throws AxisFault {
msgContext
.setProperty(MetricsConstants.REQUEST_RECEIVED_TIME, System.currentTimeMillis());
// global increment
((Counter) msgContext.getParameter(MetricsConstants.GLOBAL_REQUEST_COUNTER).getValue())
.increment();
return InvocationResponse.CONTINUE;
}
}
代码示例来源:origin: org.apache.sandesha2/sandesha2-core
private void makeMessageReadyForReinjection(MessageContext messageContext) {
messageContext.setProperty(AddressingConstants.WS_ADDRESSING_VERSION, null);
messageContext.getOptions().setMessageId(null);
messageContext.getOptions().setTo(null);
messageContext.getOptions().setAction(null);
messageContext.setProperty(Sandesha2Constants.APPLICATION_PROCESSING_DONE, Sandesha2Constants.VALUE_TRUE);
}
代码示例来源:origin: org.apache.synapse/synapse-core
private static MessageContext cloneForSend(MessageContext ori, String preserveAddressing)
throws AxisFault {
MessageContext newMC = MessageHelper.clonePartially(ori);
newMC.setEnvelope(ori.getEnvelope());
if (preserveAddressing != null && Boolean.parseBoolean(preserveAddressing)) {
newMC.setMessageID(ori.getMessageID());
} else {
MessageHelper.removeAddressingHeaders(newMC);
}
newMC.setProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS,
ori.getProperty(org.apache.axis2.context.MessageContext.TRANSPORT_HEADERS));
return newMC;
}
代码示例来源:origin: wso2/wso2-synapse
private void sendResponseAndFinish(HttpResponse response, int status,
NHttpServerConnection conn, OutputStream os,
MessageContext msgContext) {
response.setStatusCode(status);
SourceContext.updateState(conn, ProtocolState.WSDL_RESPONSE_DONE);
sourceHandler.commitResponseHideExceptions(conn, response);
closeOutputStream(os);
msgContext.setProperty(GET_REQUEST_HANDLED, Boolean.TRUE);
}
内容来源于网络,如有侵权,请联系作者删除!