public interface IReliableSubscriptions extends CleanCloseable
Modifier and Type | Method and Description |
---|---|
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.
|
close
long create(Class<?> expectedType, SubscriptionCriteria criteria)
long create(Class<?> expectedType, SubscriptionCriteria criteria, String database)
long create(SubscriptionCriteria criteria)
long create(SubscriptionCriteria criteria, String database)
<T> Subscription<T> open(Class<T> clazz, long id, SubscriptionConnectionOptions options) throws SubscriptionException
SubscriptionException
<T> Subscription<T> open(Class<T> clazz, long id, SubscriptionConnectionOptions options, String database) throws SubscriptionException
SubscriptionException
Subscription<RavenJObject> open(long id, SubscriptionConnectionOptions options) throws SubscriptionException
SubscriptionException
Subscription<RavenJObject> open(long id, SubscriptionConnectionOptions options, String database) throws SubscriptionException
SubscriptionException
List<SubscriptionConfig> getSubscriptions(int start, int take)
List<SubscriptionConfig> getSubscriptions(int start, int take, String database)
void delete(long id)
void delete(long id, String database)
void release(long id)
void release(long id, String database)
Copyright © 2016. All Rights Reserved.