import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * Create a new mcast service impl
 * @param member - the local member
 * @param sendFrequency - the time (ms) in between pings sent out
 * @param expireTime - the time (ms) for a member to expire
 * @param port - the mcast port
 * @param bind - the bind address (not sure this is used yet)
 * @param mcastAddress - the mcast address
 * @param service - the callback service
 * @param localLoopbackDisabled - disable loopbackMode
 * @throws IOException
 */
public McastServiceImpl(
    MemberImpl member,
    long sendFrequency,
    long expireTime,
    int port,
    InetAddress bind,
    InetAddress mcastAddress,
    int ttl,
    int soTimeout,
    MembershipListener service,
    MessageListener msgservice,
    boolean localLoopbackDisabled)
throws IOException {
    this.member = member;
    this.address = mcastAddress;
    this.port = port;
    this.mcastSoTimeout = soTimeout;
    this.mcastTTL = ttl;
    this.mcastBindAddress = bind;
    this.timeToExpiration = expireTime;
    this.service = service;
    this.msgservice = msgservice;
    this.sendFrequency = sendFrequency;
    this.localLoopbackDisabled = localLoopbackDisabled;
    init();
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
public MessageListener getListener() {
    return listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
public void setListener(MessageListener listener) {
    this.listener = listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
public void setMessageListener(MessageListener listener) {
    this.msglistener = listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
public MessageListener getListener() {
	return listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
public void setListener(MessageListener listener) {
	this.listener = listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * Create a new mcast service impl
 * 
 * @param member
 *            - the local member
 * @param sendFrequency
 *            - the time (ms) in between pings sent out
 * @param expireTime
 *            - the time (ms) for a member to expire
 * @param port
 *            - the mcast port
 * @param bind
 *            - the bind address (not sure this is used yet)
 * @param mcastAddress
 *            - the mcast address
 * @param service
 *            - the callback service
 * @param localLoopbackDisabled
 *            - disable loopbackMode
 * @throws IOException
 */
public McastServiceImpl(MemberImpl member, long sendFrequency, long expireTime, int port, InetAddress bind,
		InetAddress mcastAddress, int ttl, int soTimeout, MembershipListener service, MessageListener msgservice,
		boolean localLoopbackDisabled) throws IOException {
	this.member = member;
	this.address = mcastAddress;
	this.port = port;
	this.mcastSoTimeout = soTimeout;
	this.mcastTTL = ttl;
	this.mcastBindAddress = bind;
	this.timeToExpiration = expireTime;
	this.service = service;
	this.msgservice = msgservice;
	this.sendFrequency = sendFrequency;
	this.localLoopbackDisabled = localLoopbackDisabled;
	init();
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
public void setMessageListener(MessageListener listener) {
	this.msglistener = listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * getMessageListener
 *
 * @return MessageListener
 */
@Override
public MessageListener getMessageListener() {
    return listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * setMessageListener
 *
 * @param listener MessageListener
 */
@Override
public void setMessageListener(MessageListener listener) {
    this.listener = listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * getMessageListener
 *
 * @return MessageListener
 */
@Override
public MessageListener getMessageListener() {
	return listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * setMessageListener
 *
 * @param listener
 *            MessageListener
 */
@Override
public void setMessageListener(MessageListener listener) {
	this.listener = listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * getMessageListener
 *
 * @return MessageListener
 * TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
 */
@Override
public MessageListener getMessageListener() {
    return listener;
}
 

import org.apache.catalina.tribes.MessageListener; //导入依赖的package包/类
/**
 * setMessageListener
 *
 * @param listener MessageListener
 * TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
 */
@Override
public void setMessageListener(MessageListener listener) {
    this.listener = listener;
}