public class DocumentSubscriptions extends Object implements IReliableSubscriptions
Modifier and Type | Class and Description |
---|---|
static class |
DocumentSubscriptions.ErrorAndUrl |
Constructor and Description |
---|
DocumentSubscriptions(IDocumentStore documentStore) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
create(Class<?> expectedType,
SubscriptionCriteria criteria)
It creates a data subscription in a database.
|
long |
create(Class<?> expectedType,
SubscriptionCriteria criteria,
String database)
It creates a data subscription in a database.
|
long |
create(SubscriptionCriteria criteria)
It creates a data subscription in a database.
|
long |
create(SubscriptionCriteria criteria,
String database)
It creates a data subscription in a database.
|
void |
delete(long id)
It deletes a subscription.
|
void |
delete(long id,
String database)
It deletes a subscription.
|
List<SubscriptionConfig> |
getSubscriptions(int start,
int take)
It downloads a list of all existing subscriptions in a database.
|
List<SubscriptionConfig> |
getSubscriptions(int start,
int take,
String database)
It downloads a list of all existing subscriptions in a database.
|
<T> Subscription<T> |
open(Class<T> clazz,
long id,
SubscriptionConnectionOptions options)
It opens a subscription and starts pulling documents since a last processed document for that subscription (in document's Etag order).
|
<T> Subscription<T> |
open(Class<T> clazz,
long id,
SubscriptionConnectionOptions options,
String database)
It opens a subscription and starts pulling documents since a last processed document for that subscription (in document's Etag order).
|
Subscription<RavenJObject> |
open(long id,
SubscriptionConnectionOptions options)
It opens a subscription and starts pulling documents since a last processed document for that subscription (in document's Etag order).
|
Subscription<RavenJObject> |
open(long id,
SubscriptionConnectionOptions options,
String database)
It opens a subscription and starts pulling documents since a last processed document for that subscription (in document's Etag order).
|
void |
release(long id)
It releases a subscriptions by forcing a connected client to drop.
|
void |
release(long id,
String database)
It releases a subscriptions by forcing a connected client to drop.
|
static SubscriptionException |
tryGetSubscriptionException(Exception ere) |
public DocumentSubscriptions(IDocumentStore documentStore)
public long create(Class<?> expectedType, SubscriptionCriteria criteria)
IReliableSubscriptions
create
in interface IReliableSubscriptions
public long create(Class<?> expectedType, SubscriptionCriteria criteria, String database)
IReliableSubscriptions
create
in interface IReliableSubscriptions
public long create(SubscriptionCriteria criteria)
IReliableSubscriptions
create
in interface IReliableSubscriptions
public long create(SubscriptionCriteria criteria, String database)
IReliableSubscriptions
create
in interface IReliableSubscriptions
public <T> Subscription<T> open(Class<T> clazz, long id, SubscriptionConnectionOptions options) throws SubscriptionException
IReliableSubscriptions
open
in interface IReliableSubscriptions
SubscriptionException
public <T> Subscription<T> open(Class<T> clazz, long id, SubscriptionConnectionOptions options, String database) throws SubscriptionException
IReliableSubscriptions
open
in interface IReliableSubscriptions
SubscriptionException
public Subscription<RavenJObject> open(long id, SubscriptionConnectionOptions options) throws SubscriptionException
IReliableSubscriptions
open
in interface IReliableSubscriptions
SubscriptionException
public Subscription<RavenJObject> open(long id, SubscriptionConnectionOptions options, String database) throws SubscriptionException
IReliableSubscriptions
open
in interface IReliableSubscriptions
SubscriptionException
public List<SubscriptionConfig> getSubscriptions(int start, int take)
IReliableSubscriptions
getSubscriptions
in interface IReliableSubscriptions
public List<SubscriptionConfig> getSubscriptions(int start, int take, String database)
IReliableSubscriptions
getSubscriptions
in interface IReliableSubscriptions
public void delete(long id)
IReliableSubscriptions
delete
in interface IReliableSubscriptions
public void delete(long id, String database)
IReliableSubscriptions
delete
in interface IReliableSubscriptions
public void release(long id)
IReliableSubscriptions
release
in interface IReliableSubscriptions
public void release(long id, String database)
IReliableSubscriptions
release
in interface IReliableSubscriptions
public static SubscriptionException tryGetSubscriptionException(Exception ere)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
Copyright © 2016. All Rights Reserved.