01: /*
02: * All content copyright (c) 2003-2007 Terracotta, Inc., except as may otherwise be noted in a separate copyright
03: * notice. All rights reserved.
04: */
05: package com.tc.async.impl;
06:
07: import com.tc.async.api.EventContext;
08: import com.tc.async.api.EventHandlerException;
09: import com.tc.async.api.Sink;
10: import com.tc.async.api.SpecializedEventContext;
11:
12: public class InBandMoveToNextSink implements SpecializedEventContext {
13:
14: private final EventContext event;
15: private final Sink sink;
16:
17: public InBandMoveToNextSink(EventContext event, Sink sink) {
18: this .event = event;
19: this .sink = sink;
20: }
21:
22: public void execute() throws EventHandlerException {
23: sink.add(event);
24: }
25:
26: }
|