public McastMember(String name,
    String domain,
    String host,
    int port,
    long aliveTime) 
{
                                                
        this.host = host;
        this.port = port;
        this.name = name;
        this.domain = domain;
        this.memberAliveTime=aliveTime;
}

Construct a new member object

Parameters:

name - - the name of this member, cluster unique

domain - - the cluster domain name of this member

host - - the tcp listen host

port - - the tcp listen port

 public boolean equals(Object o) 
{
        if ( o instanceof McastMember )    {
            return this.name.equals(((McastMember)o).getName());
        }
        else
            return false;
}

Returns true if the param o is a McastMember with the same name

 protected byte[] getData(long startTime) throws Exception 
{
        //package looks like
        //alive - 8 bytes
        //port - 4 bytes
        //host - 4 bytes
        //nlen - 4 bytes
        //name - nlen bytes
        //dlen - 4 bytes
        //domain - dlen bytes
        byte[] named = getName().getBytes();
        byte[] domaind = getDomain().getBytes();
        byte[] addr = java.net.InetAddress.getByName(host).getAddress();
        byte[] data = new byte[8+4+addr.length+4+named.length+4+domaind.length];
        long alive=System.currentTimeMillis()-startTime;
        System.arraycopy(XByteBuffer.toBytes((long)alive),0,data,0,8);
        System.arraycopy(XByteBuffer.toBytes(port),0,data,8,4);
        System.arraycopy(addr,0,data,12,addr.length);
        System.arraycopy(XByteBuffer.toBytes(named.length),0,data,16,4);
        System.arraycopy(named,0,data,20,named.length);
        System.arraycopy(XByteBuffer.toBytes(domaind.length),0,data,named.length+20,4);
        System.arraycopy(domaind,0,data,named.length+24,domaind.length);
        return data;
}

Create a data package to send over the wire representing this member. This is faster than serialization.

 public String getDomain() 
{
        return domain;
}

Return the domain of this object

 public String getHost() 
{
        return this.host;
}

Return the TCP listen host for this member

 protected static McastMember getMember(byte[] data) 
{
       //package looks like
       //alive - 8 bytes
       //port - 4 bytes
       //host - 4 bytes
       //nlen - 4 bytes
       //name - nlen bytes
       //dlen - 4 bytes
       //domain - dlen bytes
       byte[] alived = new byte[8];
       System.arraycopy(data, 0, alived, 0, 8);
       byte[] portd = new byte[4];
       System.arraycopy(data, 8, portd, 0, 4);
       byte[] addr = new byte[4];
       System.arraycopy(data, 12, addr, 0, 4);
       //FIXME control the nlen
       byte[] nlend = new byte[4];
       System.arraycopy(data, 16, nlend, 0, 4);
       int nlen = XByteBuffer.toInt(nlend, 0);
       byte[] named = new byte[nlen];
       System.arraycopy(data, 20, named, 0, named.length);
       //FIXME control the dlen
       byte[] dlend = new byte[4];
       System.arraycopy(data, nlen + 20, dlend, 0, 4);
       int dlen = XByteBuffer.toInt(dlend, 0);
       byte[] domaind = new byte[dlen];
       System.arraycopy(data, nlen + 24, domaind, 0, domaind.length);
       return new McastMember(new String(named),
                              new String(domaind),
                              addressToString(addr),
                              XByteBuffer.toInt(portd, 0),
                              XByteBuffer.toLong(alived, 0));
}

Deserializes a member from data sent over the wire

 public long getMemberAliveTime() 
{
       return memberAliveTime;
}

Contains information on how long this member has been online. The result is the number of milli seconds this member has been broadcasting its membership to the cluster.

 public HashMap getMemberProperties() 
{
        java.util.HashMap map = new java.util.HashMap(2);
        map.put(McastMember.TCP_LISTEN_HOST,this.host);
        map.put(McastMember.TCP_LISTEN_PORT,String.valueOf(this.port));
        map.put(McastMember.MEMBER_NAME,name);
        map.put(McastMember.MEMBER_DOMAIN,domain);
        return map;
}

 public String getName() 
{
        return name;
}

Return the name of this object

 public int getPort() 
{
        return this.port;
}

Return the listen port of this member

 public int hashCode() 
{
        return this.name.hashCode();
}

 protected  void inc() 
{
        msgCount++;
}

Increment the message count.

 public  void setDomain(String domain) 
{
        this.domain = domain;
}

 public  void setHost(String host) 
{
        this.host = host;
}

 public  void setMemberAliveTime(long time) 
{
       memberAliveTime=time;
}

 public  void setMsgCount(int msgCount) 
{
        this.msgCount = msgCount;
}

 public  void setName(String name) 
{
        this.name = name;
}

 public  void setPort(int port) 
{
        this.port = port;
}

 public String toString() 
{
        return "org.apache.catalina.cluster.mcast.McastMember["+name+","+domain+","+host+","+port+", alive="+memberAliveTime+"]";
}

String representation of this object