Package | Description |
---|---|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
Modifier and Type | Method and Description |
---|---|
(package private) List<TupleConnections.StreamTupleConnection> |
TupleConnections.getConnections(StreamProperties props)
Return an unmodifable list of List<StreamConnection>
|
Modifier and Type | Method and Description |
---|---|
SubscriptionEntry |
Admin.subscribe(long timeoutMS,
SubscriptionEntry subscription,
List<TupleConnections.StreamTupleConnection> connections)
Subscribe to an output stream.
|
SubscriptionEntry |
HAAdmin.subscribe(long timeoutMS,
SubscriptionEntry subscription,
List<TupleConnections.StreamTupleConnection> connections)
Subscribe to an output stream with predicate
|
void |
Admin.unsubscribe(long timeoutMS,
StreamProperties props,
String logicalstream,
List<TupleConnections.StreamTupleConnection> connections)
UnSubscribe to an output stream.
|
void |
HAAdmin.unsubscribe(long timeoutMS,
StreamProperties props,
String logicalstream,
List<TupleConnections.StreamTupleConnection> connections)
UnSubscribe to an output stream.
|
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.