com.continuent.tungsten.replicator.management
Class MockEventDispatcher

java.lang.Object
  com.continuent.tungsten.replicator.management.MockEventDispatcher

All Implemented Interfaces:

com.continuent.tungsten.fsm.event.EventDispatcher

public class MockEventDispatcher
extends java.lang.Object
implements com.continuent.tungsten.fsm.event.EventDispatcher

Dummy event dispatcher used for testing.

Version:

1.0

Author:

Robert Hodges

Constructor Summary

MockEventDispatcher()

Method Summary

boolean	cancelActive(com.continuent.tungsten.fsm.event.EventRequest request, boolean mayInterruptIfRunning)
com.continuent.tungsten.fsm.event.EventRequest	put(com.continuent.tungsten.fsm.core.Event event)
com.continuent.tungsten.fsm.event.EventRequest	putOutOfBand(com.continuent.tungsten.fsm.core.Event event)
void	setListener(com.continuent.tungsten.fsm.event.EventCompletionListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockEventDispatcher

public MockEventDispatcher()

Method Detail

setListener

public void setListener(com.continuent.tungsten.fsm.event.EventCompletionListener listener)

Specified by:

setListener in interface com.continuent.tungsten.fsm.event.EventDispatcher

put

public com.continuent.tungsten.fsm.event.EventRequest put(com.continuent.tungsten.fsm.core.Event event)
                                                   throws java.lang.InterruptedException

Specified by:

put in interface com.continuent.tungsten.fsm.event.EventDispatcher

Throws:

java.lang.InterruptedException

putOutOfBand

public com.continuent.tungsten.fsm.event.EventRequest putOutOfBand(com.continuent.tungsten.fsm.core.Event event)
                                                            throws java.lang.InterruptedException

Specified by:

putOutOfBand in interface com.continuent.tungsten.fsm.event.EventDispatcher

Throws:

java.lang.InterruptedException

cancelActive

public boolean cancelActive(com.continuent.tungsten.fsm.event.EventRequest request,
                            boolean mayInterruptIfRunning)
                     throws java.lang.InterruptedException

Specified by:

cancelActive in interface com.continuent.tungsten.fsm.event.EventDispatcher

Throws:

java.lang.InterruptedException