Examples of ClusterListReply

org.objectweb.joram.shared.admin.ClusterListReply
A ClusterListReply instance holds the identifiers of a cluster's destinations.

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

   * @exception ConnectException  If the admin connection is closed or broken.
   * @exception AdminException  If the request fails.
   */
  public List getClusterFellows() throws ConnectException, AdminException {
    ClusterList request = new ClusterList(agentId);
    ClusterListReply reply = (ClusterListReply) doRequest(request);


    List topics = reply.getDestinations();
    List list = new ArrayList();
    if (topics != null) {
      for (int i = 0; i < topics.size(); i++)
        list.add(new Topic((String) topics.get(i)));
    }

View Full Code Here

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

    } else if (adminRequest instanceof GetFatherRequest) {
      replyToTopic(new GetFatherReply((fatherId != null)?fatherId.toString():null),
                   not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());
    } else if (adminRequest instanceof ClusterList) {
      List clstr = clusterList();
      replyToTopic(new ClusterListReply(clstr), not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());
    } else if (adminRequest instanceof ClusterAdd) {
      clusterAdd(not, ((ClusterAdd) adminRequest).getAddedDest());
    } else if (adminRequest instanceof ClusterLeave) {
      clusterLeave();
      replyToTopic(new AdminReply(true, null), not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());

View Full Code Here

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

    String info = strbuf.append("Request [").append(not.getClass().getName())
        .append("], sent to Destination [").append(getId()).append("], successful [true] ").toString();


    if (adminRequest instanceof ClusterList) {
      List list = clusterList();
      replyToTopic(new ClusterListReply(list), not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());
    } else if (adminRequest instanceof ClusterAdd) {
      clusterAdd(not, ((ClusterAdd) adminRequest).getAddedDest());
    } else if (adminRequest instanceof ClusterLeave) {
      clusterLeave();
      replyToTopic(new AdminReply(true, info), not.getReplyTo(), not.getRequestMsgId(), not.getReplyMsgId());

View Full Code Here

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

   *
   * @exception ConnectException  If the admin connection is closed or broken.
   * @exception AdminException  If the request fails.
   */
  public String[] getQueueClusterElements() throws ConnectException, AdminException {
    ClusterListReply reply = (ClusterListReply) doRequest(new ClusterList(agentId));
    List list = reply.getDestinations();
    return list == null ? null : (String[]) list.toArray(new String[list.size()]);
  }

View Full Code Here

TOP

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.