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

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

本文整理了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

  1. @Override
  2. public PduRequest getRequest() {
  3.   return future.getRequest();
  4. }

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

  1. @Override
  2. public PduRequest getRequest() {
  3.   return future.getRequest();
  4. }

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

  1. @Override
  2. public PduRequest getRequest() {
  3.   return future.getRequest();
  4. }

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

  1. @Override
  2. public PduRequest getRequest() {
  3.   return future.getRequest();
  4. }

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

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

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

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

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

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

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

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

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

  1. @Override
  2. public String[] dumpWindow() {
  3.   Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  4.   String[] dump = new String[sortedSnapshot.size()];
  5.   int i = 0;
  6.   for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
  7.     dump[i] = future.getRequest().toString();
  8.     i++;
  9.   }
  10.   return dump;
  11. }

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

  1. @Override
  2. public String[] dumpWindow() {
  3.   Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  4.   String[] dump = new String[sortedSnapshot.size()];
  5.   int i = 0;
  6.   for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
  7.     dump[i] = future.getRequest().toString();
  8.     i++;
  9.   }
  10.   return dump;
  11. }

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

  1. @Override
  2. public String[] dumpWindow() {
  3.   Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  4.   String[] dump = new String[sortedSnapshot.size()];
  5.   int i = 0;
  6.   for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
  7.     dump[i] = future.getRequest().toString();
  8.     i++;
  9.   }
  10.   return dump;
  11. }

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

  1. @Override
  2. public String[] dumpWindow() {
  3.   Map<Integer,WindowFuture<Integer,PduRequest,PduResponse>> sortedSnapshot = this.sendWindow.createSortedSnapshot();
  4.   String[] dump = new String[sortedSnapshot.size()];
  5.   int i = 0;
  6.   for (WindowFuture<Integer,PduRequest,PduResponse> future : sortedSnapshot.values()) {
  7.     dump[i] = future.getRequest().toString();
  8.     i++;
  9.   }
  10.   return dump;
  11. }

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

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

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

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

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

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

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

  1. protected void stopSmppClientSession(Esme esme) {
  2.   DefaultSmppSession smppSession = esme.getSmppSession();
  3.   if (smppSession != null) {
  4.     if (smppSession.isBound()) {
  5.       try {
  6.         smppSession.unbind(5000);
  7.       } catch (Exception e) {
  8.         logger.error(String.format("Failed to unbind smpp client session for %s.",
  9.             smppSession.getConfiguration().getName()));
  10.       }
  11.     }
  12.     try {
  13.       smppSession.close();
  14.     } catch (Exception e) {
  15.       logger.error(String.format("Failed to close smpp client session for %s.",
  16.           smppSession.getConfiguration().getName()));
  17.     }
  18.     // firing of onPduRequestTimeout() for sent messages for which we do not have responses
  19.     Window<Integer, PduRequest, PduResponse> wind = smppSession.getSendWindow();
  20.     Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
  21.     for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
  22.       this.logger.warn("Firing of onPduRequestTimeout from SmppClientManagement.stopSmppClientSession() - 1: "
  23.           + future.getRequest().toString());
  24.       smppSession.expired(future);
  25.     }
  26.     smppSession.destroy();
  27.   }
  28. }

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

  1. protected void stopSmppClientSession(Esme esme) {
  2.   DefaultSmppSession smppSession = esme.getSmppSession();
  3.   if (smppSession != null) {
  4.     if (smppSession.isBound()) {
  5.       try {
  6.         smppSession.unbind(5000);
  7.       } catch (Exception e) {
  8.         logger.error(String.format("Failed to unbind smpp client session for %s.",
  9.             smppSession.getConfiguration().getName()));
  10.       }
  11.     }
  12.     try {
  13.       smppSession.close();
  14.     } catch (Exception e) {
  15.       logger.error(String.format("Failed to close smpp client session for %s.",
  16.           smppSession.getConfiguration().getName()));
  17.     }
  18.     // firing of onPduRequestTimeout() for sent messages for which we do not have responses
  19.     Window<Integer, PduRequest, PduResponse> wind = smppSession.getSendWindow();
  20.     Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
  21.     for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
  22.       this.logger.warn("Firing of onPduRequestTimeout from SmppClientManagement.stopSmppClientSession() - 1: "
  23.           + future.getRequest().toString());
  24.       smppSession.expired(future);
  25.     }
  26.     smppSession.destroy();
  27.   }
  28. }

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

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

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

  1. public void sessionDestroyed(SmppSession session) {
  2.   synchronized (this) {
  3.     if (logger.isInfoEnabled()) {
  4.       logger.info(String.format("Session destroyed: %s", session.getConfiguration().getSystemId()));
  5.     }
  6.     // print out final stats
  7.     if (session.hasCounters()) {
  8.       logger.info(String.format("final session rx-submitSM: %s", session.getCounters().getRxSubmitSM()));
  9.     }
  10.     // remove esmeServer out of enquire list
  11.     String esmeName = session.getConfiguration().getName();
  12.     Esme esmeServer = this.esmeManagement.getEsmeByName(esmeName);
  13.     esmeServer.setServerBound(false);
  14.     esmeServer.resetEnquireLinkFail();
  15.     this.smppServerOpsThread.removeEnquireList(esmeName);
  16.     DefaultSmppSession defaultSession = (DefaultSmppSession) session;
  17.     // firing of onPduRequestTimeout() for sent messages for which we do not have responses
  18.     Window<Integer, PduRequest, PduResponse> wind = defaultSession.getSendWindow();
  19.     Map<Integer, WindowFuture<Integer, PduRequest, PduResponse>> futures = wind.createSortedSnapshot();
  20.     for (WindowFuture<Integer, PduRequest, PduResponse> future : futures.values()) {
  21.       this.logger.warn("Firing of onPduRequestTimeout from DefaultSmppServerHandler.sessionDestroyed(): "
  22.           + future.getRequest().toString());
  23.       defaultSession.expired(future);
  24.     }
  25.     // make sure it's really shutdown
  26.     session.destroy();
  27.   }
  28. }

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

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

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

WindowFuture

相关文章

    查看更多

    热门标签

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

    最新文章

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