SaslSocketTransceiver
instead.public class SocketTransceiver extends Transceiver
Transceiver
implementation. This uses a simple,
non-standard wire protocol and is not intended for production services.Constructor and Description |
---|
SocketTransceiver(SocketAddress address)
Deprecated.
|
SocketTransceiver(SocketChannel channel)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
|
Protocol |
getRemote()
Deprecated.
Returns the protocol passed to
Transceiver.setRemote(Protocol) . |
String |
getRemoteName()
Deprecated.
|
boolean |
isConnected()
Deprecated.
True if a handshake has been completed for this connection.
|
List<ByteBuffer> |
readBuffers()
Deprecated.
Called by the default definition of
Transceiver.transceive(List) . |
void |
setRemote(Protocol remote)
Deprecated.
Called with the remote protocol when a handshake has been completed.
|
void |
writeBuffers(List<ByteBuffer> buffers)
Deprecated.
Called by
Requestor.request(String,Object) for one-way messages. |
lockChannel, transceive, transceive, unlockChannel
public SocketTransceiver(SocketAddress address) throws IOException
IOException
public SocketTransceiver(SocketChannel channel) throws IOException
IOException
public String getRemoteName()
getRemoteName
in class Transceiver
public List<ByteBuffer> readBuffers() throws IOException
Transceiver
Transceiver.transceive(List)
.readBuffers
in class Transceiver
IOException
public void writeBuffers(List<ByteBuffer> buffers) throws IOException
Transceiver
Requestor.request(String,Object)
for one-way messages.writeBuffers
in class Transceiver
IOException
public boolean isConnected()
Transceiver
isConnected
in class Transceiver
public void setRemote(Protocol remote)
Transceiver
Transceiver.isConnected()
should return true and #getRemote() should return this
protocol. Does nothing by default.setRemote
in class Transceiver
public Protocol getRemote()
Transceiver
Transceiver.setRemote(Protocol)
. Throws
IllegalStateException by default.getRemote
in class Transceiver
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class Transceiver
IOException
Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.