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

Class SendSubscribeOperationTest<T extends SendOperation>

java.lang.Object

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

Direct Known Subclasses:

SendSubscribeWithGroupOperationTest, SendSubscribeWithoutGroupOperationTest

public abstract class SendSubscribeOperationTest<T extends SendOperation>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	destination
protected Map<String,Object>	headers
protected List<org.springframework.messaging.Message<User>>	messages
protected String	partitionId
protected String	payload
protected T	sendSubscribeOperation
protected User	user
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 void	manualCheckpointHandler(org.springframework.messaging.Message<?> message)
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)
protected void	verifyCheckpointFailure(Checkpointer checkpointer)
protected abstract void	verifyCheckpointFailureCalled(int times)
protected void	verifyCheckpointSuccess(Checkpointer checkpointer)
protected abstract void	verifyCheckpointSuccessCalled(int times)
protected void	waitMillis(long millis)

Methods inherited from class java.lang.Object

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

Field Detail

sendSubscribeOperation

protected T extends SendOperation sendSubscribeOperation

partitionId

protected String partitionId

destination

protected String destination

payload

protected String payload

user

protected User user

headers

protected Map<String,Object> headers

userMessage

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

messages

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

Constructor Detail

SendSubscribeOperationTest

public SendSubscribeOperationTest()

Method Detail

setUp

@BeforeEach
public abstract void setUp()
                    throws Exception

Throws:

Exception

testSendString

@Test
public void testSendString()

testSendByte

@Test
public void testSendByte()

testSendUser

@Test
public void testSendUser()

testSendReceiveWithManualCheckpointMode

@Test
public void testSendReceiveWithManualCheckpointMode()

testSendReceiveWithRecordCheckpointMode

@Test
public void testSendReceiveWithRecordCheckpointMode()

manualCheckpointHandler

protected void manualCheckpointHandler(org.springframework.messaging.Message<?> message)

verifyCheckpointSuccessCalled

protected abstract void verifyCheckpointSuccessCalled(int times)

verifyCheckpointBatchSuccessCalled

protected abstract void verifyCheckpointBatchSuccessCalled(int times)

verifyCheckpointFailureCalled

protected abstract void verifyCheckpointFailureCalled(int times)

subscribe

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

setCheckpointConfig

protected abstract void setCheckpointConfig(CheckpointConfig checkpointConfig)

verifyCheckpointSuccess

protected void verifyCheckpointSuccess(Checkpointer checkpointer)

verifyCheckpointFailure

protected void verifyCheckpointFailure(Checkpointer checkpointer)

getPartitionId

public String getPartitionId()

setPartitionId

public void setPartitionId(String partitionId)

getSendSubscribeOperation

public T getSendSubscribeOperation()

setSendSubscribeOperation

public void setSendSubscribeOperation(T sendSubscribeOperation)

waitMillis

protected void waitMillis(long millis)