Code commits

Git

  • Marius Bogoevici <mbogoevici@pivotal.io>

    Marius Bogoevici <mbogoevici@pivotal.io> 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe

    GH-541 Make reconnect time for Kafka/Rabbit configurable

    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/pom.xml (version 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaConsumerProperties.java (version 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java (version 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitConsumerProperties.java (version 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java (version 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe)
    • spring-cloud-stream-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc (version 6c4a271078bd8e32ed3e88ebad2c08755a39bbbe)
  • Marius Bogoevici <mbogoevici@pivotal.io>

    Marius Bogoevici <mbogoevici@pivotal.io> 25a8415f56351bce64b692547f5c995ed6666650

    Move tests to AssertJ

    • spring-cloud-stream-binders/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/RawModeKafkaBinderTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/LocalizedQueueConnectionFactoryIntegrationTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderCleanerTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitBinderModuleTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-test/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/AbstractBinderTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/PartitionCapableBinderTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-binders/spring-cloud-stream-binder-test/src/test/java/org/springframework/cloud/stream/binder/MessageChannelBinderSupportTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-dependencies/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-integration-tests/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/ContentTypeOutboundSourceTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/CustomMessageConverterTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/MessageChannelConfigurerTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/StreamListenerTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-test-support-internal/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-test-support/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/ExampleTest.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/matcher/MessageQueueMatcherTest.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/pom.xml (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/aggregation/ModuleAggregationTest.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/BinderAwareChannelResolverTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/BinderFactoryConfigurationTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/ExtendedPropertiesBinderAwareChannelResolverTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/HealthIndicatorsConfigurationTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/InputOutputBindingOrderTest.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/LifecycleBinderTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/MessageConverterTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/ChannelBindingServiceTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • spring-cloud-stream/src/test/java/org/springframework/cloud/stream/config/SpelExpressionConverterConfigurationTests.java (version 25a8415f56351bce64b692547f5c995ed6666650)
    • src/checkstyle/checkstyle.xml (version 25a8415f56351bce64b692547f5c995ed6666650)