org.apache.synapse.MessageContext.getMessageID()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(125)

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

MessageContext.getMessageID介绍

[英]Get the message id if available
[中]获取消息id（如果可用）

代码示例

代码示例来源：origin: wso2/wso2-synapse

/**
 * {@inheritDoc}
 */
public String getMessageID() {
  return mc.getMessageID();
}

代码示例来源：origin: wso2/wso2-synapse

/**
 * {@inheritDoc}
 */
public String getMessageID() {
  return mc.getMessageID();
}

代码示例来源：origin: org.apache.synapse/synapse-extensions

public String getMessageID() {
  return mc.getMessageID();
}

代码示例来源：origin: wso2/wso2-synapse

public MessageContext get(String messageId) {
  MessageContext message = null;
  synchronized (queueLock) {
    for (MessageContext m : queue) {
      if (m.getMessageID().equals(messageId)) {
        message = m;
        break;
      }
    }
  }
  return message;
}

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

public MessageContext get(String messageId) {
  lock.lock();
  try {
    if (messageId != null) {
      for (MessageContext msgCtx : messageList) {
        if (msgCtx.getMessageID().equals(messageId)) {
          return msgCtx;
        }
      }
    }
  } finally {
    lock.unlock();
  }
  return null;
}

代码示例来源：origin: org.wso2.ei/org.wso2.ei.samples

public boolean mediate(MessageContext synCtx) {

    log.info("Starting Spring Meditor");
    log.info("Bean in Initialized with User:["+userName+"]");
    log.info("E-MAIL:["+email+"]");
    log.info("Massage Id:  "+synCtx.getMessageID());
    log.info("Logged....");
    return true;
  }
}

代码示例来源：origin: wso2/wso2-synapse

public boolean mediate(MessageContext synCtx) {

    log.info("Starting Spring Meditor");
    log.info("Bean in Initialized with User:["+userName+"]");
    log.info("E-MAIL:["+email+"]");
    log.info("Massage Id:  "+synCtx.getMessageID());
    log.info("Logged....");
    return true;
  }
}

代码示例来源：origin: wso2/wso2-synapse

/**
 * Set message Id of the message context as statistic trace Id at the beginning of the statistic flow.
 *
 * @param msgCtx synapse message context.
 */
protected static void setStatisticsTraceId(MessageContext msgCtx) {
  if (msgCtx.getProperty(StatisticsConstants.FLOW_STATISTICS_ID) == null && msgCtx.getMessageID() != null) {
    msgCtx.setProperty(StatisticsConstants.FLOW_STATISTICS_ID, msgCtx.getMessageID().replace(':', '_'));
  } else if (msgCtx.getMessageID() == null) {
    log.error("Message ID is null");
  }
}

代码示例来源：origin: org.apache.synapse/synapse-samples

public boolean mediate(MessageContext synCtx) {

    log.info("Starting Spring Meditor");
    log.info("Bean in Initialized with User:["+userName+"]");
    log.info("E-MAIL:["+email+"]");
    log.info("Massage Id:  "+synCtx.getMessageID());
    log.info("Logged....");
    return true;
  }
}

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

public MessageContext remove() throws NoSuchElementException {
  lock.lock();
  try {
    MessageContext msgCtx = messageList.remove();
    if (msgCtx != null) {
      notifyMessageRemoval(msgCtx.getMessageID());
    }
    return msgCtx;
  } finally {
    lock.unlock();
  }
}

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

public List<String> getMessageIds() {
  List<String> returnList = new ArrayList<String>();
  List<MessageContext> list = messageStore.getAll();
  for(MessageContext m : list) {
    returnList.add(m.getMessageID());
  }
  return returnList;
}

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

public MessageContext poll() {
  lock.lock();
  try {
    MessageContext context = messageList.poll();
    if (context != null) {
      // notify observers
      notifyMessageRemoval(context.getMessageID());
    }
    return context;
  } finally {
    lock.unlock();
  }
}

代码示例来源：origin: wso2/wso2-synapse

public MessageContext receive() {
  MessageContext message;
  synchronized (queueLock) {
    message = queue.peek();
    if (logger.isDebugEnabled()) {
      if (message != null) {
        logger.debug(getId() + " received MessageID : " + message.getMessageID());
      }
    }
    lastMessage = message;
  }
  return message;
}

代码示例来源：origin: wso2/wso2-synapse

/**
 * Extracts the sequence id from the message context.
 *
 * @param message the message context.
 * @return sequence id of the message.
 */
private Long getMessageSequenceId(MessageContext message) throws StoreException {
  String sequenceIdValue;
  sequenceIdValue = xPath.stringValueOf(message);
  if (log.isDebugEnabled()) {
    log.debug("Sequence id extracted from the incoming message " + message.getMessageID() + " is:"
        + sequenceIdValue);
  }
  return Long.parseLong(sequenceIdValue);
}

代码示例来源：origin: wso2/wso2-synapse

public MessageContext remove() throws NoSuchElementException {
  MessageContext message;
  synchronized (queueLock) {
    message = queue.remove();
  }
  if (message != null) {
    dequeued();
    if (logger.isDebugEnabled()) {
      logger.debug(nameString() + " removed MessageID:" + message.getMessageID() + " => true");
    }
  }
  return message;
}

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

public boolean offer(MessageContext messageContext) {
  lock.lock();
  try {
    if (messageContext != null) {
      messageContext.getEnvelope().build();
      messageList.offer(messageContext);
      // Notify observers
      notifyMessageAddition(messageContext.getMessageID());
      if (log.isDebugEnabled()) {
        log.debug("Message with id " + messageContext.getMessageID() + " stored");
      }
    }
  } finally {
    lock.unlock();
  }
  return true;
}

代码示例来源：origin: org.wso2.carbon.appmgt/org.wso2.carbon.appmgt.gateway

public static void logWithRequestInfo(Log log, MessageContext messageContext, String message) {
  Session session = getSession(messageContext);
  String hashedSessionID = null;
  if(session != null){
    hashedSessionID = getMD5Hash(session.getUuid());
  }
  org.apache.axis2.context.MessageContext axis2MessageContext = ((Axis2MessageContext) messageContext).getAxis2MessageContext();
  String fullResourceURL = (String) messageContext.getProperty(RESTConstants.REST_FULL_REQUEST_PATH);
  String httpVerb =   (String) axis2MessageContext.getProperty(Constants.Configuration.HTTP_METHOD);
  String requestInfo = String.format("{%s;%s;%s;%s}", hashedSessionID, messageContext.getMessageID(), httpVerb, fullResourceURL);
  log.debug(String.format("%s - %s", requestInfo, message));
}

代码示例来源：origin: wso2/wso2-synapse

/**
 * Related to advertising the point where mediation flow starts.
 *
 * @param synCtx message context
 */
public void advertiseMediationFlowStartPoint(MessageContext synCtx) {
  if (synEnv.isDebuggerEnabled()) {
    setMessageContext(synCtx);
    this.advertiseDebugEvent(this.createDebugEvent(SynapseDebugEventConstants.DEBUG_EVENT_STARTED).toString());
    if (log.isDebugEnabled()) {
      log.debug("Mediation flow started for id " + synCtx.getMessageID());
    }
  }
}

代码示例来源：origin: wso2/wso2-synapse

public void testOrderedDelivery2() throws  Exception {
  System.out.println("Testing InMemoryStore Guaranteed Delivery...");
  MessageStore store = new InMemoryStore();
  store.getProducer().storeMessage(createMessageContext("FOO"));
  MessageConsumer consumer = store.getConsumer();
  MessageContext msg = consumer.receive();
  assertEquals("FOO", msg.getMessageID());
  store.getProducer().storeMessage(createMessageContext("BAR"));
  msg = consumer.receive();
  assertEquals("FOO", msg.getMessageID());
  consumer.ack();
  msg = consumer.receive();
  assertEquals("BAR", msg.getMessageID());
}

代码示例来源：origin: wso2/wso2-synapse

public void testOrderedDelivery1() throws Exception {
  System.out.println("Testing InMemoryStore Ordered Delivery...");
  MessageStore store = new InMemoryStore();
  for (int i = 0; i < 100; i++) {
    store.getProducer().storeMessage(createMessageContext("ID" + i));
  }
  MessageConsumer consumer = store.getConsumer();
  for (int i = 0; i < 100; i++) {
    assertEquals("ID" + i, consumer.receive().getMessageID());
    consumer.ack();
  }
}

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

MessageContext

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    MessageContext类方法

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