Class FlowMessagePersistence

Namespace

Crosser.EdgeNode.Flows

Assembly

Crosser.EdgeNode.Flows.dll

public class FlowMessagePersistence

Inheritance

object

FlowMessagePersistence

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

FlowMessagePersistence(FlowModule)

public FlowMessagePersistence(FlowModule module)

Parameters

module FlowModule

Methods

CreatePersistentMessage(IFlowMessage)

public Task<IResult> CreatePersistentMessage(IFlowMessage message)

Parameters

message IFlowMessage

Returns

Task<IResult>

DeleteFromStorage(Guid)

public Task<IResult> DeleteFromStorage(Guid messageId)

Parameters

messageId Guid

Returns

Task<IResult>

GetAllMessagesForModule()

public Task<IResult<IEnumerable<PersistentMessage>>> GetAllMessagesForModule()

Returns

Task<IResult<IEnumerable<PersistentMessage>>>

TryAgain(Guid)

public Task<FlowMessageRetry> TryAgain(Guid messageId)

Parameters

messageId Guid

Returns

Task<FlowMessageRetry>