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

Class SendSubscribeWithGroupOperationTest<T extends SendOperation & SubscribeByGroupOperation>

java.lang.Object

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

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

public abstract class SendSubscribeWithGroupOperationTest<T extends SendOperation & SubscribeByGroupOperation>
extends SendSubscribeOperationTest<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected String	consumerGroup

Fields inherited from class com.azure.spring.integration.test.support.SendSubscribeOperationTest

destination, headers, messages, partitionId, payload, sendSubscribeOperation, user, userMessage

Constructor Summary

Constructors

Constructor	Description
SendSubscribeWithGroupOperationTest()

Method Summary

Modifier and Type	Method	Description
protected void	setCheckpointConfig(CheckpointConfig checkpointConfig)
protected void	subscribe(String destination, Consumer<org.springframework.messaging.Message<?>> consumer, Class<?> payloadType)

Methods inherited from class com.azure.spring.integration.test.support.SendSubscribeOperationTest

getPartitionId, getSendSubscribeOperation, manualCheckpointHandler, setPartitionId, setSendSubscribeOperation, setUp, testSendByte, testSendReceiveWithManualCheckpointMode, testSendReceiveWithRecordCheckpointMode, testSendString, testSendUser, verifyCheckpointBatchSuccessCalled, verifyCheckpointFailure, verifyCheckpointFailureCalled, verifyCheckpointSuccess, verifyCheckpointSuccessCalled, waitMillis

Methods inherited from class java.lang.Object

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

Field Detail

consumerGroup

protected String consumerGroup

Constructor Detail

SendSubscribeWithGroupOperationTest

public SendSubscribeWithGroupOperationTest()

Method Detail

subscribe

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

Specified by:

subscribe in class SendSubscribeOperationTest<T extends SendOperation & SubscribeByGroupOperation>

setCheckpointConfig

protected void setCheckpointConfig(CheckpointConfig checkpointConfig)

Specified by:

setCheckpointConfig in class SendSubscribeOperationTest<T extends SendOperation & SubscribeByGroupOperation>