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
java.util.concurrent.CompletableFuture	createToAll(java.lang.String group)
java.util.concurrent.CompletableFuture	createToAll(java.lang.String group, CreatePersistentSubscriptionToAllOptions options)
static EventStoreDBPersistentSubscriptionsClient	createToStream(EventStoreDBClientSettings settings)
java.util.concurrent.CompletableFuture	createToStream(java.lang.String stream, java.lang.String group)
java.util.concurrent.CompletableFuture	createToStream(java.lang.String stream, java.lang.String group, CreatePersistentSubscriptionToStreamOptions 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	deleteToStream(java.lang.String stream, java.lang.String group)
java.util.concurrent.CompletableFuture	deleteToStream(java.lang.String stream, java.lang.String group, DeletePersistentSubscriptionOptions options)
java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>>	getInfoToAll(java.lang.String groupName)
java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>>	getInfoToAll(java.lang.String groupName, GetPersistentSubscriptionInfoOptions options)
java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>>	getInfoToStream(java.lang.String stream, java.lang.String groupName)
java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>>	getInfoToStream(java.lang.String stream, java.lang.String groupName, GetPersistentSubscriptionInfoOptions options)
java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionInfo>>	listAll()
java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionInfo>>	listAll(ListPersistentSubscriptionsOptions options)
java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToAllInfo>>	listToAll()
java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToAllInfo>>	listToAll(ListPersistentSubscriptionsOptions options)
java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToStreamInfo>>	listToStream(java.lang.String stream)
java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToStreamInfo>>	listToStream(java.lang.String stream, ListPersistentSubscriptionsOptions options)
java.util.concurrent.CompletableFuture	replayParkedMessagesToAll(java.lang.String groupName)
java.util.concurrent.CompletableFuture	replayParkedMessagesToAll(java.lang.String groupName, ReplayParkedMessagesOptions options)
java.util.concurrent.CompletableFuture	replayParkedMessagesToStream(java.lang.String stream, java.lang.String groupName)
java.util.concurrent.CompletableFuture	replayParkedMessagesToStream(java.lang.String stream, java.lang.String groupName, ReplayParkedMessagesOptions options)
java.util.concurrent.CompletableFuture	restartSubsystem()
java.util.concurrent.CompletableFuture	restartSubsystem(RestartPersistentSubscriptionSubsystemOptions options)
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<PersistentSubscription>	subscribeToStream(java.lang.String stream, java.lang.String group, PersistentSubscriptionListener listener)
java.util.concurrent.CompletableFuture<PersistentSubscription>	subscribeToStream(java.lang.String stream, java.lang.String group, SubscribePersistentSubscriptionOptions options, PersistentSubscriptionListener listener)
java.util.concurrent.CompletableFuture	updateToAll(java.lang.String group)
java.util.concurrent.CompletableFuture	updateToAll(java.lang.String group, UpdatePersistentSubscriptionToAllOptions options)
java.util.concurrent.CompletableFuture	updateToStream(java.lang.String stream, java.lang.String group)
java.util.concurrent.CompletableFuture	updateToStream(java.lang.String stream, java.lang.String group, UpdatePersistentSubscriptionToStreamOptions options)

Methods inherited from class com.eventstore.dbclient.EventStoreDBClientBase

isShutdown, shutdown

Methods inherited from class java.lang.Object

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

Method Detail

createToStream

public static EventStoreDBPersistentSubscriptionsClient createToStream(EventStoreDBClientSettings settings)

createToStream

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

createToAll

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

createToStream

public java.util.concurrent.CompletableFuture createToStream(java.lang.String stream,
                                                             java.lang.String group,
                                                             CreatePersistentSubscriptionToStreamOptions options)

createToAll

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

updateToStream

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

updateToAll

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

updateToStream

public java.util.concurrent.CompletableFuture updateToStream(java.lang.String stream,
                                                             java.lang.String group,
                                                             UpdatePersistentSubscriptionToStreamOptions options)

updateToAll

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

deleteToStream

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

deleteToAll

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

deleteToStream

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

deleteToAll

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

subscribeToStream

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

subscribeToAll

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

subscribeToStream

public java.util.concurrent.CompletableFuture<PersistentSubscription> subscribeToStream(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)

listAll

public java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionInfo>> listAll(ListPersistentSubscriptionsOptions options)

listAll

public java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionInfo>> listAll()

listToStream

public java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToStreamInfo>> listToStream(java.lang.String stream,
                                                                                                               ListPersistentSubscriptionsOptions options)

listToStream

public java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToStreamInfo>> listToStream(java.lang.String stream)

listToAll

public java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToAllInfo>> listToAll()

listToAll

public java.util.concurrent.CompletableFuture<java.util.List<PersistentSubscriptionToAllInfo>> listToAll(ListPersistentSubscriptionsOptions options)

getInfoToStream

public java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>> getInfoToStream(java.lang.String stream,
                                                                                                              java.lang.String groupName,
                                                                                                              GetPersistentSubscriptionInfoOptions options)

getInfoToStream

public java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>> getInfoToStream(java.lang.String stream,
                                                                                                              java.lang.String groupName)

getInfoToAll

public java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>> getInfoToAll(java.lang.String groupName,
                                                                                                           GetPersistentSubscriptionInfoOptions options)

getInfoToAll

public java.util.concurrent.CompletableFuture<java.util.Optional<PersistentSubscriptionInfo>> getInfoToAll(java.lang.String groupName)

replayParkedMessagesToStream

public java.util.concurrent.CompletableFuture replayParkedMessagesToStream(java.lang.String stream,
                                                                           java.lang.String groupName,
                                                                           ReplayParkedMessagesOptions options)

replayParkedMessagesToStream

public java.util.concurrent.CompletableFuture replayParkedMessagesToStream(java.lang.String stream,
                                                                           java.lang.String groupName)

replayParkedMessagesToAll

public java.util.concurrent.CompletableFuture replayParkedMessagesToAll(java.lang.String groupName,
                                                                        ReplayParkedMessagesOptions options)

replayParkedMessagesToAll

public java.util.concurrent.CompletableFuture replayParkedMessagesToAll(java.lang.String groupName)
                                                                 throws java.util.concurrent.ExecutionException,
                                                                        java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

restartSubsystem

public java.util.concurrent.CompletableFuture restartSubsystem()

restartSubsystem

public java.util.concurrent.CompletableFuture restartSubsystem(RestartPersistentSubscriptionSubsystemOptions options)