KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > tc > net > protocol > tcm > TCMessageSinkToSedaSink


1 /*
2  * All content copyright (c) 2003-2006 Terracotta, Inc., except as may otherwise be noted in a separate copyright notice. All rights reserved.
3  */
4 package com.tc.net.protocol.tcm;
5
6 import com.tc.async.api.Sink;
7
8 class TCMessageSinkToSedaSink implements TCMessageSink {
9   private final Sink destSink;
10   private final Sink hydrateSink;
11   
12
13   public TCMessageSinkToSedaSink(Sink destSink, Sink hydrateSink) {
14     this.destSink = destSink;
15     this.hydrateSink = hydrateSink;
16   }
17
18   public void putMessage(TCMessage message) {
19     HydrateContext context = new HydrateContext(message, destSink);
20     hydrateSink.add(context);
21   }
22   
23     
24   
25 }
26
Popular Tags