org.jboss.ejb.plugins.cmp.jdbc2.schema
Class PartitionedTableCache

java.lang.Object
  extended byorg.jboss.mx.util.JBossNotificationBroadcasterSupport (src) 
      extended byorg.jboss.system.ServiceMBeanSupport (src) 
          extended byorg.jboss.ejb.plugins.cmp.jdbc2.schema.PartitionedTableCache
All Implemented Interfaces:
Cache (src) , MBeanRegistration (src) , NotificationBroadcaster (src) , NotificationEmitter (src) , Service (src) , ServiceMBean (src)

public class PartitionedTableCache
extends ServiceMBeanSupport (src)
implements Cache (src)


Nested Class Summary
 
Nested classes inherited from class org.jboss.ejb.plugins.cmp.jdbc2.schema.Cache (src)
Cache.CacheLoader (src) , Cache.Listener (src) , Cache.RemoveException (src)
 
Field Summary
 
Fields inherited from class org.jboss.system.ServiceMBeanSupport (src)
log, server, SERVICE_CONTROLLER_SIG, serviceName
 
Fields inherited from interface org.jboss.ejb.plugins.cmp.jdbc2.schema.Cache (src)
NONE
 
Fields inherited from interface org.jboss.system.ServiceMBean (src)
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED
 
Constructor Summary
PartitionedTableCache(int minCapacity, int maxCapacity, int partitionsTotal)
           
 
Method Summary
 boolean contains(Transaction (src)  tx, java.lang.Object pk)
           
 void flush()
           
 java.lang.Object[] getFields(java.lang.Object pk)
           
 int getMaxCapacity()
           
 int getMaxPartitionCapacity()
           
 int getMinCapacity()
           
 int getMinPartitionCapacity()
           
 int getPartitionsTotal()
           
 java.lang.Object[] getRelations(java.lang.Object pk)
           
 void lock()
           
 void lock(java.lang.Object key)
           
 void lockForUpdate(Transaction (src)  tx, java.lang.Object pk)
           
 void put(Transaction (src)  tx, java.lang.Object pk, java.lang.Object[] fields, java.lang.Object[] relations)
           
 void registerListener(Cache.Listener (src)  listener)
           
 void releaseLock(Transaction (src)  tx, java.lang.Object pk)
           
 void remove(Transaction (src)  tx, java.lang.Object pk)
           
 void setMaxCapacity(int maxCapacity)
           
 int size()
           
 void unlock()
           
 void unlock(java.lang.Object key)
           
 
Methods inherited from class org.jboss.system.ServiceMBeanSupport (src)
create, createService, destroy, destroyService, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, startService, stop, stopService
 
Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport (src)
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PartitionedTableCache

public PartitionedTableCache(int minCapacity,
                             int maxCapacity,
                             int partitionsTotal)
Method Detail

registerListener

public void registerListener(Cache.Listener (src)  listener)

size

public int size()

getMaxCapacity

public int getMaxCapacity()

setMaxCapacity

public void setMaxCapacity(int maxCapacity)

getMinCapacity

public int getMinCapacity()

getPartitionsTotal

public int getPartitionsTotal()

getMinPartitionCapacity

public int getMinPartitionCapacity()

getMaxPartitionCapacity

public int getMaxPartitionCapacity()

lock

public void lock()
Specified by:
lock in interface Cache (src)

lock

public void lock(java.lang.Object key)
Specified by:
lock in interface Cache (src)

unlock

public void unlock()
Specified by:
unlock in interface Cache (src)

unlock

public void unlock(java.lang.Object key)
Specified by:
unlock in interface Cache (src)

getFields

public java.lang.Object[] getFields(java.lang.Object pk)
Specified by:
getFields in interface Cache (src)

getRelations

public java.lang.Object[] getRelations(java.lang.Object pk)
Specified by:
getRelations in interface Cache (src)

put

public void put(Transaction (src)  tx,
                java.lang.Object pk,
                java.lang.Object[] fields,
                java.lang.Object[] relations)
Specified by:
put in interface Cache (src)

remove

public void remove(Transaction (src)  tx,
                   java.lang.Object pk)
Specified by:
remove in interface Cache (src)

contains

public boolean contains(Transaction (src)  tx,
                        java.lang.Object pk)
Specified by:
contains in interface Cache (src)

lockForUpdate

public void lockForUpdate(Transaction (src)  tx,
                          java.lang.Object pk)
                   throws java.lang.Exception
Specified by:
lockForUpdate in interface Cache (src)
Throws:
java.lang.Exception

releaseLock

public void releaseLock(Transaction (src)  tx,
                        java.lang.Object pk)
                 throws java.lang.Exception
Specified by:
releaseLock in interface Cache (src)
Throws:
java.lang.Exception

flush

public void flush()
Specified by:
flush in interface Cache (src)