public class SocketRepository extends Object
| Constructor and Description | 
|---|
SocketRepository(org.pentaho.di.core.logging.LogChannelInterface log)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
closeAll()
Closes all sockets on application end... 
 | 
Map<Integer,SocketRepositoryEntry> | 
getSocketMap()  | 
ServerSocket | 
openServerSocket(int port,
                String user)  | 
void | 
releaseSocket(int port)
We don't actually ever close a server socket, we re-use them as much as possible. 
 | 
void | 
setSocketMap(Map<Integer,SocketRepositoryEntry> socketMap)  | 
public SocketRepository(org.pentaho.di.core.logging.LogChannelInterface log)
public ServerSocket openServerSocket(int port, String user) throws IOException
IOExceptionpublic void releaseSocket(int port)
                   throws IOException
port - IOExceptionpublic Map<Integer,SocketRepositoryEntry> getSocketMap()
public void setSocketMap(Map<Integer,SocketRepositoryEntry> socketMap)
socketMap - the socketMap to setpublic void closeAll()
IOException - in case there is an error