01: /*
02: * All content copyright (c) 2003-2006 Terracotta, Inc., except as may otherwise be noted in a separate copyright notice. All rights reserved.
03: */
04: package com.tc.net.protocol.tcm;
05:
06: import com.tc.async.api.Sink;
07:
08: class TCMessageSinkToSedaSink implements TCMessageSink {
09: private final Sink destSink;
10: private final Sink hydrateSink;
11:
12: public TCMessageSinkToSedaSink(Sink destSink, Sink hydrateSink) {
13: this .destSink = destSink;
14: this .hydrateSink = hydrateSink;
15: }
16:
17: public void putMessage(TCMessage message) {
18: HydrateContext context = new HydrateContext(message, destSink);
19: hydrateSink.add(context);
20: }
21:
22: }
|