org.jclouds.abiquo.internal

Class BaseMonitoringService

java.lang.Object

org.jclouds.abiquo.internal.BaseMonitoringService

All Implemented Interfaces:

MonitoringService

Direct Known Subclasses:

BaseAsyncTaskMonitor, BaseConversionMonitor, BaseVirtualApplianceMonitor, BaseVirtualMachineMonitor

@Singleton
public class BaseMonitoringService
extends Object
implements MonitoringService

Utility service to monitor asynchronous operations.

Author:

Ignasi Barrera, Francesc Montserrat

Field Summary

Fields

Modifier and Type	Field and Description
protected RestContext<AbiquoApi,AbiquoAsyncApi>	context
protected com.google.common.eventbus.EventBus	eventBus The event bus used to dispatch monitoring events.
protected Long	pollingDelay
protected ScheduledExecutorService	scheduler The scheduler used to perform monitoring tasks.

Constructor Summary

Constructors

Constructor and Description
BaseMonitoringService(RestContext<AbiquoApi,AbiquoAsyncApi> context, ScheduledExecutorService scheduler, Long pollingDelay, com.google.common.eventbus.EventBus eventBus)

Method Summary

Methods

Modifier and Type	Method and Description
<T> void	awaitCompletion(com.google.common.base.Function<T,MonitorStatus> completeCondition, T... objects) Generic monitoring methods
<T> void	awaitCompletion(Long maxWait, TimeUnit timeUnit, com.google.common.base.Function<T,MonitorStatus> completeCondition, T... objects) Monitor the given objects using the given complete condition.
AsyncTaskMonitor	getAsyncTaskMonitor() Gets the asynchronous task monitor service.
ConversionMonitor	getConversionMonitor() Gets the conversion monitor service.
VirtualApplianceMonitor	getVirtualApplianceMonitor() Gets the virtual appliance monitor service.
VirtualMachineMonitor	getVirtualMachineMonitor() Delegating monitors
<T> void	monitor(com.google.common.base.Function<T,MonitorStatus> completeCondition, T... objects) Monitor the given objects using the given complete condition.
<T> void	monitor(Long maxWait, TimeUnit timeUnit, com.google.common.base.Function<T,MonitorStatus> completeCondition, T... objects) Monitor the given objects using the given complete condition.
<T extends AbstractEventHandler<?>> void	register(T handler) Registers the given event handler.
<T extends AbstractEventHandler<?>> void	unregister(T handler) Unregisters the given event handler.

Methods inherited from class java.lang.Object

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

Field Detail

context

protected RestContext<AbiquoApi,AbiquoAsyncApi> context

scheduler

protected ScheduledExecutorService scheduler

The scheduler used to perform monitoring tasks.

pollingDelay

protected Long pollingDelay

eventBus

protected com.google.common.eventbus.EventBus eventBus

The event bus used to dispatch monitoring events.

A sync bus is used by default, to prevent deadlocks when using the BlockingEventHandler.

Constructor Detail

BaseMonitoringService

@Inject
public BaseMonitoringService(RestContext<AbiquoApi,AbiquoAsyncApi> context,
                            @Named(value="jclouds.scheduler-threads")
                            ScheduledExecutorService scheduler,
                            @Named(value="abiquo.monitor-delay")
                            Long pollingDelay,
                            com.google.common.eventbus.EventBus eventBus)

Method Detail

awaitCompletion

public <T> void awaitCompletion(com.google.common.base.Function<T,MonitorStatus> completeCondition,
                       T... objects)

Generic monitoring methods

Specified by:

awaitCompletion in interface MonitoringService

Parameters:

completeCondition - The function that will be used to decide if the asynchronous operations have finished.

objects - The objects to monitor.

awaitCompletion

public <T> void awaitCompletion(Long maxWait,
                       TimeUnit timeUnit,
                       com.google.common.base.Function<T,MonitorStatus> completeCondition,
                       T... objects)

Description copied from interface: MonitoringService

Monitor the given objects using the given complete condition.

Specified by:

awaitCompletion in interface MonitoringService

Parameters:

maxWait - The maximum time to wait.

timeUnit - The time unit for the maxWait parameter.

completeCondition - The function that will be used to decide if the asynchronous operations have finished.

objects - The objects to monitor.

monitor

public <T> void monitor(com.google.common.base.Function<T,MonitorStatus> completeCondition,
               T... objects)

Description copied from interface: MonitoringService

Monitor the given objects using the given complete condition.

Specified by:

monitor in interface MonitoringService

Parameters:

completeCondition - The function that will be used to decide if the asynchronous operations have finished.

objects - The objects to monitor.

monitor

public <T> void monitor(Long maxWait,
               TimeUnit timeUnit,
               com.google.common.base.Function<T,MonitorStatus> completeCondition,
               T... objects)

Description copied from interface: MonitoringService

Monitor the given objects using the given complete condition.

Specified by:

monitor in interface MonitoringService

Parameters:

maxWait - The maximum time to wait.

timeUnit - The time unit for the maxWait parameter.

completeCondition - The function that will be used to decide if the asynchronous operations have finished.

objects - The objects to monitor.

register

public <T extends AbstractEventHandler<?>> void register(T handler)

Description copied from interface: MonitoringService

Registers the given event handler.

Specified by:

register in interface MonitoringService

Type Parameters:

T - The type of event handler to register.

Parameters:

handler - The event handler to register.

unregister

public <T extends AbstractEventHandler<?>> void unregister(T handler)

Description copied from interface: MonitoringService

Unregisters the given event handler.

Specified by:

unregister in interface MonitoringService

Type Parameters:

T - The type of event handler to unregister.

Parameters:

handler - The event handler to unregister.

getVirtualMachineMonitor

public VirtualMachineMonitor getVirtualMachineMonitor()

Delegating monitors

Specified by:

getVirtualMachineMonitor in interface MonitoringService

Returns:

The virtual machine monitor service.

getVirtualApplianceMonitor

public VirtualApplianceMonitor getVirtualApplianceMonitor()

Description copied from interface: MonitoringService

Gets the virtual appliance monitor service.

Specified by:

getVirtualApplianceMonitor in interface MonitoringService

Returns:

The virtual appliance monitor service.

getAsyncTaskMonitor

public AsyncTaskMonitor getAsyncTaskMonitor()

Description copied from interface: MonitoringService

Gets the asynchronous task monitor service.

Specified by:

getAsyncTaskMonitor in interface MonitoringService

Returns:

The asynchronous task monitor service.

getConversionMonitor

public ConversionMonitor getConversionMonitor()

Description copied from interface: MonitoringService

Gets the conversion monitor service.

Specified by:

getConversionMonitor in interface MonitoringService

Returns:

The conversion monitor service.