Skip navigation links

com.oracle.cep.cluster.hagroups
Class ActiveActiveGroupBean

java.lang.Object
  |
  +--com.oracle.cep.cluster.hagroups.ActiveActiveGroupBean

public class ActiveActiveGroupBean

extends java.lang.Object

implements BeanPostProcessorService, ApplicationIdentityAware

A bean which manages subscriptions to BroadcastGroup membership notifications. The BroadcastGroup in question is not the deployment group, but rather an HA-specific construct. The HA group specific to this application is selected by matching the value of groupPattern property to the name of a group registered with the local server. The value of this pattern is by default GROUP_PATTERN. <p/> The bean also provides a method getGroupProperty(String) which allows configuration properties to be parsed for a value specific to the HA group relevant to this application.

Field Summary

static java.lang.String

GROUP_PATTERN The default regular expression for matching the active HA group.

Constructor Summary

ActiveActiveGroupBean()

Method Summary
void	afterPropertiesSet()
void	afterPropertiesSet(BundleContext context)
void	destroy(BundleContext context)
java.lang.String	getGroupName()
java.lang.String	getGroupPattern()
java.lang.String	getGroupProperty(java.lang.String propString) Return the property for a group when the property string is of the form groupName1=prop1,groupName2=prop2,groupName3=prop3,default=defprop
java.util.Collection	getNotficationGroups()
int	getOrder() This is defined to come before the other lifecycle callbacks.
java.lang.Object	postProcessAfterInitialization(BundleContext context, ConfigurableListableBeanFactory factory, java.lang.Object bean, java.lang.String beanName)
java.lang.Object	postProcessAfterInitialization(java.lang.Object bean, java.lang.String beanName)
java.lang.Object	postProcessAfterInitialization(java.lang.Object bean, java.lang.String beanName, java.lang.String groupName)
void	postProcessBeforeDestruction(BundleContext context, ConfigurableListableBeanFactory factory, java.lang.Object bean, java.lang.String beanName)
void	postProcessBeforeDestruction(java.lang.Object bean, java.lang.String beanName)
void	postProcessBeforeDestruction(java.lang.Object bean, java.lang.String beanName, java.lang.String groupName)
java.lang.Object	postProcessBeforeInitialization(BundleContext context, ConfigurableListableBeanFactory factory, java.lang.Object bean, java.lang.String beanName)
java.lang.Object	postProcessBeforeInitialization(java.lang.Object bean, java.lang.String beanName)
void	setApplicationIdentity(java.lang.String applicationId)
void	setBeanClassLoader(java.lang.ClassLoader classLoader)
void	setBeanFactory(BeanFactory beanFactory)
void	setBeanName(java.lang.String beanName)
void	setBroadcastDomain(BroadcastDomain domain)
void	setBundlePropertyAdmin(BundlePropertyAdmin admin)
void	setClusterService(ClusterService cluster)
void	setGroupName(java.lang.String groupName)
void	setGroupPattern(java.lang.String groupPattern) Set the regular expression to use when looking for a group for which membership callbacks will be delivered.
void	setManagementService(ManagementService service)

Methods inherited from class java.lang.Object

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

Field Detail

GROUP_PATTERN

public static final java.lang.String GROUP_PATTERN

The default regular expression for matching the active HA group.

Constructor Detail

ActiveActiveGroupBean

public ActiveActiveGroupBean()

Method Detail

setClusterService

public void setClusterService(ClusterService cluster)

setBroadcastDomain

public void setBroadcastDomain(BroadcastDomain domain)

setBundlePropertyAdmin

public void setBundlePropertyAdmin(BundlePropertyAdmin admin)

postProcessBeforeInitialization

public java.lang.Object postProcessBeforeInitialization(java.lang.Object bean,
                                                        java.lang.String beanName)
                                                 throws BeansException

getGroupPattern

public java.lang.String getGroupPattern()

setGroupPattern

public void setGroupPattern(java.lang.String groupPattern)

Set the regular expression to use when looking for a group for which membership callbacks will be delivered. By default this matches GROUP_PATTERN. String

Parameters:

groupPattern - regular expression

getGroupName

public java.lang.String getGroupName()

setGroupName

public void setGroupName(java.lang.String groupName)

postProcessAfterInitialization

public java.lang.Object postProcessAfterInitialization(java.lang.Object bean,
                                                       java.lang.String beanName)
                                                throws BeansException

postProcessAfterInitialization

public java.lang.Object postProcessAfterInitialization(java.lang.Object bean,
                                                       java.lang.String beanName,
                                                       java.lang.String groupName)
                                                throws BeansException

postProcessBeforeDestruction

public void postProcessBeforeDestruction(java.lang.Object bean,
                                         java.lang.String beanName)
                                  throws BeansException

postProcessBeforeDestruction

public void postProcessBeforeDestruction(java.lang.Object bean,
                                         java.lang.String beanName,
                                         java.lang.String groupName)
                                  throws BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

setManagementService

public void setManagementService(ManagementService service)

getGroupProperty

public java.lang.String getGroupProperty(java.lang.String propString)

Return the property for a group when the property string is of the form groupName1=prop1,groupName2=prop2,groupName3=prop3,default=defprop

Parameters:

propString -

Returns:

the property for this group or the default if there is one or null if there is none

postProcessBeforeInitialization

public java.lang.Object postProcessBeforeInitialization(BundleContext context,
                                                        ConfigurableListableBeanFactory factory,
                                                        java.lang.Object bean,
                                                        java.lang.String beanName)
                                                 throws BeansException

Specified by:

postProcessBeforeInitialization in interface BeanPostProcessorService

postProcessAfterInitialization

public java.lang.Object postProcessAfterInitialization(BundleContext context,
                                                       ConfigurableListableBeanFactory factory,
                                                       java.lang.Object bean,
                                                       java.lang.String beanName)
                                                throws BeansException

Specified by:

postProcessAfterInitialization in interface BeanPostProcessorService

postProcessBeforeDestruction

public void postProcessBeforeDestruction(BundleContext context,
                                         ConfigurableListableBeanFactory factory,
                                         java.lang.Object bean,
                                         java.lang.String beanName)
                                  throws BeansException

Specified by:

postProcessBeforeDestruction in interface BeanPostProcessorService

afterPropertiesSet

public void afterPropertiesSet(BundleContext context)
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface BeanPostProcessorService

destroy

public void destroy(BundleContext context)
             throws java.lang.Exception

Specified by:

destroy in interface BeanPostProcessorService

getOrder

public int getOrder()

This is defined to come before the other lifecycle callbacks.

getNotficationGroups

public java.util.Collection getNotficationGroups()

Returns:

all notification groups in the domain, as determined by this bean

setApplicationIdentity

public void setApplicationIdentity(java.lang.String applicationId)

Specified by:

setApplicationIdentity in interface ApplicationIdentityAware

setBeanName

public void setBeanName(java.lang.String beanName)

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

setBeanClassLoader

public void setBeanClassLoader(java.lang.ClassLoader classLoader)