public void setTxBufSize(int size);
public void setMaxRetryAttempts(int attempts);
public void setDirectBuffer(boolean directBuf);
- public void memberAdded(Member member);
- public void memberDisappeared(Member member);
+ public void add(Member member);
+ public void remove(Member member);
}
* @see org.apache.catalina.tribes.ClusterSender#add(org.apache.catalina.tribes.Member)
*/
public synchronized void add(Member member) {
- getTransport().memberAdded(member);
+ getTransport().add(member);
}
/**
* @see org.apache.catalina.tribes.ClusterSender#remove(org.apache.catalina.tribes.Member)
*/
public synchronized void remove(Member member) {
- getTransport().memberDisappeared(member);
+ getTransport().remove(member);
}
// ------------------------------------------------------------- protected
if ( x != null ) throw x;
}
- public void memberAdded(Member member) {
+ public void add(Member member) {
}
- public void memberDisappeared(Member member) {
+ public void remove(Member member) {
//disconnect senders
BioSender sender = (BioSender)bioSenders.remove(member);
if ( sender != null ) sender.disconnect();
}
- public void memberAdded(Member member) {
+ public void add(Member member) {
}
- public void memberDisappeared(Member member) {
+ public void remove(Member member) {
//disconnect senders
}
if ( x != null ) throw x;
}
- public void memberAdded(Member member) {
+ public void add(Member member) {
}
- public void memberDisappeared(Member member) {
+ public void remove(Member member) {
//disconnect senders
NioSender sender = (NioSender)nioSenders.remove(member);
if ( sender != null ) sender.disconnect();
super.connect();
}
- public void memberAdded(Member member) {
+ public void add(Member member) {
}
- public void memberDisappeared(Member member) {
+ public void remove(Member member) {
//disconnect senders
}
}
\ No newline at end of file