PreEmptive Analytics .NET API
1.3
|
Class that manages the offline storage of messages. More...
Inherits PreEmptive.Analytics.Common.MessageQueueProcessor, and PreEmptive.Analytics.Common.IQueuePersister.
Public Member Functions | |
OfflineStorageThread (IOfflineDataStore offlineDataStore, IFlowController flowController, IQueueTransmitter transmitterThread, IAttributeLimiter attributeLimiter, ILogger logger, IAsyncProvider asyncprovider) | |
Constructor for OfflineStorageThread. More... | |
override void | ProcessBatch (MessageBatch batch) |
Handles the transmission of a MessageBatch. More... | |
override MessageBatch | GetMessageBatch () |
Retrieves a saved MessageBatch. More... | |
void | SaveDataOffline (MessageBatch batch) |
Stores a MessageBatch for later transmission. More... | |
Additional Inherited Members | |
![]() | |
bool | Running [get, set] |
If the MessageQueueProcessor is currently running. More... | |
Class that manages the offline storage of messages.
PreEmptive.Analytics.Common.OfflineStorageThread.OfflineStorageThread | ( | IOfflineDataStore | offlineDataStore, |
IFlowController | flowController, | ||
IQueueTransmitter | transmitterThread, | ||
IAttributeLimiter | attributeLimiter, | ||
ILogger | logger, | ||
IAsyncProvider | asyncprovider | ||
) |
Constructor for OfflineStorageThread.
offlineDataStore | Interface that defines how offline messages should be stored. |
flowController | Interface that defines the behaior of the message queue. |
transmitterThread | TransmitterThread object that handles the sending of messages. |
attributeLimiter | The field size limits of the upstream server |
logger | An ILogger instance for reporting information about the offline storage thread. |
asyncprovider | The provider of the asynchronous execution functionality |
|
virtual |
Retrieves a saved MessageBatch.
Reimplemented from PreEmptive.Analytics.Common.MessageQueueProcessor.
|
virtual |
Handles the transmission of a MessageBatch.
batch | The MessageBatch object to process. |
Reimplemented from PreEmptive.Analytics.Common.MessageQueueProcessor.
void PreEmptive.Analytics.Common.OfflineStorageThread.SaveDataOffline | ( | MessageBatch | batch | ) |
Stores a MessageBatch for later transmission.
batch | The MessageBatch object to save. |
Implements PreEmptive.Analytics.Common.IQueuePersister.