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

Class SendOperationTest<O extends SendOperation>

java.lang.Object

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

public abstract class SendOperationTest<O extends SendOperation>
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
SendOperationTest()

Method Summary

Modifier and Type	Method	Description
Mono<Void>	getMono()
String	getPayload()
O	getSendOperation()
void	setMono(Mono<Void> mono)
void	setPayload(String payload)
void	setSendOperation(O sendOperation)
protected abstract void	setupError(String errorMessage)
void	testSendCreateSenderFailure()
void	testSendFailure()
void	testSendWithoutPartition()
void	testSendWithoutPartitionSupplier()
void	testSendWithPartitionId()
void	testSendWithPartitionKey()
void	testSendWithSessionId()
void	testSendWithSessionIdAndPartitionKeyDifferent()
protected abstract void	verifyGetClientCreator(int times)
protected abstract void	verifyPartitionSenderCalled(int times)
protected abstract void	verifySendCalled(int times)
protected abstract void	verifySendWithPartitionId(int times)
protected abstract void	verifySendWithPartitionKey(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

destination

protected String destination

message

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

mono

protected Mono<Void> mono

partitionKey

protected String partitionKey

payload

protected String payload

sendOperation

protected O extends SendOperation sendOperation

Constructor Detail

SendOperationTest

public SendOperationTest()

Method Detail

setupError

protected abstract void setupError(String errorMessage)

testSendCreateSenderFailure

@Test
public void testSendCreateSenderFailure()
                                 throws Throwable

Throws:

Throwable

testSendFailure

@Test
public void testSendFailure()

testSendWithPartitionId

@Test
public void testSendWithPartitionId()
                             throws ExecutionException,
                                    InterruptedException

Throws:

ExecutionException

InterruptedException

testSendWithPartitionKey

@Test
public void testSendWithPartitionKey()
                              throws ExecutionException,
                                     InterruptedException

Throws:

ExecutionException

InterruptedException

testSendWithSessionId

@Test
public void testSendWithSessionId()
                           throws ExecutionException,
                                  InterruptedException

Throws:

ExecutionException

InterruptedException

testSendWithSessionIdAndPartitionKeyDifferent

@Test
public void testSendWithSessionIdAndPartitionKeyDifferent()
                                                   throws ExecutionException,
                                                          InterruptedException

Throws:

ExecutionException

InterruptedException

testSendWithoutPartition

@Test
public void testSendWithoutPartition()
                              throws ExecutionException,
                                     InterruptedException

Throws:

ExecutionException

InterruptedException

testSendWithoutPartitionSupplier

@Test
public void testSendWithoutPartitionSupplier()
                                      throws ExecutionException,
                                             InterruptedException

Throws:

ExecutionException

InterruptedException

verifyGetClientCreator

protected abstract void verifyGetClientCreator(int times)

verifyPartitionSenderCalled

protected abstract void verifyPartitionSenderCalled(int times)

verifySendCalled

protected abstract void verifySendCalled(int times)

verifySendWithPartitionId

protected abstract void verifySendWithPartitionId(int times)

verifySendWithPartitionKey

protected abstract void verifySendWithPartitionKey(int times)

whenSendWithException

protected abstract void whenSendWithException()

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)