Support class to perform receive operations with or without Fifo Grouping
If configured to use Fifo Grouping, the read/take operation will use FifoGroupingPoll / FifoGroupingPoll accordingly.
All the handlers that uses the Fifo Grouping capability should be used with a template that uses Fifo Grouping
All the handlers that uses the Fifo Grouping capability must be performed under a transaction
Declaration Syntax
C# | Visual Basic | Visual C++ | J# |
public abstract class FifoGroupingReceiveHandler<TData> : MemoryOnlySearchReceiveHandler<TData>
Public MustInherit Class FifoGroupingReceiveHandler(Of TData) _ Inherits MemoryOnlySearchReceiveHandler(Of TData)
generic<typename TData> public ref class FifoGroupingReceiveHandler abstract : public MemoryOnlySearchReceiveHandler<TData>
Generic Template Parameters
- TData
- Type of data to receive
Members
All Members | Constructors | Methods | Properties | ||
Icon | Member | Description |
---|---|---|
FifoGroupingReceiveHandler<(Of <(TData>)>)()()() | Initializes a new instance of the FifoGroupingReceiveHandler<(Of <(TData>)>) class | |
Equals(Object) | (Inherited from Object.) | |
Finalize()()() |
Allows an Object to attempt to free resources and perform other cleanup operations before the Object is reclaimed by garbage collection.
(Inherited from Object.) | |
GetHashCode()()() |
Serves as a hash function for a particular type.
(Inherited from Object.) | |
GetType()()() |
Gets the Type of the current instance.
(Inherited from Object.) | |
MemberwiseClone()()() |
Creates a shallow copy of the current Object.
(Inherited from Object.) | |
NonBlocking |
Gets or sets whether to perform the operation in a non blocking manner.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
NonBlockingFactor |
Gets or sets the non blocking factor if NonBlocking is true.
For instance if its value is 10 and the receive timeout of the operation is 1 seconds,
The operation will be executed 10 times with intervals of 100 miliseconds between each executions.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
Receive(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveBatch(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveBatchBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Executes receive operation logic in blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveBatchNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int32) |
Executes receive operation logic in non blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Executes receive operation logic in blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction) |
Executes receive operation logic in non blocking mode
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ToString()()() | (Inherited from Object.) | |
UseFifoGrouping |
Allows to configure the take/read operation to be performed in a Fifo Grouping manner.
If set to true, will use FifoGroupingPoll / FifoGroupingPoll as read/take modifiers.
| |
UseMemoryOnlySearch |
Allows to configure the take/read operation to be performed in a memory only search manner.
If set to true, will use MemoryOnlySearch / MemoryOnlySearch as read/take modifiers.
(Inherited from MemoryOnlySearchReceiveHandler<(Of <(TData>)>).) |
Inheritance Hierarchy
Object | ||||
NonBlockingReceiveHandler<(Of <(TData>)>) | ||||
MemoryOnlySearchReceiveHandler<(Of <(TData>)>) | ||||
FifoGroupingReceiveHandler<(Of <(TData>)>) | ||||
ExclusiveReadReceiveOperationHandler<(Of <(TData>)>) | ||||
TakeReceiveOperationHandler<(Of <(TData>)>) |