Package com.azure.spring.integration.test.support.reactor

Class MessageHandlerTest<O extends SendOperation>

java.lang.Object

com.azure.spring.integration.test.support.reactor.MessageHandlerTest<O>

public abstract class MessageHandlerTest<O extends SendOperation>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	destination
protected String	dynamicDestination
protected DefaultMessageHandler	handler
protected Mono<Void>	mono
protected O	sendOperation

Constructor Summary

Constructors

Constructor	Description
MessageHandlerTest()

Method Summary

Modifier and Type	Method	Description
DefaultMessageHandler	getHandler()
Mono<Void>	getMono()
O	getSendOperation()
void	setHandler(DefaultMessageHandler handler)
void	setMono(Mono<Void> mono)
void	setSendOperation(O sendOperation)
abstract void	setUp()
void	testSend()
void	testSendCallback()
void	testSendDynamicTopic()
void	testSendSync()
void	testSendTimeout()

Methods inherited from class java.lang.Object

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

Field Detail

destination

protected String destination

dynamicDestination

protected String dynamicDestination

handler

protected DefaultMessageHandler handler

mono

protected Mono<Void> mono

sendOperation

protected O extends SendOperation sendOperation

Constructor Detail

MessageHandlerTest

public MessageHandlerTest()

Method Detail

setUp

public abstract void setUp()

testSend

@Test
public void testSend()

testSendCallback

@Test
public void testSendCallback()

testSendDynamicTopic

@Test
public void testSendDynamicTopic()

testSendSync

@Test
public void testSendSync()

testSendTimeout

@Test
public void testSendTimeout()

getMono

public Mono<Void> getMono()

setMono

public void setMono(Mono<Void> mono)

getHandler

public DefaultMessageHandler getHandler()

setHandler

public void setHandler(DefaultMessageHandler handler)

getSendOperation

public O getSendOperation()

setSendOperation

public void setSendOperation(O sendOperation)