com.gauce.io.CommonResponse
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Object
GauceResponse중 BinResponse와 CSVResponse에서 공통적으로 사용되는 method들을 모아둔 클래스 이다.
| Constructor Summary | |
CommonResponse()
|
|
| Method Summary | |
void |
bufferFilled(BufferFilledEvent bufferFilledEvent)
GauceDataSet의 지정된 버퍼만큼 GauceRecord가 찼을때 자동으로 이 mehtod가 Callback 받는다 이 이벤트를 받아 생성된 GauceDataSet을 Component로 전송한다. |
void |
close()
Component와의 통신을 끊는다. |
void |
commit()
Component에게 Transaction을 끝마친 결과를 전송한다. |
void |
commit(java.lang.String msg)
Component에게 Transaction을 끝마친 결과를 전송한다. commit() method와 기능은 동일하며 지정된 메세지를 Component로 같이 전송한다. |
void |
enableFirstRow(GauceDataSet dataSet)
GauceDataSet을 first-row가 지원되는 GauceDataSet으로 서비스하기 위해 등록시킨다. |
void |
flush()
Buffer에 남은 Packet을 Component로 전송하고 Buffer를 비운다. |
com.gauce.common.crypto.GauceProvider |
getGauceProvider()
데이터 패킷의 암호화와 관련된 정보를 반환한다. |
java.lang.String |
getMethod()
컴포넌트에서 서비스로의 Request방법을 반환한다. |
java.lang.String |
getSessionKey()
컴포넌트에서 전달된 데이터셋에 대한 암/복호화에 사용되기 위한 세션키를 반환한다. |
abstract int |
identity()
현재 사용되고 있는 Protocol의 유형을 반환한다. |
void |
initialize(java.lang.Object out,
boolean enableCompress,
boolean flushMode,
GauceVariable var)
GauceResponse를 initialize한다. |
void |
setEnableCompress(boolean compress)
Component로 전송하는 Packet을 압축하는지 여부를 저장한다. |
void |
setEnableEncrypt(boolean enable)
GauceDataSet의 Packet을 Component로 전송할 때 Packet에 대한 암호화를 할 것인지에 대한 여부를 저장한다. |
void |
setEncoding(java.lang.String enc)
Component로 data를 전송할 때 사용되는 character set을 설정한다. |
void |
setFirstRowSize(int size)
지정된 크기의 first row size를 설정한다. |
void |
setGauceProvider(com.gauce.common.crypto.GauceProvider provider)
데이터 패킷의 암호화와 관련된 정보를 담은 GauceProvider을 설정한다. |
void |
setMethod(java.lang.String method)
컴포넌트에서 서비스로의 Request방법을 설정한다. |
void |
setSendColumn(boolean canSendColumn)
first row마다 Column정보를 Component로 전송할 것인지를 저장한다. |
void |
setSessionKey(java.lang.String sessionKey)
컴포넌트에서 전달된 데이터셋에 대한 암/복호화에 사용되기 위한 세션키를 저장한다. |
void |
write(byte[] buf)
char배열을 Component로 전송한다. |
void |
write(byte[] buf,
int off,
int len)
buf의 내용중 지정된 부분만큼 Component로 전송한다. |
abstract void |
write(GauceDataSet dataSet)
GauceDataSet을 Component로 전송한다. |
void |
write(java.lang.String str)
String을 Component로 전송한다. |
void |
writeException(java.lang.String type,
java.lang.String code,
java.lang.String e)
서비스 중 발생하는 Exception을 Component로 전송한다. |
| Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
public CommonResponse()
| Method Detail |
public void initialize(java.lang.Object out,
boolean enableCompress,
boolean flushMode,
GauceVariable var)
enableCompress - 압축여부flushMode - flush mode가 First-row인지 아니면 All-row인지 여부var - Gauce Variable 정보out -
public abstract void write(GauceDataSet dataSet)
throws java.io.IOException
write in interface GauceResponsedataSet - Component로 전송할 GauceDataSet
java.io.IOException - 전송중 발생하는 오류
java.io.IOException
public void write(byte[] buf)
throws java.io.IOException
write in interface GauceResponsebuf - 전송할 byte배열
java.io.IOException - 전송중 발행하는 오류
java.io.IOException
public void write(byte[] buf,
int off,
int len)
throws java.io.IOException
write in interface GauceResponsebuf - 전송할 byte배열off - offsetlen - 전송할 char배열의 길이
java.io.IOException - 전송중 발생하는 오류
java.io.IOException
public void write(java.lang.String str)
throws java.io.IOException
write in interface GauceResponsestr - Component로 전송할 String
java.io.IOException - 전송중 발생하는 오류
java.io.IOException
public void flush()
throws java.io.IOException
flush in interface GauceResponsejava.io.IOException - 전송중 발생하는 오류
java.io.IOException
public void close()
throws java.io.IOException
close in interface GauceResponsejava.io.IOException - 통신중 발생하는 오류
java.io.IOExceptionpublic void setSendColumn(boolean canSendColumn)
canSendColumn - Column정보를 전송할 것인지에 대한 여부 (true : 전송, false
: 전송안함)
public void writeException(java.lang.String type,
java.lang.String code,
java.lang.String e)
writeException in interface GauceResponsetype - 오류 유형code - 오류코드e - 오류 내용
public void commit()
throws java.io.IOException
Gauce서비스중 Transaction을 종료하는 Packet을 나타낸다.Gauce서비스 동작중 발생하는 오류를 누적해서 저장한다. 발생하는 오류를 Stack에 저장하고 있다가 서비스 종료시 Component로 지금까지 발생한 모든 오류를 Packet(CSV)로 만들어서 전송한다. 만약 성공이면 0이, 실패이면 -1이 Component로 전송되며, -1일경우 수반되는오류가 같이 Component로 전송된다.
commit in interface GauceResponsejava.io.IOException - commit하는 과정에서 발생하는 오류
java.io.IOException
public void commit(java.lang.String msg)
throws java.io.IOException
만약 성공적인 작업이면 성공메시지로 Component에게 전송되며 실패이면 오류메시지에 추가되어 전송된다.
commit in interface GauceResponsemsg - Component에게 전송할 메시지
java.io.IOException - Transaction을 commit하는 동안 발생하는 오류
java.io.IOExceptionpublic void setEncoding(java.lang.String enc)
enc - 설정할 character setpublic abstract int identity()
이 값은 properties에 명시된 값을 반환한다.
public void enableFirstRow(GauceDataSet dataSet)
enableFirstRow in interface GauceResponsedataSet - 서비스에 등록시킬 GauceDataSetpublic void bufferFilled(BufferFilledEvent bufferFilledEvent)
bufferFilled in interface BufferFilledListenerbufferFilledEvent - 버퍼가 지정된 first row크기만큼 찾을때 발생하는 이벤트public void setFirstRowSize(int size)
size - 설정할 first row sizepublic void setEnableEncrypt(boolean enable)
enable - - 암호화 여부public com.gauce.common.crypto.GauceProvider getGauceProvider()
public void setGauceProvider(com.gauce.common.crypto.GauceProvider provider)
provider - - 데이터 패킷의 암호화와 관련된 정보를 담은 GauceProviderpublic void setEnableCompress(boolean compress)
compress - - Component로 전송하는 Packet을 압축하는지 여부public void setMethod(java.lang.String method)
method - - 컴포넌트에서 서비스로의 Request방법public java.lang.String getMethod()
public void setSessionKey(java.lang.String sessionKey)
sessionKey - 새로 저장할 컴포넌트에서 전달된 세션키public java.lang.String getSessionKey()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||