scribeclienttest.java

p2p仿真器。开发者可以工作在覆盖层中进行创造和测试逻辑算法或者创建和测试新的服务。PlanetSim还可以将仿真代码平稳转换为在Internet上的实验代码

package planet.test.scribe;

import planet.commonapi.*;
import planet.scribe.*;

/**
 * @author Ruben Mondejar  <[e-mail]>
 */

public class ScribeClientTest implements ScribeClient {     

	//true if received a message 
	private boolean activated = false;	
	
	protected String id = null;
    /**
     * Whether or not this client should accept anycasts
     */
    protected boolean acceptAnycast = false;

    /**
     * Whether this client has had a subscribe fail
     */
    protected boolean subscribeFailed = false;

    /**
     * Constructor.
     */
    public ScribeClientTest(String id) {
      this.id = id;
    }

    public void acceptAnycast(boolean value) {
      this.acceptAnycast = value;
    }

    /**
     * DESCRIBE THE METHOD
     *
     * @param topic DESCRIBE THE PARAMETER
     * @param content DESCRIBE THE PARAMETER
     * @return DESCRIBE THE RETURN VALUE
     */
    public boolean anycast(Topic topic, ScribeContent content) {
      if (acceptAnycast)
      	System.out.println(content);

      return acceptAnycast;
    }

    /**
     * DESCRIBE THE METHOD
     *
     * @param topic DESCRIBE THE PARAMETER
     * @param content DESCRIBE THE PARAMETER
     */
    public void deliver(Topic topic, ScribeContent content) {
      System.out.println(id+" deliver -->"+content);
      activated=true;
    }

    /**
     * DESCRIBE THE METHOD
     *
     * @param topic DESCRIBE THE PARAMETER
     * @param child DESCRIBE THE PARAMETER
     */
    public void childAdded(Topic topic, NodeHandle child) {
      System.out.println("CHILD ADDED AT " +child.getId() +" --> "+id);
    }

    /**
     * DESCRIBE THE METHOD
     *
     * @param topic DESCRIBE THE PARAMETER
     * @param child DESCRIBE THE PARAMETER
     */
    public void childRemoved(Topic topic, NodeHandle child) {
      System.out.println("CHILD REMOVED AT " + id);
    }

    public void subscribeFailed(Topic topic) {
      System.out.println(id+" subscribe failed of " +topic);
      subscribeFailed = true;
    }

    public boolean getSubscribeFailed() {
      return subscribeFailed;
    }
    
    public boolean isActivated() {
      return activated;
    }
  }