org.apache.qpid.amqp_1_0.transport

Class SASLEndpointImpl

java.lang.Object

org.apache.qpid.amqp_1_0.transport.SASLEndpointImpl

All Implemented Interfaces:

DescribedTypeConstructorRegistry.Source, ValueWriter.Registry.Source, SASLEndpoint

public class SASLEndpointImpl
extends Object
implements DescribedTypeConstructorRegistry.Source, ValueWriter.Registry.Source, SASLEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
PrintWriter	_out

Method Summary

Modifier and Type	Method and Description
boolean	closedForInput()
boolean	closedForOutput()
AMQPDescribedTypeRegistry	getDescribedTypeRegistry()
Object	getLock()
byte	getMajorVersion()
byte	getMinorVersion()
byte	getRevision()
void	invalidHeaderReceived()
boolean	isReadable()
boolean	isWritable()
void	protocolHeaderReceived(byte major, byte minorVersion, byte revision)
void	receive(short channel, Object frame)
void	receiveSaslChallenge(SaslChallenge saslChallenge)
void	receiveSaslInit(SaslInit saslInit)
void	receiveSaslMechanisms(SaslMechanisms saslMechanisms)
void	receiveSaslOutcome(SaslOutcome saslOutcome)
void	receiveSaslResponse(SaslResponse saslResponse)
void	send(SaslFrameBody body)
void	setClosedForOutput(boolean b)
void	setFrameOutputHandler(FrameOutputHandler frameOutputHandler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_out

public PrintWriter _out

Method Detail

setFrameOutputHandler

public void setFrameOutputHandler(FrameOutputHandler frameOutputHandler)

isReadable

public boolean isReadable()

isWritable

public boolean isWritable()

send

public void send(SaslFrameBody body)

invalidHeaderReceived

public void invalidHeaderReceived()

closedForInput

public boolean closedForInput()

protocolHeaderReceived

public void protocolHeaderReceived(byte major,
                                   byte minorVersion,
                                   byte revision)

receive

public void receive(short channel,
                    Object frame)

getDescribedTypeRegistry

public AMQPDescribedTypeRegistry getDescribedTypeRegistry()

Specified by:

getDescribedTypeRegistry in interface DescribedTypeConstructorRegistry.Source

Specified by:

getDescribedTypeRegistry in interface ValueWriter.Registry.Source

setClosedForOutput

public void setClosedForOutput(boolean b)

closedForOutput

public boolean closedForOutput()

getLock

public Object getLock()

getMajorVersion

public byte getMajorVersion()

getMinorVersion

public byte getMinorVersion()

getRevision

public byte getRevision()

receiveSaslInit

public void receiveSaslInit(SaslInit saslInit)

Specified by:

receiveSaslInit in interface SASLEndpoint

receiveSaslMechanisms

public void receiveSaslMechanisms(SaslMechanisms saslMechanisms)

Specified by:

receiveSaslMechanisms in interface SASLEndpoint

receiveSaslChallenge

public void receiveSaslChallenge(SaslChallenge saslChallenge)

Specified by:

receiveSaslChallenge in interface SASLEndpoint

receiveSaslResponse

public void receiveSaslResponse(SaslResponse saslResponse)

Specified by:

receiveSaslResponse in interface SASLEndpoint

receiveSaslOutcome

public void receiveSaslOutcome(SaslOutcome saslOutcome)

Specified by:

receiveSaslOutcome in interface SASLEndpoint