|
GigaSpaces - Open Spaces | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
SQLQuery.
SpaceDataEventListener based containers.FilterProvider allowing to construct a
filter provider that can be used to provide pre initialized ISpaceFilter
implementation including its different aspects to an embedded space.PlatformTransactionManager.IJSpace.ScrollableResults created based on either an
entity name or a SQLQuery.SQLQuery.
SQLQuery.
IJSpace
implementation.GigaSpace.execute(org.openspaces.core.executor.Task).
GigaSpace.execute(org.openspaces.core.executor.Task).
GigaSpace.execute(org.openspaces.core.executor.Task, Object).
GigaSpace.execute(org.openspaces.core.executor.DistributedTask, Object[])
GigaSpace.execute(org.openspaces.core.executor.DistributedTask)
Resource
abstraction.
PathMatchingResourcePatternResolver.
Resource
abstraction.
PathMatchingResourcePatternResolver.
PathMatchingResourcePatternResolver.
GigaSpace instance using the
DefaultGigaSpace implementation.
AbstractSpaceFactoryBean.doCreateSpace().
IJSpace based on the master local cache set using
AbstractLocalCacheSpaceFactoryBean.setSpace(IJSpace) and a set of properties driving the actual local cache type based
on AbstractLocalCacheSpaceFactoryBean.createCacheProeprties().
AbstractSpaceListeningContainer.validateConfiguration() and AbstractSpaceListeningContainer.initialize().
SpaceDataEvent annotation in order to find event
listener methods to delegate to.FilterProvider factory that accepts
a Pojo filter with annotation markers as to which filter operation to listen to.ModeAnnotationRegistry and ModeAnnotationRegistryPostProcessor.ServletContext key under which the ApplicationContext
(loaded from the pu.xml) is stored.
ApplicationContext.AsyncOperationHandler to be used
with an async polling container.SimpleAsyncPollingEventListenerContainer.AsyncPolling annotation post processor.AsyncSpaceRemotingProxyFactoryBean
into a field.AsyncSpaceRemotingProxyFactoryBean.GigaSpace.asyncRead(Object) under exclusive
read lock.
GigaSpace.asyncRead(Object).
GigaSpace.asyncTake(Object).
Future that wras an already arrived
AsyncResult.ScriptingExecutor remoting proxy using
AsyncSpaceRemotingProxyFactoryBean.ScriptingExecutor proxy
AsyncScriptingProxyConfigurer on top of the given space
T
into a result R.Task to delegate
the actual execution to and implements the AvgTask.reduce(java.util.List) operation.ServletContext key under which the BeanLevelProperties
is stored.
mergedProperties and the bean name
that the bean implementing this interface is associated with.Properties that contains the bean level
merged properties.BeanLevelProperties.BeanLevelProperties.BeanLevelProperties parser that parses -properties
parameter(s) and transforms it into bean level properties.BeanPostProcessor that process beans that implement
BeanLevelPropertiesAware or BeanLevelMergedPropertiesAware based on the provided
BeanLevelProperties.PropertyPlaceholderConfigurer that works with
BeanLevelProperties in order to inject bean level properties.BeanPropertyMonitor.ExistingJiniTransactionManager.bindExistingTransaction(net.jini.core.transaction.Transaction, boolean, boolean) with
rollback and commit flags set to true (disabled).
Transaction, which means that any operation under
the current thread by GigaSpace will be performed under it.
BlockingQueue script pool with a configurable size.BlockingQueueCompiledScriptPool.5.
IteratorBuilder.bufferSize(int)
and defaults to 100.
SimpleMapCache.
TransactionalMapCache.
BulkDataPersister execution
and calls the provided ExceptionHandler in case of exceptions.Callable in a distributed fashion.Callable using Space task executors.call.
IJSpace can not be created.IJSpace can not be found (when using jini/rmi protocol).Number into the type the number helper handles.
closeMethod is supplied, will invoke it.
ServletContext key under which the ClusterInfo
is stored.
ClusterInfo.BeanPostProcessor that takes a ClusterInfo and injects it to all the
beans that implements ClusterInfoAware interface and to those that contain a field that
has the annotation ClusterInfoContext}.ClusterInfo.ClusterInfo parser that parses -cluster parameter and
transforms it into a cluster info.ClusterInfo parameters as injected
properties that can be used within Spring application context.CommandLineParser.Parameter arguments.CompiledScriptCache.CompiledScriptPool instance.ScriptingExecutor and uses
Script.getRouting() in order to compute the routing index.
ApplicationContextProcessingUnitContainerProvider.addConfigLocation(String).SpaceModeContextLoader.CpuRequirement.BlockingQueueCompiledScriptPool
with the configured size.
CompiledScriptPool.
BeanPostProcessors.
BeanPostProcessors.
SpaceURL.LOCAL_CACHE_UPDATE_MODE based
on either localCacheUpdateMode or
localCacheUpdateModeName.
LocalViewSpaceFactoryBean.setLocalViews(java.util.List) locaViews}.
IntegratedProcessingUnitContainer based on the configured parameters.
StandaloneProcessingUnitContainer based on the configured parameters.
ProcessingUnitContextLoader.
DataEventSession based on the provided factory.
EventSessionConfig based on the different
parameters this container accepts.
ConcurrentMultiDataIterator
with the provided AbstractHibernateExternalDataSource.setInitialLoadThreadPoolSize(int) thread pool size.
IMap based on the configuration.
WebApplicationContext - ProcessingUnitWebApplicationContext.
DataProvider
(not needed by default).SpaceDriverManagerDataSource.BasicDataSource from jakarta commons dbcp
that uses a space to provide with a pooled data source implementation.handleEvent.
DefaultListQueryDataIterator
for each chunk.SQLQuery.
DefaultScrollableDataIterator
for each chunk.SQLQuery.
GigaMap interface simplifying the work with
JCache and Map interface on top of the Space.GigaSpace.SQLQuery by creating
an Hiberante query using Hibernate Session and listing it.IReplicationFilter.Session.SQLQuery.
SQLQuery.
ExecutorService that uses the executors support
implemented in GigaSpace.JiniPlatformTransactionManager
and one of its derived classes.AbstractSpaceFactoryBean.destroy().
AbstractSpaceListeningContainer.shutdown() when the BeanFactory destroys the container instance.
PlatformTransactionManager
using directly injected Jini TransactionManager.IJSpace and provides it as the
space.DistributedJiniTransactionManager.Task that is executed on
several space nodes, requiring to AsyncResultsReducer.reduce(java.util.List) the list of
AsyncResults.DistributedJiniTransactionManager.IJSpace implementation.
UrlSpaceFactoryBean.doGetSpaceUrls() and then using the returned
SpaceURL a space is found using SpaceFinder.find(SpaceURL).
TransactionManager.
TransactionManager provided using the
DirectJiniTransactionManager.setTransactionManager(TransactionManager).
LocalTransactionManager using the provided
LocalJiniTransactionManager.setSpace(com.j_spaces.core.IJSpace).
TransactionManager that is lookup up using
JiniServiceFactoryBean.
OnFilterClose.
MethodFilterFactoryBean.setFilterClose(String).
FilterProvider using
FilterOperationDelegate as the ISpaceFilter
implementation.
filter and operation
codes.
OnFilterInit.
MethodFilterFactoryBean.setFilterInit(String).
AbstractFilterProviderFactoryBean.getFilter()
delegate and its annotated methods.
AbstractFilterProviderFactoryBean.getFilter()
delegate and the callbacks set on this factory.
SpaceDataEvent annotation.
MethodEventListenerAdapter.setMethodName(String).
SpaceURLParser and returns the parsed
SpaceURL.
GigaSpace.read(Object,long)
under an exclusive read lock.
GigaSpace.readMultiple(Object,int)
using the provided template and configured maxEntries (defaults to 50).
GigaSpace.readMultiple(Object,int)
using the provided template and configured maxEntries (defaults to 50).
GigaSpace.takeMultiple(Object,int)
using the provided template and configured maxEntries (defaults to 50).
GigaSpace.read(Object,long) with the
given timeout.
GigaSpace.take(Object, long) with
the given timeout.
GigaSpace.read(Object,long)
under an exclusive read lock with no timeout.
GigaSpace.readMultiple(Object,int)
using the provided template and configured maxEntries (defaults to 50).
GigaSpace.readMultiple(Object,int)
using the provided template and configured maxEntries (defaults to 50).
GigaSpace.takeMultiple(Object, int).
GigaSpace.read(Object,long) with no
timeout.
GigaSpace.take(Object, long) with
no timeout.
update, readIfExist or
takeIfExist operations are rejected.DataAccessException runtime
exception.GigaSpace.asyncRead(Object) under exclusive
read lock.GigaSpace.read(Object,long)
under an exclusive read lock.Callable.call().
Runnable.run() and returns the optional result
provided in the constructor.
Session.
StatelessSession.
AbstractSpaceListeningContainer.isRunning().
ExecutorSpaceRemotingProxyFactoryBean
into a field.ExecutorSpaceRemotingProxyFactoryBean.Task that can be used to simulate remote invcation with
SpaceRemotingServiceExporter.ScriptingExecutor remoting proxy using
ExecutorSpaceRemotingProxyFactoryBean.Transaction so it
will be automatically picked up by operations perfomed using GigaSpace.ISpaceFilter implementation that acts as an adapter
delegating the execution of the filter lifecycle methods and specific operation to pluggable
reflection based methods.FilterProvider implementation.Annotation of annotationType from the
supplied Method, traversing its super methods if no annotation
can be found on the given method itself.
Annotation of annotationType from the
supplied Class, traversing its interfaces and super classes
if no annotation can be found on the given class itself.
Class in the inheritance hierarchy of the
specified clazz (including the specified
clazz itself) which declares an annotation for the
specified annotationType, or null if not
found.
AfterSpaceModeChangeEvent events with space mode SpaceMode.BACKUP to all beans in the application context
that implement the SpaceAfterBackupListener interface.
AfterSpaceModeChangeEvent events with space mode SpaceMode.PRIMARY to all beans in the application context
that implement the SpaceAfterPrimaryListener interface.
BeforeSpaceModeChangeEvent events with space mode SpaceMode.BACKUP to all beans in the application context
that implement the SpaceBeforeBackupListener interface.
BeforeSpaceModeChangeEvent events with space mode SpaceMode.PRIMARY to all beans in the application context
that implement the SpaceBeforePrimaryListener interface.
key in this cache.
key in this cache.
Annotation of annotationType from the
supplied Method.
Annotations from the supplied Method.
GigaSpace is this is a GigaSpace
that worked directly against a cluster member.
pu.xml) during web application
startup.
TransactionDefinition.getIsolationLevel() values).
"value" attribute of a single-element
Annotation, given an annotation instance.
"value" attribute of a single-element
Annotation, given the annotation type.
annotation type.
WebsterFile
over the given URL.
FilterProvider.
SpaceRemotingServiceExporter.RemotingServiceInvoker
filter for sync remote service execution.
ManagedDataSource.initialLoad() operation.
null.
SpaceURL.UPDATE_MODE_PULL (1) each update triggers an
invalidation event at every cache instance.
JeePUServiceDetails.getDescription().
IMap used by this GigaMap implementation to delegate
different space operations.
Policy.setHigh(double) and
Policy.setLow(double)).
NumberHelper implemenations
based on the provided Number type (such as Integer or Float).
GigaMap implementation constructed in
the GigaMapFactoryBean.afterPropertiesSet() phase.
GigaSpace implementation constructed in
the GigaSpaceFactoryBean.afterPropertiesSet() phase.
IJSpace created during the bean initialization
(AbstractSpaceFactoryBean.afterPropertiesSet()).
IJSpace that is the local cache wrapping the
master proxy set using AbstractLocalCacheSpaceFactoryBean.setSpace(com.j_spaces.core.IJSpace).
PUPathMatchingResourcePatternResolver
which allows to perform path mathcing over a remote processing unit.
ClusterInfo.getRunningNumber() + 1.
ResourceLazyLoadingScript.loadScript().
IJSpace used by this GigaSpace implementation to delegate
different space operations.
"value"
attribute of a single-element Annotation, given an annotation instance.
IMap and
Cache implementation.GigaMap instance if non already created.
GigaMapFactoryBean.GigaMap instance wrapping
the GigaMapFactoryBean.JavaSpace and GigaSpaces IJSpace extension
utilizing GigaSpaces extended and simplified programming model.GigaSpace instance if non already created.
GigaSpaceFactoryBean.GigaSpace instance wrapping
the GigaSpaceFactoryBean.ConnectionFactory based on a Space instance.GigaSpaceConnectionFactory.GigaSpace implementation into a class field or setter
property.GigaSpaceContextBeanPostProcessor.GigaSpaceContext in order to inject
GigaSpaceContext instances using annotations.GigaSpace implementation.GigaSpace implementation into a class field or setter
property.GigaSpaceContextBeanPostProcessor.GSQueueImpl based on
a queue name.GigaSpaceQueue.GSTopicImpl based on
a topic name.GigaSpaceTopic.XAConnectionFactory based on a Space instance.GigaSpaceXAConnectionFactory.null) under the configured write
lease.
true if there are properties associated with the given bean name.
true if there is a lease renewal manager associated with this transaction
true if the script has been loaded.
true if the script has been loaded.
true if there is an existing transaction held by this bean,
false if no transaction is in progress.
HostRequirement.AvgTask.reduce(java.util.List) to ignore failed invocations.
MaxTask.reduce(java.util.List) to ignore failed invocations.
MinTask.reduce(java.util.List) to ignore failed invocations.
SumTask.reduce(java.util.List) to ignore failed invocations.
initMethod is supplied, will invoke it.
ManagedDataSource.init(java.util.Properties)
on them.
DataIterators
from ManagedDataSource.initialLoad().
ApplicationContext.ApplicationContext.
IntegratedProcessingUnitContainer provider.DistributedSpaceTask that wraps the actual Task
to be executed.GigaSpaceInternalSpaceException.SpaceTask that wraps the actual Task
to be executed.SpaceDataEventListener based on the
provided data.
true if the member is alive or not.
true if the member is alive or not.
annotationType
is declared locally on the supplied clazz.
annotationType
is present on the supplied clazz and is
inherited
(i.e., not declared locally for the class).
BACKUP.
true when batching is enabled.
true if this task was cancelled before it completed
normally.
true if this task completed.
true if this transaction provider is enabled or not.
true if this class defined as FIFO, otherwise false.
true if the application context initialized successfully.
true if the given key is locked.
true if the given key is locked.
AbstractHibernateExternalDataSource.getManagedEntries() list.
AbstractSpaceFactoryBean.setEnableMemberAliveIndicator(Boolean) flag.
NONE, in other words - unknown.
PRIMARY.
true if the Space uses a remote protocol.
true if the url points at a remote protocol.
true if the url points at a remote protocol.
true if this runnable is currently running.
true if this web service is running on a shared instance of a
web container.
true as this is a singleton.
true as this is a singleton.
true since this factory is a singleton.
true since this bean is a singleton.
true if the same compiled script can be used by different threads (note, parameres
or bindings usually make a scripting library not thread safe).
TriggerOperationHandler.triggerReceive(Object,org.openspaces.core.GigaSpace,long) will be used as the
template for the receive operation by returning true.
GSIterator based on the builder
configuration.
GSIterator
over the Space.
DefaultListQueryDataIterator for the
given sql query.
StatelessListQueryDataIterator for the given
query.
GSIterator.jdbc namespace.ApplicationContextProcessingUnitContainer
that can handle JEE processing units.ApplicationContextProcessingUnitContainerProvider
that can handle JEE processing units.SessionData that is written to the Space.
JeeProcessingUnitContainerProvider that
can run web applications (war files) using Jetty.JettyHolder.PlatformTransactionManager that
holds the Jini transactional context.jms namespace.LazyLoadingScripts.JeeProcessingUnitContainerProvider.APPLICATION_CONTEXT_CONTEXT
within the servlet context.
LocalCacheSpaceFactoryBean.IJSpace local cache.PlatformTransactionManager
using GigaSpaces LocalJiniTransactionManager.LocalJiniTransactionManager.LocalJiniTransactionManager.LocalViewSpaceFactoryBean.IJSpace local view.IMap and supports the ability to lock and unlock
certain keys within the map.IMap.
PlatformTransactionManager
using Jini in order to lookup the transaction manager based on a name (can have null
value).LookupJiniTransactionManager.LookupJiniTransactionManager.ManagedDataSource that can provide a list
of all the given entries this managed data source handles.IMap based on the configuration.
IMap based on an IJSpace.IMap factories.T.Task to delegate
the actual execution to and implements the MaxTask.reduce(java.util.List) operation.MemoryRequirement.MethodEventListenerAdapter.setMethodName(String) that the event will be delegated to.FilterProvider factory that accepts
a Pojo filter with different operation callbacks that are marked using this factory.T.Task to delegate
the actual execution to and implements the MinTask.reduce(java.util.List) operation.PreBackup, PostBackup, PrePrimary
and PostPrimary and registers them in the ModeAnnotationRegistry.DataIterator
which handles multiple data iterators.GigaSpace.readMultiple(Object,int) using
the provided template and configured maxEntries (defaults to 50).GigaSpace.readMultiple(Object,int) using
the provided template and configured maxEntries (defaults to 50).GigaSpace.takeMultiple(Object,int) using
the provided template and configured maxEntries (defaults to 50).DefaultTaskExecutorService which is an executor
service that can execute tasks on top of the Space.
Notify annotation post processor.true to AbstractNotifyEventListenerContainer.setAutoRenew(boolean).Number implementation allowing
to use it in a generalized fashion.NumberHelper implemenations
based on the provided Number type (such as Integer or Float).SpaceMode.BACKUP.
SpaceMode.PRIMARY.
ContextRefreshedEvent is raised will send two extra events:
BeforeSpaceModeChangeEvent and AfterSpaceModeChangeEvent with the current
space mode.
SpaceModeContextLoader.setActiveWhenPrimary(boolean) is set to true (the default) will
listens for AfterSpaceModeChangeEvent and load an application context if received.
AbstractSpaceListeningContainer.setActiveWhenPrimary(boolean) is set to true (the default),
the container lifecycle will be controlled by the space mode.
SpaceMode.BACKUP.
SpaceMode.PRIMARY.
SpaceDataEventListener by delegating to
AbstractResultEventListenerAdapter.onEventWithResult(Object,org.openspaces.core.GigaSpace,org.springframework.transaction.TransactionStatus,Object)
and writing the result back to the space (if it is not null) using
AbstractResultEventListenerAdapter.handleResult(Object,org.openspaces.core.GigaSpace).
TaskExecutorEventListenerAdapter.setDelegate(org.openspaces.events.SpaceDataEventListener)
to be executed using the provided TaskExecutorEventListenerAdapter.setTaskExecutor(org.springframework.core.task.TaskExecutor).
AsyncSpaceRemotingEntry which holds all the relevant
invocation information.
AbstractReflectionEventListenerAdapter.setDelegate(Object).
OpenSpaces namespace.OpenSpacesMessageDispatcher is responsible for sending messages to GigaSpaces space.OpenSpacesMessageDispatcher for each unique endpoint.OpenSpacesMessageReceiver is used to receive data from an GigaSpaces's space. OpenSpacesMuleContextLoader used for loading Mule configuration that refrenced from PU configuration
file.ApplicationContextProcessingUnitContainerProvider.addConfigLocation(String).
Policy.setMonitor(String))
breaches the policy thresholds.Polling annotation post processor.SpaceMode.BACKUP.SpaceMode.PRIMARY.SpaceMode.BACKUP.SpaceMode.PRIMARY.FilterOperationDelegateInvoker based on the operation
code.
FilterOperationDelegateInvoker based on the operation
code.
ProcessingUnitContainer.ContextLoader.ContextLoaderListener excepts in creating
a {link ProcessingUnitContextLoader.XmlWebApplicationContext allowing to
dynamically add (during construction) a BeanPostProcessor.Task allowing to return
additional objects to be processed on the node the task is executed.ApplicationEventPublisher.publishEvent(org.springframework.context.ApplicationEvent)
which will create a recursive event calling.
value to the cache with specified key for
timeToLive milliseconds to live in the cache.
value to the cache with specified key.
value to the cache with specified key for
timeToLive milliseconds to live in the cache.
RangeRequirement.null if
there currently is none.
null if
there currently is none.
null if
there currently is none.
null if
there currently is none.
null if
there currently is none.
null if
there currently is none.
ReceiveOperationHandler to be used
with a polling container.AbstractPollingEventListenerContainer.SumReducer.
SumReducer.
SumReducer.
SumReducer.
SpaceModeContextLoader.Polling or Notify.DataEventSession and
based on different parameters set on this container.
RelocationPolicy.RemoteException that is thrown from the Space.SyncSpaceRemotingProxyFactoryBean in
broadcast mode in order to reduce the broadcast results into a "client
side" result value.RemotingAnnotationBeanPostProcessor.key from this cache.
key from this cache.
ReplicationFilterProvider.ApplicationContext implementation that works with
Spring Resource for config locations.null).
ApplicationContext based on the
configured list of config locations.
Runnable in a distributed fashion.Runnable using Space task executors.run.
run.
ScaleUpPolicy.Script using remoting.Script.getRouting() in order to
computer the routing index.BACKUP mode.
PRIMARY mode.
ApplicationContextAware.
IWorker.init(com.j_spaces.core.IJSpace, String, String)
(the last argument).
AbstractNotifyEventListenerContainer.setListenerLease(long) is set, automatically performs lease renewal.
BeanLevelProperties.
BeanLevelProperties to the newly created application context.
BeanLevelProperties.
BeanLevelProperties that will be used to
configure this processing unit.
BeanLevelProperties that will be used to
configure this processing unit.
BeanLevelProperties that will be used to
configure this processing unit.
BeanNameAware.
true (defaults to false) causes the remote invocation
to be called on all active (primary) cluster memebers.
true (defaults to false) causes the remote invocation
to be called on all active (primary) cluster memebers.
GigaSpace will work with a clustered
view of the space or directly with a cluster member.
IMap will work with a clustered
view of the space or directly with a cluster member.
ClusterInfo to the newly created application context.
ClusterInfoAware.
ClusterInfo that will be used to configure this
processing unit.
ClusterInfo that will be used to configure this
processing unit.
ClusterInfo that will be used to configure this
processing unit.
AbstractNotifyEventListenerContainer.setComTypeName(String).
DefaultGigaSpace.read(Object) or
DefaultGigaSpace.readIfExists(Object) operations.
GigaSpace.read(Object) and
GigaSpace.readIfExists(Object) operations.
DefaultGigaSpace.take(Object) or
DefaultGigaSpace.takeIfExists(Object) operations.
GigaSpace.take(Object) and
GigaSpace.takeIfExists(Object) operations.
Map.get(Object) or
Map.remove(Object).
DefaultGigaSpace.write(Object).
GigaSpace.write(Object) operation.
GigaMap.
GigaSpace.
AsyncSpaceRemotingEntry)
to be fifo.
ISpaceFilter.
GigaSpace that will be used to pass an IJSpace
instance to the worker init method.
IJSpace
from.
IJSpace
from.
AsyncSpaceRemotingEntry.
true (defaults to false) all of the service methods
will be invoked and the proxy will not wait for a return value.
true (defaults to false) all of the service methods
will be invoked and the proxy will not wait for a return value.
true, will not propagate the event if the take operation returned
null.
ManagedDataSource.initialLoad() operation.
ConcurrentMultiDataIterator.
SessionData that is written to the Space.
AbstractNotifyEventListenerContainer.setAutoRenew(boolean) is set to true sets the lease listener for
it.
GigaMap.
mergedProperties and the bean
name that the bean implementing this interface is associated with.
SpaceRemotingInvocation.getMetaArguments().
SpaceRemotingInvocation.getMetaArguments().
SpaceRemotingInvocation.getMetaArguments().
true it will allow the space to connect to
the Mirror service to push its data and operations for asynchronous persistency.
Policy.setHigh(double) and
Policy.setLow(double)).
true - Lease object would not return from the write/writeMultiple
operations.
IJSpace will be created with.
ApplicationContext that will be used
when constructing this processing unit application context.
ApplicationContext that will be used
when constructing this processing unit application context.
Object[] to
the listener.
true will pass an array value returned from a
ReceiveOperationHandler
directly to the listener without "serializing" it as one array element
each time.
true will perform snapshot operation on the provided template
before invoking registering as an event listener.
true will remove the event from the space using take operation.
parameters just with properties for simpler
configuration.
RemoteInvocationAspect
which can be set using AsyncSpaceRemotingProxyFactoryBean.setRemoteInvocationAspect(RemoteInvocationAspect).
RemoteInvocationAspect
which can be set using ExecutorSpaceRemotingProxyFactoryBean.setRemoteInvocationAspect(org.openspaces.remoting.RemoteInvocationAspect).
RemoteInvocationAspect
which can be set using SyncSpaceRemotingProxyFactoryBean.setRemoteInvocationAspect(RemoteInvocationAspect).
true, allows to plug a custom reducer that can
reduce the array of result objects into another response object.
true, allows to plug a custom reducer that can
reduce the array of result objects into another response object.
AsyncSpaceRemotingEntry class).
SyncSpaceRemotingEntry class).
SyncSpaceRemotingEntry class).
true (defaults to true) will return the first result
when using broadcast.
true (defaults to true) will return the first result
when using broadcast.
GigaSpace.
delegate listener.
TaskExecutor to use for running the
listener threads.
TransactionManager to be used.
PlatformTransactionManager to use
for transactional wrapping of listener execution.
triggerOperationHandler which mainly makes sense when using
transactions.
GigaMap.
GigaSpace.
SpaceURL.UPDATE_MODE_PULL (1) each update triggers an
invalidation event at every cache instance.
SpaceURL.UPDATE_MODE_PULL (1) each update triggers an
invalidation event at every cache instance.
localCacheUpdateMode.
localCacheUpdateMode.
AbstractResultEventListenerAdapter.setUpdateOrWrite(boolean) is set to
true.
IJSpace will be created with.
true, will use Hiberante merge to perform the create/update, and will
merge before calling delete.
ReadTriggerOperationHandler.triggerReceive(Object,org.openspaces.core.GigaSpace,long) will be used as the
template for the receive operation by returning true.
false, optimistic lock is disabled.
true (defaults to false) service methods that return
void will be invoked and the proxy will not wait for a return value.
true (defaults to false) service methods that return
void will be invoked and the proxy will not wait for a return value.
ThreadPool that shares a single instance of a therad pool.true if broadcast should be enabled or not.
AbstractSpaceListeningContainer.doShutdown(), and close this container.
SimpleAsyncPollingEventListenerContainer.GigaSpace.asyncTake(Object) in order to simulate events
(optionally transactional).GigaMap
that works with no transactions.GigaMap
interface.SimpleMapCache to provide
second level cache implementation which is not transactional.SimpleNotifyEventListenerContainer.SpaceDataEventListener that will be triggered by notifications.SimplePollingEventListenerContainer.GigaSpace.take(Object,long) calls that also allow for transactional
reception of messages.GigaSpace.asyncRead(Object).GigaSpace.read(Object,long).GigaSpace.asyncTake(Object).GigaSpace.take(Object,long).SLA.sla namespace.AbstractSpaceFactoryBean.afterPropertiesSet().
SpaceMode.BACKUP.SpaceMode.PRIMARY.SpaceMode.BACKUP.SpaceMode.PRIMARY.DataSource based on a space.FilterProvider factory that accepts
a concrete ISpaceFilter implementation
in addition to all the operation codes it will listen to.PRIMARY mode.ProcessingUnitContainer can implement to provide
spaces that it is using.ExecutionException holding both the
remoteInvocation and the
remoteResult remote result.DefaultReplicationFilterProviderFactory.IJSpace utilites.SQLQueryFactoryBean.SQLQuery so namespace based
configuration will be simpler.BeanLevelProperties,
ClusterInfo, and a list of config locations).StandaloneProcessingUnitContainer provider.StandaloneProcessingUnitContainer provider.StatelessListQueryDataIterator
for each chunk.SQLQuery.
StatelessScrollableDataIterator
for each chunk.SQLQuery.
StatelessSession.SQLQuery by creating
an Hiberante query using Hibernate StatelessSession and listing it.StatelessSession.SQLQuery.
SQLQuery.
Resource and ResourceLoader to load
a given script (for example, from the classpath).T
into a result R.Task to delegate
the actual execution to and implements the SumTask.reduce(java.util.List) operation.SyncSpaceRemotingProxyFactoryBean
into a field.SyncSpaceRemotingProxyFactoryBean.ScriptingExecutor remoting proxy using
SyncSpaceRemotingProxyFactoryBean.ScriptingExecutor proxy
SystemRequirement.call.
run.
run.
SpaceDataEventListener
to Spring TaskExecutor implementation (usually to be executed in a different thread).ExecutorService.GigaSpace allowing for
Task to be injected with the space it is executed on.Task can implement this method to be injected with
the Space they are executed on.Task routing.TransactionalAsyncFutureListener.onTransactionalResult(com.gigaspaces.async.AsyncResult, org.springframework.transaction.TransactionStatus)
after the AsyncFutureListener.onResult(com.gigaspaces.async.AsyncResult).Polling
or Notify as transactional.GigaMap.GigaMap
interface.AbstractJiniTransactionManager and its different sub-classes.DataAccessException runtime exception.
TriggerOperationHandler to be used
with a polling container.GigaSpace.read(Object,long) and returns its result.
DataAccessException subclasses or one of our own subclasses.Polling or Notify.Modifiers.NONE).
UrlSpaceFactoryBean.IJSpace instances.IJSpace) based on a url.View so namespace based
configuration will be simpler.WaitForAllListener.waitForResult().WaitForAnyListener.waitForResult().IWorker implementations
as beans providing the same behavior when configured within a Space.LeaseContext.
LeaseContext.
LeaseContext.
|
GigaSpaces - Open Spaces | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||