com.cloudera.cdk.morphline.base
Class Notifications

java.lang.Object
  com.cloudera.cdk.morphline.base.Notifications

public final class Notifications
extends Object

Tools for notifications on the control plane.

Nested Class Summary

static class

Notifications.LifecycleEvent

Field Summary

static String

LIFE_CYLCLE

Constructor Summary

Notifications()

Method Summary

static boolean	containsLifecycleEvent(Record notification, Notifications.LifecycleEvent event)
static List	getLifecycleEvents(Record notification)
static void	notifyBeginTransaction(Command command)
static void	notifyCommitTransaction(Command command)
static void	notifyRollbackTransaction(Command command)
static void	notifyShutdown(Command command)
static void	notifyStartSession(Command command)

Methods inherited from class java.lang.Object

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

Field Detail

LIFE_CYLCLE

public static final String LIFE_CYLCLE

See Also:

Constant Field Values

Constructor Detail

Notifications

public Notifications()

Method Detail

getLifecycleEvents

public static List getLifecycleEvents(Record notification)

notifyBeginTransaction

public static void notifyBeginTransaction(Command command)

notifyCommitTransaction

public static void notifyCommitTransaction(Command command)

notifyRollbackTransaction

public static void notifyRollbackTransaction(Command command)

notifyShutdown

public static void notifyShutdown(Command command)

notifyStartSession

public static void notifyStartSession(Command command)

containsLifecycleEvent

public static boolean containsLifecycleEvent(Record notification,
                                             Notifications.LifecycleEvent event)