Package net.officefloor.nosql.cosmosdb

Class CosmosAsyncDatabaseManagedObjectSource

java.lang.Object

net.officefloor.frame.api.managedobject.source.impl.AbstractAsyncManagedObjectSource<O,F>

net.officefloor.frame.api.managedobject.source.impl.AbstractManagedObjectSource<None,None>

net.officefloor.nosql.cosmosdb.CosmosAsyncDatabaseManagedObjectSource

All Implemented Interfaces:

ManagedObject, ManagedObjectSource<None,None>

public class CosmosAsyncDatabaseManagedObjectSource
extends AbstractManagedObjectSource<None,None>
implements ManagedObject

ManagedObjectSource for the CosmosAsyncDatabase.

Author:

Daniel Sagenschneider

Nested Class Summary

Nested classes/interfaces inherited from class net.officefloor.frame.api.managedobject.source.impl.AbstractAsyncManagedObjectSource

AbstractAsyncManagedObjectSource.DependencyLabeller<K extends java.lang.Enum<K>>, AbstractAsyncManagedObjectSource.ExecutionLabeller, AbstractAsyncManagedObjectSource.Labeller<K extends java.lang.Enum<K>>, AbstractAsyncManagedObjectSource.MetaDataContext<O extends java.lang.Enum<O>,F extends java.lang.Enum<F>>, AbstractAsyncManagedObjectSource.SpecificationContext

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	PROPERTY_DATABASE	Property name for the CosmosAsyncDatabase name.

Constructor Summary

Constructors

Constructor	Description
CosmosAsyncDatabaseManagedObjectSource()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<com.azure.cosmos.CosmosAsyncDatabase>	createCosmosAsyncDatabase(com.azure.cosmos.CosmosAsyncClient client, java.lang.String databaseName)	Creates the CosmosAsyncDatabase.
java.lang.String	getDatabaseName(SourceContext sourceContext)	Obtains the name of the CosmosAsyncDatabase.
protected ManagedObject	getManagedObject()	Synchronously obtains the ManagedObject.
java.lang.Object	getObject()	Obtains the object being managed.
protected void	loadMetaData(AbstractAsyncManagedObjectSource.MetaDataContext<None,None> context)	Overridden to load meta-data.
protected void	loadSpecification(AbstractAsyncManagedObjectSource.SpecificationContext context)	Overridden to load specifications.

Methods inherited from class net.officefloor.frame.api.managedobject.source.impl.AbstractManagedObjectSource

sourceManagedObject

Methods inherited from class net.officefloor.frame.api.managedobject.source.impl.AbstractAsyncManagedObjectSource

getSpecification, init, start, stop

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_DATABASE

public static final java.lang.String PROPERTY_DATABASE

Property name for the CosmosAsyncDatabase name.

See Also:

Constant Field Values

Constructor Detail

CosmosAsyncDatabaseManagedObjectSource

public CosmosAsyncDatabaseManagedObjectSource()

Method Detail

getDatabaseName

public java.lang.String getDatabaseName(SourceContext sourceContext)

Obtains the name of the CosmosAsyncDatabase.

Parameters:

sourceContext - SourceContext.

Returns:

Name of the CosmosDatabase.

createCosmosAsyncDatabase

public reactor.core.publisher.Mono<com.azure.cosmos.CosmosAsyncDatabase> createCosmosAsyncDatabase(com.azure.cosmos.CosmosAsyncClient client,
                                                                                                   java.lang.String databaseName)

Creates the CosmosAsyncDatabase.

Parameters:

client - CosmosAsyncClient.

databaseName - Name of the CosmosAsyncDatabase.

Returns:

CosmosAsyncDatabase.

loadSpecification

protected void loadSpecification(AbstractAsyncManagedObjectSource.SpecificationContext context)

Description copied from class: AbstractAsyncManagedObjectSource

Overridden to load specifications.

Specified by:

loadSpecification in class AbstractAsyncManagedObjectSource<None,None>

Parameters:

context - Specifications.

loadMetaData

protected void loadMetaData(AbstractAsyncManagedObjectSource.MetaDataContext<None,None> context)
                     throws java.lang.Exception

Description copied from class: AbstractAsyncManagedObjectSource

Overridden to load meta-data.

Specified by:

loadMetaData in class AbstractAsyncManagedObjectSource<None,None>

Parameters:

context - Meta-data.

Throws:

java.lang.Exception - If fails to load the meta-data.

getManagedObject

protected ManagedObject getManagedObject()
                                  throws java.lang.Throwable

Description copied from class: AbstractManagedObjectSource

Synchronously obtains the ManagedObject.

Specified by:

getManagedObject in class AbstractManagedObjectSource<None,None>

Returns:

ManagedObject.

Throws:

java.lang.Throwable - If fails to obtain the ManagedObject.

getObject

public java.lang.Object getObject()
                           throws java.lang.Throwable

Description copied from interface: ManagedObject

Obtains the object being managed.

Specified by:

getObject in interface ManagedObject

Returns:

Object being managed.

Throws:

java.lang.Throwable - Indicating failed to obtain the object for use.