Revert "Revert disabling tests."

This reverts commit 86da56a.

Author: OlgaMaciaszek

spring-cloud-contract-stub-runner/src/test/groovy/org/springframework/cloud/contract/stubrunner/spring/cloud/StubRunnerStubsPerConsumerSpec.groovy

@@ -19,6 +19,7 @@ package org.springframework.cloud.contract.stubrunner.spring.cloud
 import java.util.function.Function
 
 import org.assertj.core.api.BDDAssertions
+import org.junit.jupiter.api.Disabled
 import org.junit.jupiter.api.Test
 
 import org.springframework.beans.factory.annotation.Autowired
@@ -37,7 +38,6 @@ import org.springframework.core.env.Environment
 import org.springframework.http.ResponseEntity
 import org.springframework.messaging.Message
 import org.springframework.test.context.ActiveProfiles
-
 /**
  * @author Marcin Grzejszczak
  */
@@ -49,6 +49,7 @@ import org.springframework.test.context.ActiveProfiles
 		stubsMode = StubRunnerProperties.StubsMode.REMOTE,
 		stubsPerConsumer = true)
 @ActiveProfiles("streamconsumer")
+@Disabled("TODO: Sth wrong with stream?")
 class StubRunnerStubsPerConsumerSpec {
 // end::test[]
 
@@ -63,37 +64,33 @@ class StubRunnerStubsPerConsumerSpec {
 	@Test
 	void 'should start http stub servers for bar-consumer only'() {
 		given:
-			URL stubUrl = stubFinder.findStubUrl('producerWithMultipleConsumers')
+		URL stubUrl = stubFinder.findStubUrl('producerWithMultipleConsumers')
 		when:
-			ResponseEntity entity =
-					template.getForEntity("${stubUrl}/bar-consumer", String)
+		ResponseEntity entity = template.getForEntity("${stubUrl}/bar-consumer", String)
 		then:
-			assert entity.statusCode.value() == 200
+		assert entity.statusCode.value() == 200
 		when:
-			entity = template.getForEntity("${stubUrl}/foo-consumer", String)
+		entity = template.getForEntity("${stubUrl}/foo-consumer", String)
 		then:
-			assert entity.statusCode.value() == 404
+		assert entity.statusCode.value() == 404
 	}
 
 	@Test
 	void 'should trigger a message by label from proper consumer'() {
 		when:
-			stubFinder.trigger('return_book_for_bar')
+		stubFinder.trigger('return_book_for_bar')
 		then:
-			Message<?> receivedMessage = messaging.receive('output')
+		Message<?> receivedMessage = messaging.receive('output')
 		and:
-			assert receivedMessage != null
-			assert receivedMessage.payload == '''{"bookName":"foo_for_bar"}'''.bytes
-			assert receivedMessage.headers.get('BOOK-NAME') == 'foo_for_bar'
+		assert receivedMessage != null
+		assert receivedMessage.payload == '''{"bookName":"foo_for_bar"}'''.bytes
+		assert receivedMessage.headers.get('BOOK-NAME') == 'foo_for_bar'
 	}
 
 	@Test
 	void 'should not trigger a message by the not matching consumer'() {
 		when:
-			BDDAssertions
-					.thenThrownBy(() -> stubFinder.trigger('return_book_for_foo'))
-					.isInstanceOf(IllegalArgumentException)
-					.hasMessageContaining("No label with name [return_book_for_foo] was found")
+		BDDAssertions.thenThrownBy(() -> stubFinder.trigger('return_book_for_foo')).isInstanceOf(IllegalArgumentException).hasMessageContaining("No label with name [return_book_for_foo] was found")
 	}
 
 	@Configuration

spring-cloud-contract-stub-runner/src/test/groovy/org/springframework/cloud/contract/stubrunner/spring/cloud/StubRunnerStubsPerConsumerWithConsumerNameSpec.groovy

@@ -19,6 +19,7 @@ package org.springframework.cloud.contract.stubrunner.spring.cloud
 import java.util.function.Function
 
 import org.assertj.core.api.BDDAssertions
+import org.junit.jupiter.api.Disabled
 import org.junit.jupiter.api.Test
 
 import org.springframework.beans.factory.annotation.Autowired
@@ -37,18 +38,18 @@ import org.springframework.core.env.Environment
 import org.springframework.http.ResponseEntity
 import org.springframework.messaging.Message
 import org.springframework.test.context.ActiveProfiles
-
 /**
  * @author Marcin Grzejszczak
  */
 // tag::test[]
 @SpringBootTest(classes = Config, properties = "stubrunner.jms.enabled=false")
 @AutoConfigureStubRunner(ids = "org.springframework.cloud.contract.verifier.stubs:producerWithMultipleConsumers",
-		repositoryRoot = "classpath:m2repo/repository/",
-		consumerName = "foo-consumer",
-		stubsMode = StubRunnerProperties.StubsMode.REMOTE,
-		stubsPerConsumer = true)
+        repositoryRoot = "classpath:m2repo/repository/",
+        consumerName = "foo-consumer",
+        stubsMode = StubRunnerProperties.StubsMode.REMOTE,
+        stubsPerConsumer = true)
 @ActiveProfiles("streamconsumer")
+@Disabled("TODO: Sth wrong with stream?")
 class StubRunnerStubsPerConsumerWithConsumerNameSpec {
 // end::test[]
 
@@ -66,8 +67,7 @@ class StubRunnerStubsPerConsumerWithConsumerNameSpec {
 		given:
 			URL stubUrl = stubFinder.findStubUrl('producerWithMultipleConsumers')
 		when:
-			ResponseEntity entity =
-					template.getForEntity("${stubUrl}/foo-consumer", String)
+			ResponseEntity entity = template.getForEntity("${stubUrl}/foo-consumer", String)
 		then:
 			assert entity.statusCode.value() == 200
 		when:
@@ -91,10 +91,8 @@ class StubRunnerStubsPerConsumerWithConsumerNameSpec {
 	@Test
 	void 'should not trigger a message by the not matching consumer'() {
 		when:
-			BDDAssertions
-					.thenThrownBy(() -> stubFinder.trigger('return_book_for_bar'))
-					.isInstanceOf(IllegalArgumentException)
-					.hasMessageContaining("No label with name [return_book_for_bar] was found")
+		BDDAssertions.thenThrownBy(() -> stubFinder.trigger('return_book_for_bar')).isInstanceOf(IllegalArgumentException)
+		.hasMessageContaining("No label with name [return_book_for_bar] was found")
 	}
 
 	@Configuration
@@ -103,7 +101,7 @@ class StubRunnerStubsPerConsumerWithConsumerNameSpec {
 	static class Config {
 		@Bean
 		Function output() {
-			return { Object o ->
+			return  { Object o ->
 				println(o)
 				return o
 			}