public class Nio2Session extends CloseableUtils.AbstractCloseable implements IoSession
CloseableUtils.AbstractCloseable.State
closeFuture, lock, log, state
Constructor and Description |
---|
Nio2Session(Nio2Service service,
IoHandler handler,
AsynchronousSocketChannel socket) |
Modifier and Type | Method and Description |
---|---|
protected CloseFuture |
doCloseGracefully() |
protected void |
doCloseImmediately()
doCloseImmediately is called once and only once
with state == Immediate
Overriding methods should always call the base implementation.
|
Object |
getAttribute(Object key)
Returns the value of the user-defined attribute of this session.
|
long |
getId()
Returns a unique identifier for this session.
|
SocketAddress |
getLocalAddress()
Returns the socket address of local machine which is associated with this
session.
|
SocketAddress |
getRemoteAddress()
Returns the socket address of remote peer.
|
IoService |
getService()
Returns the IoService that created this session.
|
Object |
setAttribute(Object key,
Object value)
Sets a user-defined attribute.
|
void |
startReading() |
void |
suspend() |
String |
toString() |
IoWriteFuture |
write(Buffer buffer)
Write a packet on the socket.
|
builder, close, isClosed, isClosing, preClose
public Nio2Session(Nio2Service service, IoHandler handler, AsynchronousSocketChannel socket) throws IOException
IOException
public long getId()
IoSession
public Object getAttribute(Object key)
IoSession
getAttribute
in interface IoSession
key
- the key of the attributepublic Object setAttribute(Object key, Object value)
IoSession
setAttribute
in interface IoSession
key
- the key of the attributevalue
- the value of the attributepublic SocketAddress getRemoteAddress()
IoSession
getRemoteAddress
in interface IoSession
public SocketAddress getLocalAddress()
IoSession
getLocalAddress
in interface IoSession
public void suspend()
public IoWriteFuture write(Buffer buffer)
IoSession
protected CloseFuture doCloseGracefully()
doCloseGracefully
in class CloseableUtils.AbstractCloseable
protected void doCloseImmediately()
CloseableUtils.AbstractCloseable
doCloseImmediately
in class CloseableUtils.AbstractCloseable
public IoService getService()
IoSession
getService
in interface IoSession
public void startReading()
Copyright © 2008–2016 The Apache Software Foundation. All rights reserved.