Interface IPoisonQueue

Namespace

Sportradar.LiveData.Sdk.Common.Interfaces

Assembly

Sportradar.LiveData.Sdk.dll

Poison queue interface

public interface IPoisonQueue

Properties

ProviderType

Poison queue must be assigned a to particular feed provider.

ProtocolProviderType ProviderType { get; }

Property Value

ProtocolProviderType

Methods

Enqueue(PoisonQueueElt)

Enqueue a new poison element. Throws PoisonQueueException if there is already poison elements for the same match enqueued.

void Enqueue(PoisonQueueElt obj)

Parameters

obj PoisonQueueElt

Poison element

IsMatchPoisonous(IList<long>)

Checks whether there is a poison element linked to this match

bool IsMatchPoisonous(IList<long> match_ids)

Parameters

match_ids IList<long>

Match ids

Returns

bool

Returns true if there is a poison element linked to this match

WaitForElementRemoved(TimeSpan)

Waits until an element is removed (promoted or deceased) from the poison queue.

bool WaitForElementRemoved(TimeSpan wait_timeout)

Parameters

wait_timeout TimeSpan

Wait timeout

Returns

bool

True if the wait was successful or false if the timeout occurred.

Events

OnPoisonQueueEltDead

Event raised whenever an element is to be dumped into dead letter queue.

event PoisonQueueDelegates.PoisonQueueEltDead OnPoisonQueueEltDead

Event Type

PoisonQueueDelegates.PoisonQueueEltDead

OnPoisonQueueEltPromoted

Event raised whenever an element is promoted from Poison queue and moved back into Main queue.

event PoisonQueueDelegates.PoisonQueueEltPromoted OnPoisonQueueEltPromoted

Event Type

PoisonQueueDelegates.PoisonQueueEltPromoted