Package org.objectweb.joram.shared.admin

Examples of org.objectweb.joram.shared.admin.GetNbMaxMsgRequest

506
507
508
509
510
511
512
513
514
   * @exception ConnectException  If the admin connection is closed or broken.
   * @exception AdminException  If the request fails.
   */
  public int getNbMaxMsg(String subName) throws ConnectException, AdminException {
    //  TODO: Subscription sub = getSubscription(subName);
    GetNbMaxMsgRequest request = new GetNbMaxMsgRequest(proxyId, subName);
    GetNumberReply reply = (GetNumberReply) doRequest(request);
    return reply.getNumber();
  }
View Full Code Here
2684
2685
2686
2687
2688
2689
2690
2691
2692
2693
2694
2695
2696
    } else if (adminRequest instanceof GetSubscription) {
      doReact((GetSubscription) adminRequest, not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());
    } else if (adminRequest instanceof ClearSubscription) {
      doReact((ClearSubscription) adminRequest, not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());
    } else if (adminRequest instanceof GetNbMaxMsgRequest) {
      GetNbMaxMsgRequest request = (GetNbMaxMsgRequest) adminRequest;
      int nbMaxMsg = -1;
      ClientSubscription sub = (ClientSubscription) subsTable.get(request.getSubName());
      if (sub != null)
        nbMaxMsg = sub.getNbMaxMsg();

      replyToTopic(new GetNumberReply(nbMaxMsg), not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());
    } else if (adminRequest instanceof GetDMQSettingsRequest) {
View Full Code Here
303
304
305
306
307
308
309
310
311
   *
   * @exception ConnectException  If the admin connection is closed or broken.
   * @exception AdminException  If the request fails.
   */
  public int getNbMaxMsg()  throws ConnectException, AdminException {
    GetNbMaxMsgRequest request = new GetNbMaxMsgRequest(agentId);
    GetNumberReply reply = (GetNumberReply) doRequest(request);
    return reply.getNumber();
  }
View Full Code Here
TOP

Related Classes of org.objectweb.joram.shared.admin.GetNbMaxMsgRequest

  • org.objectweb.joram.client.jms.admin.User
  • org.objectweb.joram.client.jms.Queue
  • org.objectweb.joram.mom.proxies.UserAgent
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.