Package com.azure.spring.servicebus.stream.binder.test

Class AzurePartitionBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>

  • Type Parameters:
    B - binder type
    CP - consumer properties type
    PP - producer properties type
    public abstract class AzurePartitionBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>
extends org.springframework.cloud.stream.binder.PartitionCapableBinderTests<B,​CP,​PP>
    Abstract Azure class that adds test support for Binder.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.springframework.cloud.stream.binder.AbstractBinderTests

        org.springframework.cloud.stream.binder.AbstractBinderTests.Station

    • Field Summary

      • Fields inherited from class org.springframework.cloud.stream.binder.PartitionCapableBinderTests

        spelExpressionParser

      • Fields inherited from class org.springframework.cloud.stream.binder.AbstractBinderTests

        applicationContext, logger, messageConverter, testBinder, timeoutMultiplier

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static void enableTests()
      Execute necessary operations to enable tests.
      org.springframework.cloud.stream.binder.Spy spyOn​(String name)  
      void testAnonymousGroup​(org.junit.jupiter.api.TestInfo testInfo)  
      void testClean​(org.junit.jupiter.api.TestInfo testInfo)  
      void testPartitionedModuleSpEL​(org.junit.jupiter.api.TestInfo testInfo)  
      void testSendAndReceiveNoOriginalContentType​(org.junit.jupiter.api.TestInfo testInfo)  
      protected boolean usesExplicitRouting()  

      • Methods inherited from class org.springframework.cloud.stream.binder.PartitionCapableBinderTests

        checkRkExpressionForPartitionedModuleSpEL, extractEndpoint, getClassUnderTestName, getEndpointRouting, getExpectedRoutingBaseDestination, testOneRequiredGroup, testTwoRequiredGroups

      • Methods inherited from class org.springframework.cloud.stream.binder.AbstractBinderTests

        before, binderBindUnbindLatency, cleanup, createBindableChannel, createBindableChannel, createBindableMessageSource, createConsumerBindingProperties, createConsumerProperties, createProducerBindingProperties, createProducerProperties, getBinder, getDestinationNameDelimiter, receive, receive, testSendAndReceive, testSendAndReceiveMultipleTopics, testSendJsonReceiveJsonWithStreamListener, testSendJsonReceivePojoWithStreamListener, testSendPojoReceivePojoWithStreamListener, testSendPojoReceivePojoWithStreamListenerDefaultContentType

    • Constructor Detail

      • AzurePartitionBinderTests

        public AzurePartitionBinderTests()

    • Method Detail

      • enableTests

        @BeforeAll
public static void enableTests()
        Execute necessary operations to enable tests.

      • usesExplicitRouting

        protected boolean usesExplicitRouting()
        Specified by:
        usesExplicitRouting in class org.springframework.cloud.stream.binder.PartitionCapableBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>

      • spyOn

        public org.springframework.cloud.stream.binder.Spy spyOn​(String name)
        Specified by:
        spyOn in class org.springframework.cloud.stream.binder.AbstractBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>

      • testClean

        public void testClean​(org.junit.jupiter.api.TestInfo testInfo)
               throws Exception
        Overrides:
        testClean in class org.springframework.cloud.stream.binder.AbstractBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>
        Throws:
        Exception

      • testPartitionedModuleSpEL

        public void testPartitionedModuleSpEL​(org.junit.jupiter.api.TestInfo testInfo)
        Overrides:
        testPartitionedModuleSpEL in class org.springframework.cloud.stream.binder.PartitionCapableBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>

      • testAnonymousGroup

        public void testAnonymousGroup​(org.junit.jupiter.api.TestInfo testInfo)
        Overrides:
        testAnonymousGroup in class org.springframework.cloud.stream.binder.PartitionCapableBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>

      • testSendAndReceiveNoOriginalContentType

        public void testSendAndReceiveNoOriginalContentType​(org.junit.jupiter.api.TestInfo testInfo)
                                             throws Exception
        Overrides:
        testSendAndReceiveNoOriginalContentType in class org.springframework.cloud.stream.binder.AbstractBinderTests<B extends org.springframework.cloud.stream.binder.AbstractTestBinder<? extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,​CP,​PP>,​CP,​PP>,​CP extends org.springframework.cloud.stream.binder.ConsumerProperties,​PP extends org.springframework.cloud.stream.binder.ProducerProperties>
        Throws:
        Exception