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 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)

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)

create

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

create

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

update

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

update

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

update

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

delete

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

delete

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

subscribe

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

subscribe

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