org.springframework.kafka.test.condition

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 java.lang.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

Constructor Summary

Constructors

Constructor and Description
EmbeddedKafkaCondition()

Method Summary

Modifier and Type	Method and 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()
java.lang.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 Detail

EmbeddedKafkaCondition

public EmbeddedKafkaCondition()

Method Detail

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 java.lang.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()