Package org.apache.cassandra.net

Class OutboundSink

java.lang.Object

org.apache.cassandra.net.OutboundSink

public class OutboundSink
extends Object

A message sink that all outbound messages go through. Default sink OutboundSink.Sink used by MessagingService is MessagingService.doSend(Message, InetAddressAndPort, ConnectionType), which proceeds to send messages over the network, but it can be overridden to filter out certain messages, record the fact of attempted delivery, or delay they delivery. This facility is most useful for test code.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OutboundSink.Sink

Method Summary

Modifier and Type	Method	Description
void	accept(Message<?> message, InetAddressAndPort to, ConnectionType connectionType)
void	add(BiPredicate<Message<?>,InetAddressAndPort> allow)
void	clear()
void	remove(BiPredicate<Message<?>,InetAddressAndPort> allow)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

accept

public void accept(Message<?> message,
 InetAddressAndPort to,
 ConnectionType connectionType)

add

public void add(BiPredicate<Message<?>,InetAddressAndPort> allow)

remove

public void remove(BiPredicate<Message<?>,InetAddressAndPort> allow)

clear

public void clear()