SpringCloud/spring-cloud-contract
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bump camel version (#733)

Browse Source
This commit is contained in:
Yuriy
2018-09-19 18:55:09 +03:00
committed by Marcin Grzejszczak
parent 1b36df5caf
commit ccd4e2f532
3 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/camel/CamelStubMessages.java
View File

@@ -64,7 +64,7 @@ public class CamelStubMessages implements MessageVerifier<Message> {
@Override
public <T> void send(T payload, Map<String, Object> headers, String destination) {
send(this.builder.create(payload, headers), destination);
send(this.builder.create(this.context, payload, headers), destination);
}
@Override

5
spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/camel/ContractVerifierCamelMessageBuilder.java
View File

@@ -18,6 +18,7 @@ package org.springframework.cloud.contract.verifier.messaging.camel;
import java.util.Map;
import org.apache.camel.CamelContext;
import org.apache.camel.Message;
import org.apache.camel.impl.DefaultMessage;
@@ -26,8 +27,8 @@ import org.apache.camel.impl.DefaultMessage;
*/
class ContractVerifierCamelMessageBuilder {
public <T> Message create(T payload, Map<String, Object> headers) {
DefaultMessage message = new DefaultMessage();
public <T> Message create(CamelContext camelContext, T payload, Map<String, Object> headers) {
DefaultMessage message = new DefaultMessage(camelContext);
message.setBody(payload);
message.setHeaders(headers);
return message;