Class NoOpTTrasport
java.lang.Object
org.apache.storm.thrift.transport.TTransport
org.apache.storm.thrift.transport.TEndpointTransport
org.apache.storm.thrift.transport.TSaslServerTransport
org.apache.storm.security.auth.kerberos.NoOpTTrasport
- All Implemented Interfaces:
- Closeable,- AutoCloseable
public class NoOpTTrasport
extends org.apache.storm.thrift.transport.TSaslServerTransport
- 
Nested Class SummaryNested classes/interfaces inherited from class org.apache.storm.thrift.transport.TSaslServerTransportorg.apache.storm.thrift.transport.TSaslServerTransport.Factory
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprotected static final intprotected static final intprotected static final intprotected static final intprotected org.apache.storm.thrift.transport.TTransportFields inherited from class org.apache.storm.thrift.transport.TEndpointTransportknownMessageSize, remainingMessageSize
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()voidflush()org.apache.storm.thrift.transport.TTransportbooleanisOpen()voidopen()intread(byte[] bytes, int i, int i1) protected intprotected org.apache.storm.thrift.transport.TSaslTransport.SaslResponseprotected org.apache.storm.thrift.transport.TTransportExceptionsendAndThrowMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, String arg1) protected voidsendSaslMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, byte[] arg1) protected voidsetSaslServer(SaslServer arg0) voidwrite(byte[] bytes, int i, int i1) protected voidwriteLength(int arg0) Methods inherited from class org.apache.storm.thrift.transport.TSaslServerTransportaddServerDefinition, getRole, handleSaslStartMessageMethods inherited from class org.apache.storm.thrift.transport.TEndpointTransportcheckReadBytesAvailable, countConsumedMessageBytes, getConfiguration, getMaxFrameSize, getMaxMessageSize, resetConsumedMessageSize, setMaxFrameSize, updateKnownMessageSizeMethods inherited from class org.apache.storm.thrift.transport.TTransportconsumeBuffer, getBuffer, getBufferPosition, getBytesRemainingInBuffer, peek, read, readAll, write, write
- 
Field Details- 
DEFAULT_MAX_LENGTHprotected static final int DEFAULT_MAX_LENGTH- See Also:
 
- 
MECHANISM_NAME_BYTESprotected static final int MECHANISM_NAME_BYTES- See Also:
 
- 
STATUS_BYTESprotected static final int STATUS_BYTES- See Also:
 
- 
PAYLOAD_LENGTH_BYTESprotected static final int PAYLOAD_LENGTH_BYTES- See Also:
 
- 
underlyingTransportprotected org.apache.storm.thrift.transport.TTransport underlyingTransport
 
- 
- 
Constructor Details- 
NoOpTTrasportpublic NoOpTTrasport(org.apache.storm.thrift.transport.TTransport transport) throws org.apache.storm.thrift.transport.TTransportException - Throws:
- org.apache.storm.thrift.transport.TTransportException
 
 
- 
- 
Method Details- 
isOpenpublic boolean isOpen()
- 
openpublic void open() throws org.apache.storm.thrift.transport.TTransportException- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
- Specified by:
- closein interface- Closeable
 
- 
readpublic int read(byte[] bytes, int i, int i1) throws org.apache.storm.thrift.transport.TTransportException - Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
writepublic void write(byte[] bytes, int i, int i1) throws org.apache.storm.thrift.transport.TTransportException - Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
setSaslServer
- 
sendSaslMessageprotected void sendSaslMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, byte[] arg1) throws org.apache.storm.thrift.transport.TTransportException - Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
receiveSaslMessageprotected org.apache.storm.thrift.transport.TSaslTransport.SaslResponse receiveSaslMessage() throws org.apache.storm.thrift.transport.TTransportException- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
sendAndThrowMessageprotected org.apache.storm.thrift.transport.TTransportException sendAndThrowMessage(org.apache.storm.thrift.transport.sasl.NegotiationStatus arg0, String arg1) throws org.apache.storm.thrift.transport.TTransportException - Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
getSaslClient
- 
getUnderlyingTransportpublic org.apache.storm.thrift.transport.TTransport getUnderlyingTransport()
- 
getSaslServer
- 
readLengthprotected int readLength() throws org.apache.storm.thrift.transport.TTransportException- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
writeLengthprotected void writeLength(int arg0) throws org.apache.storm.thrift.transport.TTransportException - Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
flushpublic void flush() throws org.apache.storm.thrift.transport.TTransportException- Overrides:
- flushin class- org.apache.storm.thrift.transport.TTransport
- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
 
-