|
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
.
BeanPostProcessor
s.
BeanPostProcessor
s.
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
AsyncResult
s.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.
DataIterator
s
from ManagedDataSource.initialLoad()
.
ApplicationContext
.ApplicationContext
.
IntegratedProcessingUnitContainer
provider.DistributedSpaceTask
that wraps the actual Task
to be executed.GigaSpace
InternalSpaceException
.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.LazyLoadingScript
s.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 |