Package com.eventstore.dbclient

Class EventStoreDBPersistentSubscriptionsClient

java.lang.Object

com.eventstore.dbclient.EventStoreDBClientBase

com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient

public class EventStoreDBPersistentSubscriptionsClient
extends EventStoreDBClientBase

Field Summary

Fields inherited from class com.eventstore.dbclient.EventStoreDBClientBase

client, credentials

Method Summary

Modifier and Type	Method	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	createToAll(java.lang.String group)
java.util.concurrent.CompletableFuture	createToAll(java.lang.String group, CreatePersistentSubscriptionToAllOptions options)
java.util.concurrent.CompletableFuture	createToAll(java.lang.String group, PersistentSubscriptionToAllSettings 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	deleteToAll(java.lang.String group)
java.util.concurrent.CompletableFuture	deleteToAll(java.lang.String group, DeletePersistentSubscriptionOptions options)
java.util.concurrent.CompletableFuture<PersistentSubscription>	subscribe(java.lang.String stream, java.lang.String group, PersistentSubscriptionListener listener)
java.util.concurrent.CompletableFuture<PersistentSubscription>	subscribe(java.lang.String stream, java.lang.String group, SubscribePersistentSubscriptionOptions options, PersistentSubscriptionListener listener)
java.util.concurrent.CompletableFuture<PersistentSubscription>	subscribeToAll(java.lang.String group, PersistentSubscriptionListener listener)
java.util.concurrent.CompletableFuture<PersistentSubscription>	subscribeToAll(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)
java.util.concurrent.CompletableFuture	updateToAll(java.lang.String group)
java.util.concurrent.CompletableFuture	updateToAll(java.lang.String group, PersistentSubscriptionToAllSettings settings)
java.util.concurrent.CompletableFuture	updateToAll(java.lang.String group, UpdatePersistentSubscriptionToAllOptions options)

Methods inherited from class com.eventstore.dbclient.EventStoreDBClientBase

shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static EventStoreDBPersistentSubscriptionsClient create(EventStoreDBClientSettings settings)

create

public java.util.concurrent.CompletableFuture create(java.lang.String stream,
                                                     java.lang.String group)

createToAll

public java.util.concurrent.CompletableFuture createToAll(java.lang.String group)

create

public java.util.concurrent.CompletableFuture create(java.lang.String stream,
                                                     java.lang.String group,
                                                     PersistentSubscriptionSettings settings)

createToAll

public java.util.concurrent.CompletableFuture createToAll(java.lang.String group,
                                                          PersistentSubscriptionToAllSettings settings)

create

public java.util.concurrent.CompletableFuture create(java.lang.String stream,
                                                     java.lang.String group,
                                                     CreatePersistentSubscriptionOptions options)

createToAll

public java.util.concurrent.CompletableFuture createToAll(java.lang.String group,
                                                          CreatePersistentSubscriptionToAllOptions options)

update

public java.util.concurrent.CompletableFuture update(java.lang.String stream,
                                                     java.lang.String group)

updateToAll

public java.util.concurrent.CompletableFuture updateToAll(java.lang.String group)

update

public java.util.concurrent.CompletableFuture update(java.lang.String stream,
                                                     java.lang.String group,
                                                     PersistentSubscriptionSettings settings)

updateToAll

public java.util.concurrent.CompletableFuture updateToAll(java.lang.String group,
                                                          PersistentSubscriptionToAllSettings settings)

update

public java.util.concurrent.CompletableFuture update(java.lang.String stream,
                                                     java.lang.String group,
                                                     UpdatePersistentSubscriptionOptions options)

updateToAll

public java.util.concurrent.CompletableFuture updateToAll(java.lang.String group,
                                                          UpdatePersistentSubscriptionToAllOptions options)

delete

public java.util.concurrent.CompletableFuture delete(java.lang.String stream,
                                                     java.lang.String group)

deleteToAll

public java.util.concurrent.CompletableFuture deleteToAll(java.lang.String group)

delete

public java.util.concurrent.CompletableFuture delete(java.lang.String stream,
                                                     java.lang.String group,
                                                     DeletePersistentSubscriptionOptions options)

deleteToAll

public java.util.concurrent.CompletableFuture deleteToAll(java.lang.String group,
                                                          DeletePersistentSubscriptionOptions options)

subscribe

public java.util.concurrent.CompletableFuture<PersistentSubscription> subscribe(java.lang.String stream,
                                                                                java.lang.String group,
                                                                                PersistentSubscriptionListener listener)

subscribeToAll

public java.util.concurrent.CompletableFuture<PersistentSubscription> subscribeToAll(java.lang.String group,
                                                                                     PersistentSubscriptionListener listener)

subscribe

public java.util.concurrent.CompletableFuture<PersistentSubscription> subscribe(java.lang.String stream,
                                                                                java.lang.String group,
                                                                                SubscribePersistentSubscriptionOptions options,
                                                                                PersistentSubscriptionListener listener)

subscribeToAll

public java.util.concurrent.CompletableFuture<PersistentSubscription> subscribeToAll(java.lang.String group,
                                                                                     SubscribePersistentSubscriptionOptions options,
                                                                                     PersistentSubscriptionListener listener)