|
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.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.ApplicationContext.AsyncSpaceRemotingProxyFactoryBean
into a field.AsyncSpaceRemotingProxyFactoryBean.ScriptingExecutor remoting proxy using
AsyncSpaceRemotingProxyFactoryBean.ScriptingExecutor proxy
AsyncScriptingProxyConfigurer on top of the given space
mergedProperties and the bean name
that the bean implementing this interface is associated with.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.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.IJSpace can not be created.IJSpace can not be found (when using jini/rmi protocol).closeMethod is supplied, will invoke it.
ClusterInfo.BeanPostProcessor that takes a ClusterInfo and injects it to all the
beans that implements ClusterInfoAware interface.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.
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.
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.
SpaceDriverManagerDataSource.BasicDataSource from jakarta commons dbcp
that uses a space to provide with a pooled data source implementation.handleEvent.
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.
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.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.read(Object,long)
under an exclusive read lock.Session.
StatelessSession.
AbstractSpaceListeningContainer.isRunning().
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.
key in this cache.
key in this cache.
Annotation of annotationType from the
supplied Method.
Annotations from the supplied Method.
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.
IMap used by this GigaMap implementation to delegate
different space operations.
Policy.setHigh(double) and
Policy.setLow(double)).
InternalSpaceException.
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.
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 instnace wrapping
the GigaMapFactoryBean.JavaSpace and GigaSpaces IJSpace extension
utilizing GigaSpaces extended and simplified programming model.GigaSpace instance if non already created.
GigaSpaceFactoryBean.GigaSpace instnace 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.initMethod is supplied, will invoke it.
ManagedDataSource.init(java.util.Properties)
on them.
DataIterators
from ManagedDataSource.initialLoad().
ApplicationContext.ApplicationContext.
IntegratedProcessingUnitContainer provider.InternalSpaceException.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 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 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.PlatformTransactionManager that
holds the Jini transactional context.jms namespace.LazyLoadingScripts.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.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.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).Notify annotation post processor.true to AbstractNotifyEventListenerContainer.setAutoRenew(boolean).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.
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.FilterOperationDelegateInvoker based on the operation
code.
FilterOperationDelegateInvoker based on the operation
code.
ProcessingUnitContainer.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.SpaceModeContextLoader.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.
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 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.
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.
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.
TransactionDefinition.TIMEOUT_DEFAULT is used.
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.
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().
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.
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 SyncSpaceRemotingProxyFactoryBean.setRemoteInvocationAspect(RemoteInvocationAspect).
true, allows to plug a custom reducer that can
reduce the array of result objects into another response object.
AsyncSpaceRemotingEntry class).
SyncSpaceRemotingEntry class).
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.
PlatformTransactionManager to use
for transactional wrapping of event reception plus 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.
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.
true if broadcast should be enabled or not.
AbstractSpaceListeningContainer.doShutdown(), and close this container.
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.read(Object,long).GigaSpace.take(Object,long).SLA.sla namespace.AbstractSpaceFactoryBean.afterPropertiesSet().
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.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.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).SyncSpaceRemotingProxyFactoryBean
into a field.SyncSpaceRemotingProxyFactoryBean.ScriptingExecutor remoting proxy using
SyncSpaceRemotingProxyFactoryBean.ScriptingExecutor proxy
SystemRequirement.SpaceDataEventListener
to Spring TaskExecutor implementation (usually to be executed in a different thread).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.Modifiers.NONE).
UrlSpaceFactoryBean.IJSpace instances.IJSpace) based on a url.View so namespace based
configuration will be simpler.IWorker implementations
as beans providing the same behavior when configured within a Space.LeaseContext.
LeaseContext.
LeaseContext.
|
GigaSpaces - Open Spaces | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||