okuyama.imdst.util.io
クラス KeyNodeConnector

java.lang.Object
  上位を拡張 okuyama.imdst.util.io.KeyNodeConnector

public class KeyNodeConnector
extends java.lang.Object

MasterNodeが利用するDataNodeとの接続コネクター.

作成者:
T.Okuyama

コンストラクタの概要
KeyNodeConnector(java.lang.String nodeName, int nodePort, java.lang.String nodeFullName)
           
 
メソッドの概要
 void close()
           
 void connect()
          Connect処理.
 void connect(int connectOpenTime)
          Connect処理.
 java.lang.String connectorDump()
           
 void flush()
           
 java.lang.Long getConnetTime()
           
 java.lang.String getNodeFullName()
           
 java.lang.String getNodeName()
           
 int getNodePort()
           
 boolean getPoolConnectStatus()
           
 int getUseCount()
           
 void initRetryFlg()
           
 void print(java.lang.String str)
           
 void println(java.lang.String str)
           
 java.lang.String readLine()
           
 java.lang.String readLine(java.lang.String retryStr)
           
 java.lang.String readLineWithReady()
           
 java.lang.String readLineWithReady(java.lang.String retryStr)
           
 void setPoolConnectStatus(boolean status)
           
static void setRecoverMode(boolean mode, java.lang.String target)
           
 void setRetryConnectMode(boolean mode)
           
 void setSoTimeout(int time)
           
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

コンストラクタの詳細

KeyNodeConnector

public KeyNodeConnector(java.lang.String nodeName,
                        int nodePort,
                        java.lang.String nodeFullName)
                 throws java.lang.Exception
例外:
java.lang.Exception
メソッドの詳細

setRecoverMode

public static void setRecoverMode(boolean mode,
                                  java.lang.String target)

connect

public void connect()
             throws java.lang.Exception
Connect処理.
throws Exception

例外:
java.lang.Exception

connect

public void connect(int connectOpenTime)
             throws java.lang.Exception
Connect処理.

パラメータ:
connectOpenTime - throws Exception
例外:
java.lang.Exception

readLine

public java.lang.String readLine()
                          throws java.lang.Exception
例外:
java.lang.Exception

readLineWithReady

public java.lang.String readLineWithReady()
                                   throws java.lang.Exception
例外:
java.lang.Exception

readLine

public java.lang.String readLine(java.lang.String retryStr)
                          throws java.lang.Exception
例外:
java.lang.Exception

readLineWithReady

public java.lang.String readLineWithReady(java.lang.String retryStr)
                                   throws java.lang.Exception
例外:
java.lang.Exception

print

public void print(java.lang.String str)
           throws java.lang.Exception
例外:
java.lang.Exception

println

public void println(java.lang.String str)
             throws java.lang.Exception
例外:
java.lang.Exception

flush

public void flush()
           throws java.lang.Exception
例外:
java.lang.Exception

setSoTimeout

public void setSoTimeout(int time)
                  throws java.lang.Exception
例外:
java.lang.Exception

getConnetTime

public java.lang.Long getConnetTime()

setPoolConnectStatus

public void setPoolConnectStatus(boolean status)

getPoolConnectStatus

public boolean getPoolConnectStatus()

initRetryFlg

public void initRetryFlg()

setRetryConnectMode

public void setRetryConnectMode(boolean mode)

getNodeFullName

public java.lang.String getNodeFullName()

getNodeName

public java.lang.String getNodeName()

getNodePort

public int getNodePort()

close

public void close()

getUseCount

public int getUseCount()

connectorDump

public java.lang.String connectorDump()