public class ClientConnection extends Object implements Connection, Closeable
Modifier and Type | Field and Description |
---|---|
protected int |
connectionId |
Constructor and Description |
---|
ClientConnection(HazelcastClientInstanceImpl client,
int connectionId) |
ClientConnection(HazelcastClientInstanceImpl client,
NonBlockingIOThread in,
NonBlockingIOThread out,
int connectionId,
SocketChannelWrapper socketChannelWrapper) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this connection.
|
void |
close(Throwable t) |
void |
decrementPendingPacketCount() |
boolean |
equals(Object o) |
ClientConnectionManager |
getConnectionManager() |
Address |
getEndPoint()
Gets the
Address of the other side of this Connection. |
InetAddress |
getInetAddress()
Returns remote address of this Connection.
|
InetSocketAddress |
getLocalSocketAddress() |
int |
getPendingPacketCount() |
int |
getPort()
The remote port.
|
ClientReadHandler |
getReadHandler() |
Address |
getRemoteEndpoint() |
InetSocketAddress |
getRemoteSocketAddress()
Returns the address of the endpoint this Connection is connected to, or
null if it is unconnected. |
SerializationService |
getSerializationService() |
SocketChannelWrapper |
getSocketChannelWrapper() |
ConnectionType |
getType()
Returns the
ConnectionType of this Connection. |
int |
hashCode() |
void |
incrementPendingPacketCount() |
void |
init() |
protected void |
innerClose() |
boolean |
isAlive()
Checks if the Connection is alive.
|
boolean |
isAuthenticatedAsOwner() |
boolean |
isClient()
Checks if it is a client connection.
|
boolean |
isHeartBeating() |
long |
lastReadTimeMillis()
Returns the clock time in milliseconds of the most recent read using this connection.
|
long |
lastWriteTimeMillis()
Returns the clock time in milliseconds of the most recent write using this connection.
|
void |
setIsAuthenticatedAsOwner() |
void |
setRemoteEndpoint(Address remoteEndpoint) |
void |
setType(ConnectionType type)
Sets the type of the connection
|
String |
toString() |
boolean |
write(OutboundFrame frame)
Writes a outbound frame so it can be received by the other side of the connection.
|
public ClientConnection(HazelcastClientInstanceImpl client, NonBlockingIOThread in, NonBlockingIOThread out, int connectionId, SocketChannelWrapper socketChannelWrapper) throws IOException
IOException
public ClientConnection(HazelcastClientInstanceImpl client, int connectionId) throws IOException
IOException
public void incrementPendingPacketCount()
public void decrementPendingPacketCount()
public int getPendingPacketCount()
public SerializationService getSerializationService()
public boolean write(OutboundFrame frame)
Connection
The frame could be stored in an internal queue before it actually is written, so this call does not need to be a synchronous call.
write
in interface Connection
frame
- the frame to write.public void init() throws IOException
IOException
public Address getEndPoint()
Connection
Address
of the other side of this Connection.
todo: rename to get remoteAddress?
getEndPoint
in interface Connection
public boolean isAlive()
Connection
isAlive
in interface Connection
public long lastReadTimeMillis()
Connection
lastReadTimeMillis
in interface Connection
public long lastWriteTimeMillis()
Connection
lastWriteTimeMillis
in interface Connection
public void close()
Connection
Pending packets on this connection are discarded
If the Connection is already closed, the call is ignored. So it can safely be called multiple times.
close
in interface Connection
close
in interface Closeable
close
in interface AutoCloseable
public void setType(ConnectionType type)
Connection
setType
in interface Connection
type
- to be setpublic ConnectionType getType()
Connection
ConnectionType
of this Connection.getType
in interface Connection
null
is returned.public boolean isClient()
Connection
isClient
in interface Connection
public InetAddress getInetAddress()
Connection
getInetAddress
in interface Connection
null
if the connection is not alive.public InetSocketAddress getRemoteSocketAddress()
Connection
null
if it is unconnected.getRemoteSocketAddress
in interface Connection
todo: do we really need this method because we have getInetAddress, InetSocketAddress and getEndPoint.
public int getPort()
Connection
todo: rename to getRemotePort? And do we need it because we already have getEndPoint which returns an address which includes port. It is only used in testing
getPort
in interface Connection
public SocketChannelWrapper getSocketChannelWrapper()
public ClientConnectionManager getConnectionManager()
public ClientReadHandler getReadHandler()
public void setRemoteEndpoint(Address remoteEndpoint)
public Address getRemoteEndpoint()
public InetSocketAddress getLocalSocketAddress()
protected void innerClose() throws IOException
IOException
public void close(Throwable t)
public boolean isHeartBeating()
public boolean isAuthenticatedAsOwner()
public void setIsAuthenticatedAsOwner()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.