org.apache.cassandra.net.io
Class StreamContextManager

java.lang.Object
  extended by org.apache.cassandra.net.io.StreamContextManager

public class StreamContextManager
extends java.lang.Object


Nested Class Summary
static class StreamContextManager.StreamCompletionAction
           
static class StreamContextManager.StreamContext
           
static class StreamContextManager.StreamContextSerializer
           
static class StreamContextManager.StreamStatus
           
static class StreamContextManager.StreamStatusMessage
           
static class StreamContextManager.StreamStatusMessageSerializer
           
static class StreamContextManager.StreamStatusSerializer
           
 
Field Summary
static java.util.Map<java.lang.String,java.util.List<StreamContextManager.StreamContext>> ctxBag_
           
static java.util.Map<java.lang.String,IStreamComplete> streamNotificationHandlers_
           
static java.util.Map<java.lang.String,java.util.List<StreamContextManager.StreamStatus>> streamStatusBag_
           
 
Constructor Summary
StreamContextManager()
           
 
Method Summary
static void addStreamContext(java.lang.String key, StreamContextManager.StreamContext streamContext, StreamContextManager.StreamStatus streamStatus)
           
static IStreamComplete getStreamCompletionHandler(java.lang.String key)
           
static StreamContextManager.StreamContext getStreamContext(java.lang.String key)
           
static StreamContextManager.StreamStatus getStreamStatus(java.lang.String key)
           
static boolean isDone(java.lang.String key)
           
static void registerStreamCompletionHandler(java.lang.String key, IStreamComplete streamComplete)
           
static void removeStreamCompletionHandler(java.lang.String key)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

ctxBag_

public static final java.util.Map<java.lang.String,java.util.List<StreamContextManager.StreamContext>> ctxBag_

streamStatusBag_

public static final java.util.Map<java.lang.String,java.util.List<StreamContextManager.StreamStatus>> streamStatusBag_

streamNotificationHandlers_

public static final java.util.Map<java.lang.String,IStreamComplete> streamNotificationHandlers_
Constructor Detail

StreamContextManager

public StreamContextManager()
Method Detail

getStreamContext

public static StreamContextManager.StreamContext getStreamContext(java.lang.String key)

getStreamStatus

public static StreamContextManager.StreamStatus getStreamStatus(java.lang.String key)

isDone

public static boolean isDone(java.lang.String key)

getStreamCompletionHandler

public static IStreamComplete getStreamCompletionHandler(java.lang.String key)

removeStreamCompletionHandler

public static void removeStreamCompletionHandler(java.lang.String key)

registerStreamCompletionHandler

public static void registerStreamCompletionHandler(java.lang.String key,
                                                   IStreamComplete streamComplete)

addStreamContext

public static void addStreamContext(java.lang.String key,
                                    StreamContextManager.StreamContext streamContext,
                                    StreamContextManager.StreamStatus streamStatus)


Copyright © 2009 The Apache Software Foundation