Package org.apache.cassandra.streaming
Interface StreamingMessageSender
-
- All Known Implementing Classes:
NettyStreamingMessageSender
public interface StreamingMessageSender
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
boolean
connected()
void
initialize()
void
sendMessage(StreamMessage message)
-
-
-
Method Detail
-
initialize
void initialize() throws java.io.IOException
- Throws:
java.io.IOException
-
sendMessage
void sendMessage(StreamMessage message) throws java.io.IOException
- Throws:
java.io.IOException
-
connected
boolean connected()
-
close
void close()
-
-