org.glassfish.hk2.configuration.hub.internal

Class HubImpl

java.lang.Object

org.glassfish.hk2.configuration.hub.internal.HubImpl

All Implemented Interfaces:

Hub

@Service
 @ContractsProvided(value=Hub.class)
 @Visibility(value=LOCAL)
public class HubImpl
extends java.lang.Object
implements Hub

Field Summary

Fields

Modifier and Type	Field and Description
private BeanDatabaseImpl	currentDatabase
private int	inTransaction
private IterableProvider<BeanDatabaseUpdateListener>	listeners
private java.lang.Object	lock
private static java.util.concurrent.atomic.AtomicLong	revisionCounter

Constructor Summary

Constructors

Constructor and Description
HubImpl()

Method Summary

Modifier and Type	Method and Description
(package private) void	activateCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase, java.lang.Object commitMessage, java.util.List<Change> changes, java.util.LinkedList<BeanDatabaseUpdateListener> completedListeners)
BeanDatabase	getCurrentDatabase() Gets the current database running in the system
WriteableBeanDatabase	getWriteableDatabaseCopy() Creates a writeable copy of the currently running database.
(package private) java.util.LinkedList<BeanDatabaseUpdateListener>	prepareCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase, java.lang.Object commitMessage, java.util.List<Change> changes)
(package private) void	rollbackCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase, java.lang.Object commitMessage, java.util.List<Change> changes, java.util.LinkedList<BeanDatabaseUpdateListener> completedListeners)
(package private) void	setCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase, java.lang.Object commitMessage, java.util.List<Change> changes)

Methods inherited from class java.lang.Object

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

Field Detail

revisionCounter

private static final java.util.concurrent.atomic.AtomicLong revisionCounter

lock

private final java.lang.Object lock

currentDatabase

private BeanDatabaseImpl currentDatabase

listeners

@Inject
private IterableProvider<BeanDatabaseUpdateListener> listeners

inTransaction

private int inTransaction

Constructor Detail

HubImpl

public HubImpl()

Method Detail

getCurrentDatabase

public BeanDatabase getCurrentDatabase()

Description copied from interface: Hub

Gets the current database running in the system

Specified by:

getCurrentDatabase in interface Hub

Returns:

The current database known to the Hub

getWriteableDatabaseCopy

public WriteableBeanDatabase getWriteableDatabaseCopy()

Description copied from interface: Hub

Creates a writeable copy of the currently running database. If the WriteableBeanDatabase.commit() method is called (and no other WriteableBeanDatabase.commit() method has been called) then a read-only copye of the WriteableBeanDatabase will become the current database. There is no requirement to eventually call the WriteableBeanDatabase.commit() method

Specified by:

getWriteableDatabaseCopy in interface Hub

Returns:

A writeable copy of the current database

prepareCurrentDatabase

java.util.LinkedList<BeanDatabaseUpdateListener> prepareCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase,
                                                                        java.lang.Object commitMessage,
                                                                        java.util.List<Change> changes)

activateCurrentDatabase

void activateCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase,
                             java.lang.Object commitMessage,
                             java.util.List<Change> changes,
                             java.util.LinkedList<BeanDatabaseUpdateListener> completedListeners)

rollbackCurrentDatabase

void rollbackCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase,
                             java.lang.Object commitMessage,
                             java.util.List<Change> changes,
                             java.util.LinkedList<BeanDatabaseUpdateListener> completedListeners)

setCurrentDatabase

void setCurrentDatabase(WriteableBeanDatabaseImpl writeableDatabase,
                        java.lang.Object commitMessage,
                        java.util.List<Change> changes)