Contains classes and types which simplify processing events from the space using polling.
Declaration Syntax
C# | Visual Basic | Visual C++ | J# |
namespace GigaSpaces.XAP.Events.Polling
Namespace GigaSpaces.XAP.Events.Polling
namespace GigaSpaces.XAP.Events.Polling
package GigaSpaces.XAP.Events.Polling
Types
All Types | Classes | Interfaces | Delegates |
Icon | Type | Description |
---|---|---|
DynamicEventTemplateAttribute |
Marks a method that returns the DynamicTemplate.
| |
DynamicEventTemplateProvider<(Of <(T>)>) |
Delegate which is used as a dynamic template provider.
| |
IPollingEventListenerContainerServiceDetails |
A PollingEventListenerContainer<(Of <(TData>)>) service details.
| |
IPollingEventListenerContainerServiceMonitors |
A PollingEventListenerContainer<(Of <(TData>)>) service monitors.
| |
PollingEventDrivenAttribute |
Used by CreateContainer<(Of <(TData>)>)(ISpaceProxy, Object) operation to create a PollingEventListenerContainer<(Of <(TData>)>) that will use
the marked class for event listening.
| |
PollingEventListenerContainer<(Of <(TData>)>) |
Event listener container that uses a receive operation handler to poll for events and allows to subscribe to DataEventArrived that will be triggered
by a successfull receive operation, Usally used in conjuction with the
Take<(Of <(T>)>)(T, ITransaction, Int64) API. This container also allow for transactional
reception of messages.
Event reception and listener execution can automatically be wrapped in transactions through
passing an ITransactionManager into the TransactionManager property.
Actual event listener execution happens in a concurrent asynchronous manner, initially MinConcurrentConsumers consumers will be created.
Dynamic scaling of the number of concurrent consumers can be activated through specifying a MaxConcurrentConsumers value that is higher than the
MinConcurrentConsumers value. The scale is done both ways, scale up when necessary and scale down
when some of the invokers are idle. A consumer is considered idle when IdleIterationsThreshold cycles has passed and it didn't
trigger any event, the scaling rate is determined by DynamicScaleSampleRate property, its specifies the rate in which
to sample the load of the concurrent consumers for scaling up or down.
Note:Using more than one consumer might break fifo behaviour if fifo is configured by the space or the specific class type,
however, this is not take case when using Fifo Grouping. | |
ReceiveHandlerAttribute |
Marks a field, property or a method that represents the IReceiveOperationHandler<(Of <(TData>)>) of the PollingEventListenerContainer<(Of <(TData>)>).
| |
TriggerHandlerAttribute |
Marks a field, property or a method that represents the ITriggerOperationHandler<(Of <(TData>)>) of the PollingEventListenerContainer<(Of <(TData>)>).
|