Package org.apache.cassandra.net

Class InboundSink

java.lang.Object

org.apache.cassandra.net.InboundSink

All Implemented Interfaces:

Consumer<Message<?>>, InboundMessageHandlers.MessageConsumer

public class InboundSink
extends Object
implements InboundMessageHandlers.MessageConsumer

A message sink that all inbound messages go through. Default sink used by MessagingService is IVerbHandler.doVerb(Message), but it can be overridden to filter out certain messages, record the fact of attempted delivery, or delay arrival. This facility is most useful for test code. accept(Message) is invoked on a thread belonging to the Stage assigned to the Verb of the message.

Method Summary

Modifier and Type	Method	Description
void	accept(Message<?> message)
void	add(Predicate<Message<?>> allow)
boolean	allow(Message<?> message)	Deprecated. See CASSANDRA-15066
void	clear()
void	fail(Message.Header header, Throwable failure)
void	remove(Predicate<Message<?>> allow)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Method Details

fail

public void fail(Message.Header header,
 Throwable failure)

Specified by:

fail in interface InboundMessageHandlers.MessageConsumer

accept

public void accept(Message<?> message)

Specified by:

accept in interface Consumer<Message<?>>

add

public void add(Predicate<Message<?>> allow)

remove

public void remove(Predicate<Message<?>> allow)

clear

public void clear()

allow

@Deprecated(since="4.0")
public boolean allow(Message<?> message)

Deprecated.

See CASSANDRA-15066