public class ClientConnection extends Object implements Connection
Connection.
ClientConnection is a connection between a Hazelcast Client and a Hazelcast Member.| Constructor and Description |
|---|
ClientConnection(HazelcastClientInstanceImpl client,
int connectionId) |
ClientConnection(HazelcastClientInstanceImpl client,
int connectionId,
Channel channel) |
| Modifier and Type | Method and Description |
|---|---|
void |
close(String reason,
Throwable cause)
Closes this connection.
|
boolean |
equals(Object o) |
Throwable |
getCloseCause()
Gets the cause this Connection was closed.
|
String |
getCloseReason()
Gets the reason this Connection was closed.
|
int |
getConnectedServerVersion() |
String |
getConnectedServerVersionString() |
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 |
getPort()
The remote port.
|
InetSocketAddress |
getRemoteSocketAddress()
Returns the address of the endpoint this Connection is connected to, or
null if it is unconnected. |
long |
getStartTime() |
ConnectionType |
getType()
Returns the
ConnectionType of this Connection. |
void |
handleClientMessage(ClientMessage message) |
int |
hashCode() |
protected void |
innerClose() |
boolean |
isAlive()
Checks if the Connection is alive.
|
boolean |
isAuthenticatedAsOwner() |
boolean |
isClient()
Checks if it is a client connection.
|
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 |
setConnectedServerVersion(String connectedServerVersion) |
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, int connectionId, Channel channel)
public ClientConnection(HazelcastClientInstanceImpl client, int connectionId)
public boolean write(OutboundFrame frame)
ConnectionThe 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 Connectionframe - the frame to write.public Address getEndPoint()
ConnectionAddress of the other side of this Connection.
todo: rename to get remoteAddress?
getEndPoint in interface Connectionpublic boolean isAlive()
ConnectionisAlive in interface Connectionpublic long lastReadTimeMillis()
ConnectionlastReadTimeMillis in interface Connectionpublic long lastWriteTimeMillis()
ConnectionlastWriteTimeMillis in interface Connectionpublic void setType(ConnectionType type)
ConnectionsetType in interface Connectiontype - to be setpublic ConnectionType getType()
ConnectionConnectionType of this Connection.getType in interface Connectionnull is returned.public boolean isClient()
ConnectionisClient in interface Connectionpublic InetAddress getInetAddress()
ConnectiongetInetAddress in interface Connectionnull if the connection is not alive.public InetSocketAddress getRemoteSocketAddress()
Connectionnull if it is unconnected.getRemoteSocketAddress in interface Connectiontodo: do we really need this method because we have getInetAddress, InetSocketAddress and getEndPoint.
public int getPort()
Connectiontodo: 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 Connectionpublic ClientConnectionManager getConnectionManager()
public void setRemoteEndpoint(Address remoteEndpoint)
public InetSocketAddress getLocalSocketAddress()
public void close(String reason, Throwable cause)
ConnectionPending 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 Connectionreason - the reason this connection is going to be closed. Is allowed to be null.cause - the Throwable responsible for closing this connection. Is allowed to be null.protected void innerClose()
throws IOException
IOExceptionpublic Throwable getCloseCause()
ConnectiongetCloseCause in interface Connection(),
Connection.close(String, Throwable)public String getCloseReason()
ConnectiongetCloseReason in interface ConnectionConnection.getCloseCause(),
Connection.close(String, Throwable)public void handleClientMessage(ClientMessage message)
public boolean isAuthenticatedAsOwner()
public void setIsAuthenticatedAsOwner()
public long getStartTime()
public void setConnectedServerVersion(String connectedServerVersion)
public int getConnectedServerVersion()
public String getConnectedServerVersionString()
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.