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

Class SendSubscribeOperationTest<T extends SendOperation>

java.lang.Object

com.azure.spring.integration.test.support.reactor.SendSubscribeOperationTest<T>

Direct Known Subclasses:

SendSubscribeByGroupOperationTest

public abstract class SendSubscribeOperationTest<T extends SendOperation>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	destination
protected List<org.springframework.messaging.Message<User>>	messages
protected String	partitionId
protected T	sendSubscribeOperation
protected org.springframework.messaging.Message<User>	userMessage

Constructor Summary

Constructors

Constructor	Description
SendSubscribeOperationTest()

Method Summary

Modifier and Type	Method	Description
String	getPartitionId()
T	getSendSubscribeOperation()
protected abstract void	setCheckpointConfig(CheckpointConfig checkpointConfig)
void	setPartitionId(String partitionId)
void	setSendSubscribeOperation(T sendSubscribeOperation)
abstract void	setUp()
protected abstract void	subscribe(String destination, Consumer<org.springframework.messaging.Message<?>> consumer, Class<?> payloadType)
void	testSendByte()
void	testSendReceiveWithManualCheckpointMode()
void	testSendReceiveWithRecordCheckpointMode()
void	testSendString()
void	testSendUser()
protected abstract void	verifyCheckpointBatchSuccessCalled(int times)	Deprecated.
protected void	verifyCheckpointFailure(Checkpointer checkpointer)
protected abstract void	verifyCheckpointFailureCalled(int times)
protected void	verifyCheckpointSuccess(Checkpointer checkpointer)
protected abstract void	verifyCheckpointSuccessCalled(int times)

Methods inherited from class java.lang.Object

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

Field Detail

destination

protected String destination

partitionId

protected String partitionId

sendSubscribeOperation

protected T extends SendOperation sendSubscribeOperation

messages

protected List<org.springframework.messaging.Message<User>> messages

userMessage

protected org.springframework.messaging.Message<User> userMessage

Constructor Detail

SendSubscribeOperationTest

public SendSubscribeOperationTest()

Method Detail

setCheckpointConfig

protected abstract void setCheckpointConfig(CheckpointConfig checkpointConfig)

setUp

@BeforeEach
public abstract void setUp()

subscribe

protected abstract void subscribe(String destination,
                                  Consumer<org.springframework.messaging.Message<?>> consumer,
                                  Class<?> payloadType)

testSendByte

@Test
public void testSendByte()

testSendReceiveWithManualCheckpointMode

@Test
public void testSendReceiveWithManualCheckpointMode()

testSendReceiveWithRecordCheckpointMode

@Test
public void testSendReceiveWithRecordCheckpointMode()

testSendString

@Test
public void testSendString()

testSendUser

@Test
public void testSendUser()

verifyCheckpointBatchSuccessCalled

@Deprecated
protected abstract void verifyCheckpointBatchSuccessCalled(int times)

Deprecated.

verifyCheckpointFailure

protected void verifyCheckpointFailure(Checkpointer checkpointer)

verifyCheckpointFailureCalled

protected abstract void verifyCheckpointFailureCalled(int times)

verifyCheckpointSuccess

protected void verifyCheckpointSuccess(Checkpointer checkpointer)

verifyCheckpointSuccessCalled

protected abstract void verifyCheckpointSuccessCalled(int times)

getSendSubscribeOperation

public T getSendSubscribeOperation()

setSendSubscribeOperation

public void setSendSubscribeOperation(T sendSubscribeOperation)

getPartitionId

public String getPartitionId()

setPartitionId

public void setPartitionId(String partitionId)