com.cloudhopper.commons.util.windowing.WindowFuture.getRequest()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(167)

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

WindowFuture.getRequest介绍

[英]Gets the request contained in the window entry.
[中]获取窗口项中包含的请求。

代码示例

代码示例来源：origin: twitter-archive/cloudhopper-smpp

@Override
public PduRequest getRequest() {
  return future.getRequest();
}

代码示例来源：origin: com.fizzed/ch-smpp

@Override
public PduRequest getRequest() {
  return future.getRequest();
}

代码示例来源：origin: org.restcomm.smpp/ch-smpp

@Override
public PduRequest getRequest() {
  return future.getRequest();
}

代码示例来源：origin: com.cloudhopper/ch-smpp

@Override
public PduRequest getRequest() {
  return future.getRequest();
}

代码示例来源：origin: twitter-archive/cloudhopper-smpp

@Override
public void expired(WindowFuture<Integer, PduRequest, PduResponse> future) {
  this.countSendRequestPduExpired(future.getRequest());
  this.sessionHandler.firePduRequestExpired(future.getRequest());
}

代码示例来源：origin: com.cloudhopper/ch-smpp

@Override
public void expired(WindowFuture<Integer, PduRequest, PduResponse> future) {
  this.countSendRequestPduExpired(future.getRequest());
  this.sessionHandler.firePduRequestExpired(future.getRequest());
}

代码示例来源：origin: com.fizzed/ch-smpp

@Override
public void expired(WindowFuture<Integer, PduRequest, PduResponse> future) {
  this.countSendRequestPduExpired(future.getRequest());
  this.sessionHandler.firePduRequestExpired(future.getRequest());
}

代码示例来源：origin: org.restcomm.smpp/ch-smpp

@Override
public void expired(WindowFuture<Integer, PduRequest, PduResponse> future) {
  this.countSendRequestPduExpired(future.getRequest());
  if (this.sessionHandler != null) {
    this.sessionHandler.firePduRequestExpired(future.getRequest());
  }
}

代码示例来源：origin: com.cloudhopper/ch-smpp

@Override
public String[] dumpWindow() {
  Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  String[] dump = new String[sortedSnapshot.size()];
  int i = 0;
  for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
    dump[i] = future.getRequest().toString();
    i++;
  }
  return dump;
}

代码示例来源：origin: twitter-archive/cloudhopper-smpp

@Override
public String[] dumpWindow() {
  Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  String[] dump = new String[sortedSnapshot.size()];
  int i = 0;
  for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
    dump[i] = future.getRequest().toString();
    i++;
  }
  return dump;
}

代码示例来源：origin: com.fizzed/ch-smpp

@Override
public String[] dumpWindow() {
  Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  String[] dump = new String[sortedSnapshot.size()];
  int i = 0;
  for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
    dump[i] = future.getRequest().toString();
    i++;
  }
  return dump;
}

代码示例来源：origin: org.restcomm.smpp/ch-smpp

@Override
public String[] dumpWindow() {
  Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  String[] dump = new String[sortedSnapshot.size()];
  int i = 0;
  for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
    dump[i] = future.getRequest().toString();
    i++;
  }
  return dump;
}

代码示例来源：origin: wizardjedi/my-spring-learning

private static void log(WindowFuture<Integer, PduRequest, PduResponse> future) {
  SubmitSm req = (SubmitSm)future.getRequest();
  SubmitSmResp resp = (SubmitSmResp)future.getResponse();
  log.debug("Got response with MSG ID={} for APPID={}", resp.getMessageId(), req.getReferenceObject());
}

代码示例来源：origin: org.mobicents.smsc/smpp-server-ra-ra

@Override
public void fireChannelUnexpectedlyClosed() {
  tracer.severe(String
      .format("Rx : fireChannelUnexpectedlyClosed for SmppSessionImpl=%s Default handling is to discard an unexpected channel closed",
          this.esme.getName()));
  DefaultSmppSession defaultSession = esme.getSmppSession();
  // firing of onPduRequestTimeout() for sent messages for which we do not have responses
  Window<Integer, PduRequest, PduResponse> wind = defaultSession.getSendWindow();
  Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
  for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
    tracer.warning("Firing of onPduRequestTimeout from DefaultSmppServerHandler.sessionDestroyed(): "
        + future.getRequest().toString());
    defaultSession.expired(future);
  }
}

代码示例来源：origin: org.mobicents.smsc/smpp-server-ra-ra

@Override
public void fireUnknownThrowable(Throwable throwable) {
  DefaultSmppSession defaultSession = esme.getSmppSession();
  // firing of onPduRequestTimeout() for sent messages for which we do not have responses
  Window<Integer, PduRequest, PduResponse> wind = defaultSession.getSendWindow();
  Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
  for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
    tracer.warning("Firing of onPduRequestTimeout from DefaultSmppServerHandler.sessionDestroyed(): "
        + future.getRequest().toString());
    defaultSession.expired(future);
  }
  tracer.severe("Received fireUnknownThrowable", throwable);
  // TODO what here?
}

代码示例来源：origin: org.mobicents.smsc/smpp

protected void stopSmppClientSession(Esme esme) {
  DefaultSmppSession smppSession = esme.getSmppSession();
  if (smppSession != null) {
    if (smppSession.isBound()) {
      try {
        smppSession.unbind(5000);
      } catch (Exception e) {
        logger.error(String.format("Failed to unbind smpp client session for %s.",
            smppSession.getConfiguration().getName()));
      }
    }
    try {
      smppSession.close();
    } catch (Exception e) {
      logger.error(String.format("Failed to close smpp client session for %s.",
          smppSession.getConfiguration().getName()));
    }
    // firing of onPduRequestTimeout() for sent messages for which we do not have responses
    Window<Integer, PduRequest, PduResponse> wind = smppSession.getSendWindow();
    Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
    for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
      this.logger.warn("Firing of onPduRequestTimeout from SmppClientManagement.stopSmppClientSession() - 1: "
          + future.getRequest().toString());
      smppSession.expired(future);
    }
    smppSession.destroy();
  }
}

代码示例来源：origin: org.restcomm.smpp/smpp-extensions

protected void stopSmppClientSession(Esme esme) {
  DefaultSmppSession smppSession = esme.getSmppSession();
  if (smppSession != null) {
    if (smppSession.isBound()) {
      try {
        smppSession.unbind(5000);
      } catch (Exception e) {
        logger.error(String.format("Failed to unbind smpp client session for %s.",
            smppSession.getConfiguration().getName()));
      }
    }
    try {
      smppSession.close();
    } catch (Exception e) {
      logger.error(String.format("Failed to close smpp client session for %s.",
          smppSession.getConfiguration().getName()));
    }
    // firing of onPduRequestTimeout() for sent messages for which we do not have responses
    Window<Integer, PduRequest, PduResponse> wind = smppSession.getSendWindow();
    Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
    for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
      this.logger.warn("Firing of onPduRequestTimeout from SmppClientManagement.stopSmppClientSession() - 1: "
          + future.getRequest().toString());
      smppSession.expired(future);
    }
    smppSession.destroy();
  }
}

代码示例来源：origin: org.restcomm.smpp/ch-smpp

logger.trace("Caller waiting for request: {}", future.getRequest()); 
logger.trace("Caller not waiting for request: {}", future.getRequest()); 
logger.trace("Caller timed out waiting for request: {}", future.getRequest());

代码示例来源：origin: org.mobicents.smsc/smpp

public void sessionDestroyed(SmppSession session) {
  synchronized (this) {
    if (logger.isInfoEnabled()) {
      logger.info(String.format("Session destroyed: %s", session.getConfiguration().getSystemId()));
    }
    // print out final stats
    if (session.hasCounters()) {
      logger.info(String.format("final session rx-submitSM: %s", session.getCounters().getRxSubmitSM()));
    }
    // remove esmeServer out of enquire list
    String esmeName = session.getConfiguration().getName();
    Esme esmeServer = this.esmeManagement.getEsmeByName(esmeName);
    esmeServer.setServerBound(false);
    esmeServer.resetEnquireLinkFail();
    this.smppServerOpsThread.removeEnquireList(esmeName);
    DefaultSmppSession defaultSession = (DefaultSmppSession) session;
    // firing of onPduRequestTimeout() for sent messages for which we do not have responses
    Window<Integer, PduRequest, PduResponse> wind = defaultSession.getSendWindow();
    Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
    for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
      this.logger.warn("Firing of onPduRequestTimeout from DefaultSmppServerHandler.sessionDestroyed(): "
          + future.getRequest().toString());
      defaultSession.expired(future);
    }
    // make sure it's really shutdown
    session.destroy();
  }
}

代码示例来源：origin: org.restcomm.smpp/smpp-extensions

for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
  this.logger.warn("Firing of onPduRequestTimeout from DefaultSmppServerHandler.sessionDestroyed(): "
      + future.getRequest().toString());
  defaultSession.expired(future);

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

WindowFuture

相关文章

    查看更多

    热门标签

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

    最新文章

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