public SocketHubAppender() 
{

}

 public SocketHubAppender(int _port) 
{
    port = _port;
    startServer();
}

Connects to remote server at address and port.

 public  void activateOptions() 
{
    startServer();
}

Set up the socket server on the specified port.

 public  void append(LoggingEvent event) 
{
	// if no event or no open connections, exit now
    if(event == null || oosList.size() == 0)
      return;
    // set up location info if requested
    if (locationInfo) {
    	event.getLocationInformation();	
    } 
	// loop through the current set of open connections, appending the event to each
    for (int streamCount = 0; streamCount <  oosList.size(); streamCount++) {    	
      ObjectOutputStream oos = null;
      try {
        oos = (ObjectOutputStream)oosList.elementAt(streamCount);
      }
      catch (ArrayIndexOutOfBoundsException e) {
        // catch this, but just don't assign a value
        // this should not really occur as this method is
        // the only one that can remove oos's (besides cleanUp).
      }
      // list size changed unexpectedly? Just exit the append.
      if (oos == null)
        break;
      try {
      	oos.writeObject(event);
      	oos.flush();
    	// Failing to reset the object output stream every now and
    	// then creates a serious memory leak.
    	// right now we always reset. TODO - set up frequency counter per oos?
    	oos.reset();
      }
      catch(IOException e) {
      	// there was an io exception so just drop the connection
      	oosList.removeElementAt(streamCount);
      	LogLog.debug("dropped connection");
      	// decrement to keep the counter in place (for loop always increments)
      	streamCount--;
      }
    }
}

Append an event to all of current connections.

 public  void cleanUp() 
{
    // stop the monitor thread
	LogLog.debug("stopping ServerSocket");
    serverMonitor.stopMonitor();
    serverMonitor = null;
    // close all of the connections
	LogLog.debug("closing client connections");
    while (oosList.size() != 0) {
      ObjectOutputStream oos = (ObjectOutputStream)oosList.elementAt(0);
      if(oos != null) {
        try {
        	oos.close();
        }
        catch(IOException e) {
        	LogLog.error("could not close oos.", e);
        }
        oosList.removeElementAt(0);     
      }
    }
}

Release the underlying ServerMonitor thread, and drop the connections to all connected remote servers.

 public synchronized  void close() 
{
    if(closed)
      return;
	LogLog.debug("closing SocketHubAppender " + getName());
    this.closed = true;
    cleanUp();
	LogLog.debug("SocketHubAppender " + getName() + " closed");
}

Close this appender.

This will mark the appender as closed and call then #cleanUp method.

 public boolean getLocationInfo() 
{
    return locationInfo;
}

Returns value of the LocationInfo option.

 public int getPort() 
{
    return port;
}

Returns value of the Port option.

 public boolean requiresLayout() 
{
    return false;
}

The SocketHubAppender does not use a layout. Hence, this method returns false.

 public  void setLocationInfo(boolean _locationInfo) 
{
    locationInfo = _locationInfo;
}

The LocationInfo option takes a boolean value. If true, the information sent to the remote host will include location information. By default no location information is sent to the server.

 public  void setPort(int _port) 
{
    port = _port;
}

The Port option takes a positive integer representing the port where the server is waiting for connections.