Package org.apache.kafka.common.test

Class MockFaultHandler

java.lang.Object

org.apache.kafka.common.test.MockFaultHandler

All Implemented Interfaces:

org.apache.kafka.server.fault.FaultHandler

public class MockFaultHandler
extends Object
implements org.apache.kafka.server.fault.FaultHandler

This is a fault handler suitable for use in JUnit tests. It will store the result of the first call to handleFault that was made.

Constructor Summary

Constructors

Constructor	Description
MockFaultHandler(String name)

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.server.fault.FaultHandlerException	firstException()
RuntimeException	handleFault(String failureMessage, Throwable cause)
void	maybeRethrowFirstException()
void	setIgnore(boolean ignore)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.server.fault.FaultHandler

handleFault

Constructor Details

MockFaultHandler

public MockFaultHandler(String name)

Method Details

handleFault

public RuntimeException handleFault(String failureMessage,
 Throwable cause)

Specified by:

handleFault in interface org.apache.kafka.server.fault.FaultHandler

maybeRethrowFirstException

public void maybeRethrowFirstException()

firstException

public org.apache.kafka.server.fault.FaultHandlerException firstException()

setIgnore

public void setIgnore(boolean ignore)