Package | Description |
---|---|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
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
|
Modifier and Type | Method and Description |
---|---|
(package private) Map<String,SubscriptionEntry> |
StreamBaseClient.getSubscribedStreams()
Get subscribed streams
|
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
|
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.