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

Class RxSendSubscribeOperationTest<T extends RxSendOperation>

    • Field Detail

      • destination

        protected String destination

      • partitionId

        protected String partitionId

      • sendSubscribeOperation

        protected T extends RxSendOperation sendSubscribeOperation

      • messages

        protected org.springframework.messaging.Message<User>[] messages

      • userMessage

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

    • Constructor Detail

      • RxSendSubscribeOperationTest

        public RxSendSubscribeOperationTest()

    • Method Detail

      • setCheckpointConfig

        protected abstract void setCheckpointConfig​(CheckpointConfig checkpointConfig)

      • setUp

        @BeforeEach
public abstract void setUp()

      • subscribe

        protected abstract rx.Observable<org.springframework.messaging.Message<?>> subscribe​(String destination,
                                                                                     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

        protected abstract void verifyCheckpointBatchSuccessCalled​(int times)

      • verifyCheckpointSuccessCalled

        protected abstract void verifyCheckpointSuccessCalled​(int times)

      • getPartitionId

        public String getPartitionId()

      • setPartitionId

        public void setPartitionId​(String partitionId)

      • getSendSubscribeOperation

        public T getSendSubscribeOperation()

      • setSendSubscribeOperation

        public void setSendSubscribeOperation​(T sendSubscribeOperation)