SpringCloud Stub 禁用功能

如果需要禁用此功能，請(qǐng)?jiān)O(shè)置stubrunner.stream.enabled=false屬性。

假設(shè)您具有以下Maven存儲(chǔ)庫(kù)，其中包含streamService應(yīng)用程序的已部署存根：

└── .m2
    └── repository
        └── io
            └── codearte
                └── accurest
                    └── stubs
                        └── streamService
                            ├── 0.0.1-SNAPSHOT
                            │   ├── streamService-0.0.1-SNAPSHOT.pom
                            │   ├── streamService-0.0.1-SNAPSHOT-stubs.jar
                            │   └── maven-metadata-local.xml
                            └── maven-metadata-local.xml

進(jìn)一步假設(shè)存根包含以下結(jié)構(gòu)：

├── META-INF
│   └── MANIFEST.MF
└── repository
    ├── accurest
    │   ├── bookDeleted.groovy
    │   ├── bookReturned1.groovy
    │   └── bookReturned2.groovy
    └── mappings

考慮以下合同（編號(hào)1）：

Contract.make {
	label 'return_book_1'
	input { triggeredBy('bookReturnedTriggered()') }
	outputMessage {
		sentTo('returnBook')
		body('''{ "bookName" : "foo" }''')
		headers { header('BOOK-NAME', 'foo') }
	}
}

現(xiàn)在考慮2：

Contract.make {
	label 'return_book_2'
	input {
		messageFrom('bookStorage')
		messageBody([
				bookName: 'foo'
		])
		messageHeaders { header('sample', 'header') }
	}
	outputMessage {
		sentTo('returnBook')
		body([
				bookName: 'foo'
		])
		headers { header('BOOK-NAME', 'foo') }
	}
}

現(xiàn)在考慮以下Spring配置：

stubrunner.repositoryRoot: classpath:m2repo/repository/
stubrunner.ids: org.springframework.cloud.contract.verifier.stubs:streamService:0.0.1-SNAPSHOT:stubs
stubrunner.stubs-mode: remote
spring:
  cloud:
    stream:
      bindings:
        output:
          destination: returnBook
        input:
          destination: bookStorage

server:
  port: 0

debug: true

這些示例適用于三種情況：

stubFinder.trigger('return_book_1')

Message<?> receivedMessage = messaging.receive('returnBook')

receivedMessage != null
assertJsons(receivedMessage.payload)
receivedMessage.headers.get('BOOK-NAME') == 'foo'

messaging.send(new BookReturned('foo'), [sample: 'header'], 'bookStorage')

Message<?> receivedMessage = messaging.receive('returnBook')

receivedMessage != null
assertJsons(receivedMessage.payload)
receivedMessage.headers.get('BOOK-NAME') == 'foo'

messaging.send(new BookReturned('foo'), [sample: 'header'], 'delete')