class TupleConnections extends Object
Modifier and Type | Class and Description |
---|---|
(package private) class |
TupleConnections.Reconnector
attempt to reconnect the TupleConnections
|
(package private) class |
TupleConnections.StreamTupleConnection |
Constructor and Description |
---|
TupleConnections(StreamBaseClient client,
boolean haModeOn) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
addConnection(StreamBaseURI uri,
StreamProperties props) |
void |
addConnectionStatusCallback(ConnectionStatusCallback callback) |
(package private) void |
close() |
void |
enableHeartbeating() |
(package private) void |
enqueueTupleBuffer(StreamBaseClient.SerializedTupleBuffer buffer,
boolean hasMore)
Private version of enqueue that does all of the work.
|
(package private) int |
getConnectionCount() |
(package private) List<TupleConnections.StreamTupleConnection> |
getConnections(StreamProperties props)
Return an unmodifable list of List<StreamConnection>
|
boolean |
isConnected()
Returns true if this TupleConnections has any live connections to a
server.
|
(package private) void |
processLeadershipStatusChange(TupleConnection connection,
Constants.LeadershipStatus newStatus) |
void |
removeConnectionStatusCallback(ConnectionStatusCallback callback) |
void |
setQuiescentLimit(long timeoutMS) |
(package private) void |
tupleConnectionConnected(TupleConnection conn) |
(package private) void |
tupleConnectionDisconnected(TupleConnection conn,
String reason) |
TupleConnections(StreamBaseClient client, boolean haModeOn)
void addConnection(StreamBaseURI uri, StreamProperties props) throws StreamBaseException
StreamBaseException
void close()
public boolean isConnected()
List<TupleConnections.StreamTupleConnection> getConnections(StreamProperties props) throws StreamBaseException
StreamBaseException
void tupleConnectionConnected(TupleConnection conn)
void tupleConnectionDisconnected(TupleConnection conn, String reason)
int getConnectionCount()
public void enableHeartbeating()
public void setQuiescentLimit(long timeoutMS) throws StreamBaseException
StreamBaseException
void processLeadershipStatusChange(TupleConnection connection, Constants.LeadershipStatus newStatus)
public void addConnectionStatusCallback(ConnectionStatusCallback callback)
public void removeConnectionStatusCallback(ConnectionStatusCallback callback)
void enqueueTupleBuffer(StreamBaseClient.SerializedTupleBuffer buffer, boolean hasMore) throws StreamBaseException
StreamBaseException
- thrown on network or other errorsCopyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.