Skip to content
danielHalan edited this page Feb 16, 2013 · 10 revisions

Initialize

Called once to initialize the manager

    void Initialize(string serverName, Queue[] monitorQueues);

MessageContentFormat

Property that describes what type of message content to expect in queues.

    MessageContentFormat MessageContentFormat { get; }

Current supported message contents,

    public enum MessageContentFormat  { Xml, Json, Other=0xFF }

LoadMessageContent

Load message content if not already loaded

    string LoadMessageContent(QueueItem itm);

GetUnprocessedMessages

Return new unprocessed messages that are in queue(s) of specified type **CurrentItems **contains already fetched items, that doesn't need to be return.

    public IEnumerable<QueueItem> GetUnprocessedMessages(QueueType type, IEnumerable<QueueItem> currentItems);

GetProcessedMessages

Return new processed messages that are in queue(s) of specified type **CurrentItems **contains already fetched items, that doesn't need to be return.

    IEnumerable<QueueItem> GetProcessedMessages(QueueType type, DateTime since, IEnumerable<QueueItem> currentItems);

MoveErrorMessageToOriginQueue

MoveAllErrorMessagesToOriginQueue

PurgeMessage

PurgeAllMessages

PurgeErrorMessages

PurgeErrorAllMessages

MonitorQueues

ItemsChanged

ErrorOccured

Clone this wiki locally