org.apache.axis2.context.MessageContext.setProperty()方法的使用及代码示例

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

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

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);
}

相关文章

微信公众号

最新文章

更多

MessageContext类方法