Skip to content

Commit

Permalink
removed ConnectionTable listener
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Mar 23, 2005
1 parent 6071896 commit 0625e63
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions src/org/jgroups/protocols/TCP.java
@@ -1,4 +1,4 @@
// $Id: TCP.java,v 1.15 2005/03/17 18:33:45 belaban Exp $
// $Id: TCP.java,v 1.16 2005/03/23 11:02:08 belaban Exp $

package org.jgroups.protocols;

Expand Down Expand Up @@ -34,7 +34,7 @@
* registers with the connection table to receive all incoming messages.
* @author Bela Ban
*/
public class TCP extends Protocol implements ConnectionTable.Receiver, ConnectionTable.ConnectionListener {
public class TCP extends Protocol implements ConnectionTable.Receiver {
private ConnectionTable ct=null;
private Address local_addr=null;
private String group_addr=null;
Expand Down Expand Up @@ -88,7 +88,7 @@ public void startUpHandler() {

public void start() throws Exception {
ct=getConnectionTable(reaper_interval,conn_expire_time,bind_addr,external_addr,start_port,end_port);
ct.addConnectionListener(this);
// ct.addConnectionListener(this);
ct.setReceiveBufferSize(recv_buf_size);
ct.setSendBufferSize(send_buf_size);
local_addr=ct.getLocalAddress();
Expand Down Expand Up @@ -219,14 +219,14 @@ public void receive(Message msg) {


// ConnectionTable.ConnectionListener interface
public void connectionOpened(Address peer_addr) {
if(log.isTraceEnabled()) log.trace("opened connection to " + peer_addr);
}

public void connectionClosed(Address peer_addr) {
if(peer_addr != null)
if(log.isTraceEnabled()) log.trace("closed connection to " + peer_addr);
}
// public void connectionOpened(Address peer_addr) {
// if(log.isTraceEnabled()) log.trace("opened connection to " + peer_addr);
// }
//
// public void connectionClosed(Address peer_addr) {
// if(peer_addr != null)
// if(log.isTraceEnabled()) log.trace("closed connection to " + peer_addr);
// }


/** Setup the Protocol instance acording to the configuration string */
Expand Down

0 comments on commit 0625e63

Please sign in to comment.