Class EmbeddedKafkaCondition

java.lang.Object

org.springframework.kafka.test.condition.EmbeddedKafkaCondition

All Implemented Interfaces:

org.junit.jupiter.api.extension.AfterAllCallback, org.junit.jupiter.api.extension.ExecutionCondition, org.junit.jupiter.api.extension.Extension, org.junit.jupiter.api.extension.ParameterResolver

public class EmbeddedKafkaCondition
extends Object
implements org.junit.jupiter.api.extension.ExecutionCondition, org.junit.jupiter.api.extension.AfterAllCallback, org.junit.jupiter.api.extension.ParameterResolver

JUnit5 condition for an embedded broker.

Since:

2.3

Author:

Gary Russell, Artem Bilan, Pawel Lozinski, Adrian Chlebosz, Michał Padula

Constructor Summary

Constructors

Constructor	Description
EmbeddedKafkaCondition()

Method Summary

Modifier and Type	Method	Description
void	afterAll(org.junit.jupiter.api.extension.ExtensionContext context)
org.junit.jupiter.api.extension.ConditionEvaluationResult	evaluateExecutionCondition(org.junit.jupiter.api.extension.ExtensionContext context)
static EmbeddedKafkaBroker	getBroker()
Object	resolveParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext, org.junit.jupiter.api.extension.ExtensionContext context)
boolean	supportsParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext, org.junit.jupiter.api.extension.ExtensionContext extensionContext)

Methods inherited from class java.lang.Object

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

Constructor Details

EmbeddedKafkaCondition

public EmbeddedKafkaCondition()

Method Details

supportsParameter

public boolean supportsParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext,
 org.junit.jupiter.api.extension.ExtensionContext extensionContext)
                          throws org.junit.jupiter.api.extension.ParameterResolutionException

Specified by:

supportsParameter in interface org.junit.jupiter.api.extension.ParameterResolver

Throws:

org.junit.jupiter.api.extension.ParameterResolutionException

resolveParameter

public Object resolveParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext,
 org.junit.jupiter.api.extension.ExtensionContext context)
                        throws org.junit.jupiter.api.extension.ParameterResolutionException

Specified by:

resolveParameter in interface org.junit.jupiter.api.extension.ParameterResolver

Throws:

org.junit.jupiter.api.extension.ParameterResolutionException

afterAll

public void afterAll(org.junit.jupiter.api.extension.ExtensionContext context)

Specified by:

afterAll in interface org.junit.jupiter.api.extension.AfterAllCallback

evaluateExecutionCondition

public org.junit.jupiter.api.extension.ConditionEvaluationResult evaluateExecutionCondition(org.junit.jupiter.api.extension.ExtensionContext context)

Specified by:

evaluateExecutionCondition in interface org.junit.jupiter.api.extension.ExecutionCondition

getBroker

public static EmbeddedKafkaBroker getBroker()