Package org.openspaces.pu.container.integrated

Class IntegratedProcessingUnitContainer

java.lang.Object

org.openspaces.pu.container.ProcessingUnitContainer

org.openspaces.pu.container.spi.ApplicationContextProcessingUnitContainer

org.openspaces.pu.container.integrated.IntegratedProcessingUnitContainer

public class IntegratedProcessingUnitContainer
extends 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

Constructors

Constructor	Description
IntegratedProcessingUnitContainer(org.springframework.context.ApplicationContext applicationContext)	Constructs a new integrated processing unit container based on the provided Spring ApplicationContext.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the processing unit container by destroying the Spring application context.
static ProcessingUnitContainer	createContainer(String[] args)
org.springframework.context.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 org.openspaces.pu.container.spi.ApplicationContextProcessingUnitContainer

getDumpProcessors, getInvocableServices, getMemberAliveIndicators, getQuiesceStateChangedListeners, getServiceDetailsProviders, getServiceMonitorsProviders, getUndeployListeners

Methods inherited from class java.lang.Object

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

Constructor Details

IntegratedProcessingUnitContainer

public IntegratedProcessingUnitContainer(org.springframework.context.ApplicationContext applicationContext)

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

Method Details

getApplicationContext

public org.springframework.context.ApplicationContext getApplicationContext()

Returns the spring application context this processing unit container wraps.

Specified by:

getApplicationContext in class ApplicationContextProcessingUnitContainer

close

public void close()
           throws CannotCloseContainerException

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

Overrides:

close in class 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 ProcessingUnitContainerProvider.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 ProcessingUnitContainerProvider.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()