{
"SubscriptionId": 37,
"AckEtag": "00000000-0000-0000-0000-000000000000",
"TimeOfLastClientActivity": "2016-10-25T12:59:28.7893865Z",
"TimeOfSendingLastBatch": "2016-10-25T12:59:19.0867674Z",
"Criteria": {
"KeyStartsWith": null,
"BelongsToAnyCollection": [
"Imports"
],
"PropertiesMatch": [],
"PropertiesNotMatch": [],
"StartEtag": null
},
"IsOpen": true,
"ConnectionOptions": {
"ConnectionId": "1051/6kNm2wsD0qH/4zJ7WOlakty",
"BatchOptions": {
"MaxSize": null,
"MaxDocCount": 4096,
"AcknowledgmentTimeout": "00:01:00"
},
"TimeToWaitBeforeConnectionRetry": "00:00:15",
"ClientAliveNotificationInterval": "00:02:00",
"PullingRequestTimeout": "00:05:00",
"IgnoreSubscribersErrors": true,
"Strategy": "OpenIfFree"
}
}
// Create subscription
Session.Advanced.DocumentStore.Subscriptions.Create(new SubscriptionCriteria<Import>
{
PropertiesMatch = new Dictionary<Expression<Func<Import, object>>, RavenJToken> { {x => x.IsImported, false} }}, Session.Advanced.GetDatabaseName());
// Above used GetDatabaseName extension method
public static string GetDatabaseName(this IAdvancedDocumentSessionOperations session){
return ((DocumentSession)session).DatabaseName;}
Hibernating Rhinos Ltd
Oren Eini l CEO l Mobile: + 972-52-548-6969
Office: +972-4-622-7811 l Fax: +972-153-4-622-7811
--
You received this message because you are subscribed to the Google Groups "RavenDB - 2nd generation document database" group.
To unsubscribe from this group and stop receiving emails from it, send an email to ravendb+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
2016-10-26 09:39:47.2017;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;Andes;127;Document with key 'Settings/DataSubscriptions/ImportCareProvider' was found, etag: 01000000-0000-0004-0000-00000009037A;2016-10-26 09:39:47.2017;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,024: GET - 0 ms - Andes - 304 - http://localhost:8080/databases/Andes/docs?id=Settings%2FDataSubscriptions%2FImportCareProvider;2016-10-26 09:39:47.2017;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;76;Request #28,025: POST - 3 ms - Andes - 200 - http://localhost:8080/databases/Andes/subscriptions/open?id=1&connection=3/6ffbDh3bSMB/-;2016-10-26 09:39:47.2173;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,026: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=watch-docs;2016-10-26 09:39:47.2329;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,027: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=watch-bulk-operation;2016-10-26 09:39:47.2329;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,028: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/subscriptions/pull?id=1&connection=3/6ffbDh3bSMB/-;2016-10-26 09:39:52.3525;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,029: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=unwatch-docs;2016-10-26 09:39:52.3681;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,030: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=unwatch-bulk-operation;2016-10-26 09:39:58.3985;Raven.Database.Impl.DocumentRetriever;Debug;;127;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore CareProviders/520941/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:39:58.3985;Raven.Database.Impl.DocumentRetriever;Debug;;127;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore UniqueConstraints/CareProviders/RizivNumber/52094146/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:09.0038;Raven.Database.Impl.DTC.InFlightTransactionalState;Info;Andes;170;Performing Transactions Cleanup Sequence for db Andes;2016-10-26 09:40:09.0038;Raven.Database.Impl.DTC.InFlightTransactionalState;Info;America;74;Performing Transactions Cleanup Sequence for db America;2016-10-26 09:40:10.2694;Raven.Database.Impl.DTC.InFlightTransactionalState;Info;<system>;59;Performing Transactions Cleanup Sequence for db <system>;2016-10-26 09:40:15.7322;Raven.Database.Impl.DocumentRetriever;Debug;;127;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore CareProviders/N36440/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:15.7322;Raven.Database.Impl.DocumentRetriever;Debug;;127;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore UniqueConstraints/CareProviders/RizivNumber/93644095/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:17.3103;Raven.Database.Server.Controllers.SubscriptionsController;Warn;;127;Subscription filtered out all possible documents for 30 seconds in a row, stopping operation;2016-10-26 09:40:17.3103;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,031: POST - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/subscriptions/close?id=1&connection=3/6ffbDh3bSMB/-;2016-10-26 09:40:28.6556;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;Andes;149;Document with key 'Settings/DataSubscriptions/ImportCareProvider' was found, etag: 01000000-0000-0004-0000-00000009037A;2016-10-26 09:40:28.6556;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,032: GET - 0 ms - Andes - 304 - http://localhost:8080/databases/Andes/docs?id=Settings%2FDataSubscriptions%2FImportCareProvider;2016-10-26 09:40:28.6556;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;142;Request #28,033: POST - 1 ms - Andes - 200 - http://localhost:8080/databases/Andes/subscriptions/open?id=1&connection=4/5sl7cNstuQq/614Jwqvdu7z;2016-10-26 09:40:28.6712;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,034: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=watch-docs;2016-10-26 09:40:28.6869;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,035: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=watch-bulk-operation;2016-10-26 09:40:28.7025;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,036: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/subscriptions/pull?id=1&connection=4/5sl7cNstuQq/614Jwqvdu7z;2016-10-26 09:40:28.7181;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,037: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=unwatch-docs;2016-10-26 09:40:28.7337;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;127;Request #28,038: GET - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/changes/config?id=1/6OuwhXvZejy/2R2dB6gJ7rA&command=unwatch-bulk-operation;2016-10-26 09:40:39.0049;Raven.Database.Impl.DTC.InFlightTransactionalState;Info;Andes;147;Performing Transactions Cleanup Sequence for db Andes;2016-10-26 09:40:39.0049;Raven.Database.Impl.DTC.InFlightTransactionalState;Info;America;142;Performing Transactions Cleanup Sequence for db America;2016-10-26 09:40:39.5683;Raven.Database.Impl.DocumentRetriever;Debug;;149;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore CareProviders/520941/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:39.5683;Raven.Database.Impl.DocumentRetriever;Debug;;149;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore UniqueConstraints/CareProviders/RizivNumber/52094146/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:40.2714;Raven.Database.Impl.DTC.InFlightTransactionalState;Info;<system>;155;Performing Transactions Cleanup Sequence for db <system>;2016-10-26 09:40:54.8533;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;;147;Document with key 'Raven/Replication/Destinations' was not found;2016-10-26 09:40:54.8533;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;;72;Document with key 'Raven/Replication/Destinations' was not found;2016-10-26 09:40:54.9314;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;;174;Document with key 'Raven/Replication/Destinations' was not found;2016-10-26 09:40:56.2696;Raven.Database.Impl.DocumentRetriever;Debug;;149;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore CareProviders/N36440/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:56.2696;Raven.Database.Impl.DocumentRetriever;Debug;;149;Trigger Raven.Bundles.Replication.Triggers.HideVirtuallyDeletedDocumentsReadTrigger asked us to ignore UniqueConstraints/CareProviders/RizivNumber/93644095/conflicts/c024e3df-cc14-4b14-9f61-092244fec6fd;2016-10-26 09:40:56.6603;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;;142;Document with key 'Raven/Replication/Destinations' was found, etag: 01000000-0000-0014-0000-000000000005;2016-10-26 09:40:56.6603;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;;72;Document with key 'Raven/Replication/Destinations' was found, etag: 01000000-0000-0014-0000-000000000005;2016-10-26 09:40:56.7071;Raven.Database.Storage.Esent.StorageActions.DocumentStorageActions;Debug;;74;Document with key 'Raven/Replication/Destinations' was found, etag: 01000000-0000-0014-0000-000000000005;2016-10-26 09:40:58.8366;Raven.Database.Server.Controllers.SubscriptionsController;Warn;;149;Subscription filtered out all possible documents for 30 seconds in a row, stopping operation;2016-10-26 09:40:58.8366;Raven.Database.Server.WebApi.RequestManager;Debug;Andes;149;Request #28,039: POST - 0 ms - Andes - 200 - http://localhost:8080/databases/Andes/subscriptions/close?id=1&connection=4/5sl7cNstuQq/614Jwqvdu7z;
using (var subscription = _importRepository.OpenDataSubscriptionForEntity(subscriptionId, true)) { using (subscription.Subscribe(_processCareProviderImportObserver)) { // Continue processing until a timeout period (> WaitTimeInSeconds) expires or until the job is interrupted while (!_processCareProviderImportObserver.IsIdle() && !IsInterrupted) { Thread.Sleep(500); } } }
Hibernating Rhinos Ltd
Oren Eini l CEO l Mobile: + 972-52-548-6969
Office: +972-4-622-7811 l Fax: +972-153-4-622-7811
--
Office: +972-4-622-7811 l Fax: +972-153-4-622-7811
RavenDB paving the way to "Data Made Simple" http://ravendb.net/
Hibernating Rhinos Ltd
Maxim Buryak l Core Team Developer l Mobile:+972-54-217-7751
Office: +972-4-622-7811 l Fax: +972-153-4-622-7811
RavenDB paving the way to "Data Made Simple" http://ravendb.net/
--
Hibernating Rhinos Ltd
Maxim Buryak l Core Team Developer l Mobile:+972-54-217-7751
Office: +972-4-622-7811 l Fax: +972-153-4-622-7811
RavenDB paving the way to "Data Made Simple" http://ravendb.net/