org.openspaces.pu.container.integrated
Class IntegratedProcessingUnitContainer

java.lang.Object
  org.openspaces.pu.container.integrated.IntegratedProcessingUnitContainer

All Implemented Interfaces:

ProcessingUnitContainer, ApplicationContextProcessingUnitContainer

public class IntegratedProcessingUnitContainer
extends Object
implements ApplicationContextProcessingUnitContainer

The integrated processing unit container wraps Spring ApplicationContext. It is created using IntegratedProcessingUnitContainerProvider.

An integrated processing unit container can be used to run a processing unit within an existing environment. An example of what this existing environment will provide is the classpath that the processing unit will run with. Examples for using the integrated processing unit container can be integration tests or running the processing unit from within an IDE.

The integrated processing unit container also provides a a main method (main(String[]) which uses the IntegratedProcessingUnitContainerProvider and the provided parameters create itself. Please see the javadoc for the main method for a full list of the possible parameters values.

Author:

kimchy

Constructor Summary

IntegratedProcessingUnitContainer(ApplicationContext applicationContext)
Constructs a new integrated processing unit container based on the provided Spring ApplicationContext.

Method Summary

void	close() Closes the processing unit container by destroying the Spring application context.
static ProcessingUnitContainer	createContainer(String[] args)
ApplicationContext	getApplicationContext() Returns the spring application context this processing unit container wraps.
static void	main(String[] args) Allows to run the integrated processing unit container.
static void	printUsage()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IntegratedProcessingUnitContainer

public IntegratedProcessingUnitContainer(ApplicationContext applicationContext)

Constructs a new integrated processing unit container based on the provided Spring ApplicationContext.

Method Detail

getApplicationContext

public ApplicationContext getApplicationContext()

Returns the spring application context this processing unit container wraps.

Specified by:

getApplicationContext in interface ApplicationContextProcessingUnitContainer

close

public void close()
           throws CannotCloseContainerException

Closes the processing unit container by destroying the Spring application context.

Specified by:

close in interface ProcessingUnitContainer

Throws:

CannotCloseContainerException

main

public static void main(String[] args)
                 throws Exception

Allows to run the integrated processing unit container. Uses the IntegratedProcessingUnitContainerProvider and the parameters provided in order to configure it.

The following parameters are allowed:

• -config [configLocation]: Allows to add a Spring application context config location. See IntegratedProcessingUnitContainerProvider.addConfigLocation(String). This is an optional parameter and it can be provided multiple times.
• -properties [beanName] [properties]: Allows to inject BeanLevelProperties, see IntegratedProcessingUnitContainerProvider.setBeanLevelProperties(org.openspaces.core.properties.BeanLevelProperties). [beanName] is optional, if not used, the properties will set the BeanLevelProperties.setContextProperties(java.util.Properties). If used, will inject properties only to the bean registered under the provided beanName within the Spring context (see BeanLevelProperties.setBeanProperties(String,java.util.Properties)). The [properties] can either start with embed:// which mean they will be provided within the command line (for example: embed://propName1=propVal1;propName2=propVal2) or they can follow Spring Resource lookup based on URL syntax or Spring extended classpath prefix (see DefaultResourceLoader).
• -cluster [cluster parameters]: Allows to configure ClusterInfo, see IntegratedProcessingUnitContainerProvider.setClusterInfo(org.openspaces.core.cluster.ClusterInfo).
The following parameters are allowed: total_members=1,1 (1,1 is an example value), id=1 (1 is an example value), backup_id=1 (1 is an example value) and schema=primary_backup (primary_backup is an example value). No parameter is required. For more information regarding the Space meaning of this parameters please consult GigaSpaces reference documentation within the Space URL section.

Throws:

Exception

createContainer

public static ProcessingUnitContainer createContainer(String[] args)
                                               throws Exception

Throws:

Exception

printUsage

public static void printUsage()