org.wildfly.clustering.ejb.infinispan

Class InfinispanBeanManager<G,I,T>

java.lang.Object

org.wildfly.clustering.ejb.infinispan.InfinispanBeanManager<G,I,T>

Type Parameters:

G - the group identifier type

I - the bean identifier type

T - the bean type

All Implemented Interfaces:

org.infinispan.notifications.KeyFilter, AffinitySupport<I>, Batcher, BeanManager<G,I,T>, BeanManagerStatistics

public class InfinispanBeanManager<G,I,T>
extends Object
implements BeanManager<G,I,T>, Batcher, org.infinispan.notifications.KeyFilter

A BeanManager implementation backed by an infinispan cache.

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description

InfinispanBeanManager(String beanName, Configuration<I,BeanKey<I>,BeanEntry<G>,BeanFactory<G,I,T>> beanConfiguration, Configuration<G,G,BeanGroupEntry<I,T>,BeanGroupFactory<G,I,T>> groupConfiguration, KeyAffinityServiceFactory affinityFactory, Registry<String,?> registry, NodeFactory<org.infinispan.remoting.transport.Address> nodeFactory, ExpirationConfiguration<T> expiration, PassivationConfiguration<T> passivation)

Method Summary

Modifier and Type	Method and Description
boolean	accept(Object key)
void	activated(org.infinispan.notifications.cachelistener.event.CacheEntryActivatedEvent<BeanKey<I>,BeanEntry<G>> event)
boolean	containsBean(I id)
Bean<G,I,T>	createBean(I id, G groupId, T bean)
Bean<G,I,T>	findBean(I id)
int	getActiveCount()
Batcher	getBatcher()
IdentifierFactory<I>	getBeanIdentifierFactory()
IdentifierFactory<G>	getGroupIdentifierFactory()
int	getPassiveCount()
org.jboss.ejb.client.Affinity	getStrictAffinity()
org.jboss.ejb.client.Affinity	getWeakAffinity(I id)
void	passivated(org.infinispan.notifications.cachelistener.event.CacheEntryPassivatedEvent<BeanKey<I>,BeanEntry<G>> event)
void	start()
Batch	startBatch() Starts a batch.
void	stop()
void	topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<BeanKey<I>,BeanEntry<G>> event)

Methods inherited from class java.lang.Object

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

Constructor Detail

InfinispanBeanManager

public InfinispanBeanManager(String beanName,
                             Configuration<I,BeanKey<I>,BeanEntry<G>,BeanFactory<G,I,T>> beanConfiguration,
                             Configuration<G,G,BeanGroupEntry<I,T>,BeanGroupFactory<G,I,T>> groupConfiguration,
                             KeyAffinityServiceFactory affinityFactory,
                             Registry<String,?> registry,
                             NodeFactory<org.infinispan.remoting.transport.Address> nodeFactory,
                             ExpirationConfiguration<T> expiration,
                             PassivationConfiguration<T> passivation)

Method Detail

start

public void start()

Specified by:

start in interface BeanManager<G,I,T>

stop

public void stop()

Specified by:

stop in interface BeanManager<G,I,T>

accept

public boolean accept(Object key)

Specified by:

accept in interface org.infinispan.notifications.KeyFilter

getStrictAffinity

public org.jboss.ejb.client.Affinity getStrictAffinity()

Specified by:

getStrictAffinity in interface AffinitySupport<I>

getWeakAffinity

public org.jboss.ejb.client.Affinity getWeakAffinity(I id)

Specified by:

getWeakAffinity in interface AffinitySupport<I>

createBean

public Bean<G,I,T> createBean(I id,
                              G groupId,
                              T bean)

Specified by:

createBean in interface BeanManager<G,I,T>

findBean

public Bean<G,I,T> findBean(I id)

Specified by:

findBean in interface BeanManager<G,I,T>

containsBean

public boolean containsBean(I id)

Specified by:

containsBean in interface BeanManager<G,I,T>

getGroupIdentifierFactory

public IdentifierFactory<G> getGroupIdentifierFactory()

Specified by:

getGroupIdentifierFactory in interface BeanManager<G,I,T>

getBeanIdentifierFactory

public IdentifierFactory<I> getBeanIdentifierFactory()

Specified by:

getBeanIdentifierFactory in interface BeanManager<G,I,T>

getBatcher

public Batcher getBatcher()

Specified by:

getBatcher in interface BeanManager<G,I,T>

startBatch

public Batch startBatch()

Description copied from interface: Batcher

Starts a batch.

Specified by:

startBatch in interface Batcher

Returns:

a batch.

getActiveCount

public int getActiveCount()

Specified by:

getActiveCount in interface BeanManagerStatistics

getPassiveCount

public int getPassiveCount()

Specified by:

getPassiveCount in interface BeanManagerStatistics

passivated

public void passivated(org.infinispan.notifications.cachelistener.event.CacheEntryPassivatedEvent<BeanKey<I>,BeanEntry<G>> event)

activated

public void activated(org.infinispan.notifications.cachelistener.event.CacheEntryActivatedEvent<BeanKey<I>,BeanEntry<G>> event)

topologyChanged

public void topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<BeanKey<I>,BeanEntry<G>> event)