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

Class SendOperationTest<O extends SendOperation>

java.lang.Object

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

public abstract class SendOperationTest<O extends SendOperation>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	consumerGroup
protected String	destination
protected org.springframework.messaging.Message<?>	message
protected Mono<Void>	mono
protected String	payload
protected O	sendOperation

Constructor Summary

Constructors

Constructor	Description
SendOperationTest()

Method Summary

Modifier and Type	Method	Description
String	getConsumerGroup()
Mono<Void>	getMono()
String	getPayload()
O	getSendOperation()
void	setConsumerGroup(String consumerGroup)
void	setMono(Mono<Void> mono)
void	setPayload(String payload)
void	setSendOperation(O sendOperation)
protected abstract void	setupError(String errorMessage)
void	testSend()
void	testSendCreateSenderFailure()
void	testSendFailure()
protected abstract void	verifyGetClientCreator(int times)
protected abstract void	verifySendCalled(int times)
protected abstract void	whenSendWithException()

Methods inherited from class java.lang.Object

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

Field Detail

consumerGroup

protected String consumerGroup

destination

protected String destination

message

protected org.springframework.messaging.Message<?> message

mono

protected Mono<Void> mono

payload

protected String payload

sendOperation

protected O extends SendOperation sendOperation

Constructor Detail

SendOperationTest

public SendOperationTest()

Method Detail

setupError

protected abstract void setupError(String errorMessage)

testSend

@Test
public void testSend()

testSendCreateSenderFailure

@Test
public void testSendCreateSenderFailure()

testSendFailure

@Test
public void testSendFailure()

verifyGetClientCreator

protected abstract void verifyGetClientCreator(int times)

verifySendCalled

protected abstract void verifySendCalled(int times)

whenSendWithException

protected abstract void whenSendWithException()

getConsumerGroup

public String getConsumerGroup()

setConsumerGroup

public void setConsumerGroup(String consumerGroup)

getMono

public Mono<Void> getMono()

setMono

public void setMono(Mono<Void> mono)

getPayload

public String getPayload()

setPayload

public void setPayload(String payload)

getSendOperation

public O getSendOperation()

setSendOperation

public void setSendOperation(O sendOperation)