1 4 package com.tc.async.impl; 5 6 import com.tc.async.api.ConfigurationContext; 7 import com.tc.async.api.Sink; 8 import com.tc.async.api.Stage; 9 import com.tc.exception.ImplementMe; 10 11 14 public class MockStage implements Stage { 15 16 private final String name; 17 public final MockSink sink; 18 19 public MockStage(String name) { 20 this.name = name; 21 this.sink = new MockSink(); 22 } 23 24 public void destroy() { 25 } 27 28 public synchronized Sink getSink() { 29 return sink; 30 } 31 32 public String getName() { 33 return name; 34 } 35 36 public void start(ConfigurationContext context) { 37 } 39 40 public void turnTracingOn() { 41 } 43 44 public void turnTracingOff() { 45 } 47 48 public void pause() { 49 throw new ImplementMe(); 50 51 } 52 53 public void unpause() { 54 throw new ImplementMe(); 55 56 } 57 } | Popular Tags |