PeriodicDeltaChangeListener (Apache Brooklyn)

java.lang.Object
- brooklyn.entity.rebind.PeriodicDeltaChangeListener

All Implemented Interfaces:

ChangeListener
```
public class PeriodicDeltaChangeListener
extends java.lang.Object
implements ChangeListener
```
A "simple" implementation that periodically persists all entities/locations/policies that have changed since the last periodic persistence. TODO A better implementation would look at a per-entity basis. When the entity was modified, then schedule a write for that entity in X milliseconds time (if not already scheduled). That would prevent hammering the persister when a bunch of entity attributes change (e.g. when the entity has just polled over JMX/http/etc). Such a scheduled-write approach would be similar to the Nagle buffering algorithm in TCP (see tcp_nodelay).

Field Summary
- Fields inherited from interface brooklyn.entity.rebind.ChangeListener
  NOOP

Constructor Summary

Constructors
Constructor and Description
`PeriodicDeltaChangeListener(ExecutionContext executionContext, BrooklynMementoPersister persister, PersistenceExceptionHandler exceptionHandler, Duration period)`
`PeriodicDeltaChangeListener(ExecutionManager executionManager, BrooklynMementoPersister persister, PersistenceExceptionHandler exceptionHandler, long periodMillis)` Deprecated. since 0.7.0 pass in an `ExecutionContext` and a `Duration`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`onChanged(BrooklynObject instance)`
`void`	`onManaged(BrooklynObject instance)`
`void`	`onUnmanaged(BrooklynObject instance)`
`void`	`persistNow()`
`void`	`start()`
`void`	`waitForPendingComplete(Duration timeout)`
`void`	`waitForPendingComplete(long timeout, java.util.concurrent.TimeUnit unit)` Deprecated. since 0.7.0, use `waitForPendingComplete(Duration)`

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PeriodicDeltaChangeListener

@Deprecated
public PeriodicDeltaChangeListener(ExecutionManager executionManager,
                                      BrooklynMementoPersister persister,
                                      PersistenceExceptionHandler exceptionHandler,
                                      long periodMillis)

Deprecated. since 0.7.0 pass in an ExecutionContext and a Duration

PeriodicDeltaChangeListener

public PeriodicDeltaChangeListener(ExecutionContext executionContext,
                           BrooklynMementoPersister persister,
                           PersistenceExceptionHandler exceptionHandler,
                           Duration period)

Method Detail

start
```
public void start()
```

waitForPendingComplete

public void waitForPendingComplete(long timeout,
                          java.util.concurrent.TimeUnit unit)
                            throws java.lang.InterruptedException,
                                   java.util.concurrent.TimeoutException

Deprecated. since 0.7.0, use waitForPendingComplete(Duration)

This method must only be used for testing. If required in production, then revisit implementation!

Throws:: java.lang.InterruptedException; java.util.concurrent.TimeoutException

waitForPendingComplete

public void waitForPendingComplete(Duration timeout)
                            throws java.lang.InterruptedException,
                                   java.util.concurrent.TimeoutException

Throws:: java.lang.InterruptedException; java.util.concurrent.TimeoutException

persistNow
```
public void persistNow()
```

onManaged
```
public void onManaged(BrooklynObject instance)
```
Specified by:

onManaged in interface ChangeListener

onUnmanaged
```
public void onUnmanaged(BrooklynObject instance)
```
Specified by:

onUnmanaged in interface ChangeListener

onChanged
```
public void onChanged(BrooklynObject instance)
```
Specified by:

onChanged in interface ChangeListener

Class PeriodicDeltaChangeListener

Field Summary

Fields inherited from interface brooklyn.entity.rebind.ChangeListener

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

PeriodicDeltaChangeListener

PeriodicDeltaChangeListener

Method Detail

start

waitForPendingComplete

waitForPendingComplete

persistNow

onManaged

onUnmanaged

onChanged