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

Class RxSendSubscribeByGroupOperationTest<T extends RxSendOperation & RxSubscribeByGroupOperation>

java.lang.Object

com.azure.spring.integration.test.support.rx.RxSendSubscribeOperationTest<T>

com.azure.spring.integration.test.support.rx.RxSendSubscribeByGroupOperationTest<T>

public abstract class RxSendSubscribeByGroupOperationTest<T extends RxSendOperation & RxSubscribeByGroupOperation>
extends RxSendSubscribeOperationTest<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected String	consumerGroup

Fields inherited from class com.azure.spring.integration.test.support.rx.RxSendSubscribeOperationTest

destination, messages, partitionId, sendSubscribeOperation, userMessage

Constructor Summary

Constructors

Constructor	Description
RxSendSubscribeByGroupOperationTest()

Method Summary

Modifier and Type	Method	Description
String	getConsumerGroup()
protected void	setCheckpointConfig(CheckpointConfig checkpointConfig)
void	setConsumerGroup(String consumerGroup)
protected rx.Observable<org.springframework.messaging.Message<?>>	subscribe(String destination, Class<?> payloadType)

Methods inherited from class com.azure.spring.integration.test.support.rx.RxSendSubscribeOperationTest

getPartitionId, getSendSubscribeOperation, setPartitionId, setSendSubscribeOperation, setUp, testSendByte, testSendReceiveWithManualCheckpointMode, testSendReceiveWithRecordCheckpointMode, testSendString, testSendUser, verifyCheckpointBatchSuccessCalled, verifyCheckpointSuccessCalled

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

RxSendSubscribeByGroupOperationTest

public RxSendSubscribeByGroupOperationTest()

Method Detail

subscribe

protected rx.Observable<org.springframework.messaging.Message<?>> subscribe(String destination,
                                                                            Class<?> payloadType)

Specified by:

subscribe in class RxSendSubscribeOperationTest<T extends RxSendOperation & RxSubscribeByGroupOperation>

setCheckpointConfig

protected void setCheckpointConfig(CheckpointConfig checkpointConfig)

Specified by:

setCheckpointConfig in class RxSendSubscribeOperationTest<T extends RxSendOperation & RxSubscribeByGroupOperation>

getConsumerGroup

public String getConsumerGroup()

setConsumerGroup

public void setConsumerGroup(String consumerGroup)