public class EventStoreDBPersistentSubscriptionsClient extends EventStoreDBClientBase
client, credentials| Modifier and Type | Method and Description |
|---|---|
static EventStoreDBPersistentSubscriptionsClient |
create(EventStoreDBClientSettings settings) |
java.util.concurrent.CompletableFuture |
create(java.lang.String stream,
java.lang.String group) |
java.util.concurrent.CompletableFuture |
create(java.lang.String stream,
java.lang.String group,
CreatePersistentSubscriptionOptions options) |
java.util.concurrent.CompletableFuture |
create(java.lang.String stream,
java.lang.String group,
PersistentSubscriptionSettings settings) |
java.util.concurrent.CompletableFuture |
delete(java.lang.String stream,
java.lang.String group) |
java.util.concurrent.CompletableFuture |
delete(java.lang.String stream,
java.lang.String group,
DeletePersistentSubscriptionOptions options) |
java.util.concurrent.CompletableFuture |
subscribe(java.lang.String stream,
java.lang.String group,
PersistentSubscriptionListener listener) |
java.util.concurrent.CompletableFuture |
subscribe(java.lang.String stream,
java.lang.String group,
SubscribePersistentSubscriptionOptions options,
PersistentSubscriptionListener listener) |
java.util.concurrent.CompletableFuture |
update(java.lang.String stream,
java.lang.String group) |
java.util.concurrent.CompletableFuture |
update(java.lang.String stream,
java.lang.String group,
PersistentSubscriptionSettings settings) |
java.util.concurrent.CompletableFuture |
update(java.lang.String stream,
java.lang.String group,
UpdatePersistentSubscriptionOptions options) |
shutdownpublic static EventStoreDBPersistentSubscriptionsClient create(EventStoreDBClientSettings settings)
public java.util.concurrent.CompletableFuture create(java.lang.String stream,
java.lang.String group)
public java.util.concurrent.CompletableFuture create(java.lang.String stream,
java.lang.String group,
PersistentSubscriptionSettings settings)
public java.util.concurrent.CompletableFuture create(java.lang.String stream,
java.lang.String group,
CreatePersistentSubscriptionOptions options)
public java.util.concurrent.CompletableFuture update(java.lang.String stream,
java.lang.String group)
public java.util.concurrent.CompletableFuture update(java.lang.String stream,
java.lang.String group,
PersistentSubscriptionSettings settings)
public java.util.concurrent.CompletableFuture update(java.lang.String stream,
java.lang.String group,
UpdatePersistentSubscriptionOptions options)
public java.util.concurrent.CompletableFuture delete(java.lang.String stream,
java.lang.String group)
public java.util.concurrent.CompletableFuture delete(java.lang.String stream,
java.lang.String group,
DeletePersistentSubscriptionOptions options)
public java.util.concurrent.CompletableFuture subscribe(java.lang.String stream,
java.lang.String group,
PersistentSubscriptionListener listener)
public java.util.concurrent.CompletableFuture subscribe(java.lang.String stream,
java.lang.String group,
SubscribePersistentSubscriptionOptions options,
PersistentSubscriptionListener listener)