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

Remove unused classes

Browse Source
This commit is contained in:
Dave Syer
2016-07-14 13:50:23 +01:00
parent 0522cbb4d6
commit 7fad0cd730
4 changed files with 0 additions and 247 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
samples/samples-messaging-spring/src/test/groovy/com/example/config/ContractVerifierSpringMessageBuilder.groovy
View File

@@ -1,51 +0,0 @@
/*
* Copyright 2013-2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.example.config
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessage
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessageBuilder
import org.springframework.jms.core.MessageCreator
import javax.jms.JMSException
import javax.jms.Message
import javax.jms.Session
/**
* @author Marcin Grzejszczak
*/
public class ContractVerifierSpringMessageBuilder<T extends Serializable> implements ContractVerifierMessageBuilder<T, Message> {
@Override
public ContractVerifierMessage<T, Message> create(final T payload, final Map<String, Object> headers) {
MessageCreator messageCreator = new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
Message message = session.createObjectMessage(payload);
headers.entrySet().each { Map.Entry<String, Object> entry ->
message.setObjectProperty(entry.key, entry.value)
}
return message
}
};
return new SpringMessage<>(messageCreator)
}
@Override
public ContractVerifierMessage<T, Message> create(Message message) {
return new SpringMessage<>(message);
}
}

93
samples/samples-messaging-spring/src/test/groovy/com/example/config/ContractVerifierSpringMessaging.groovy
View File

@@ -1,93 +0,0 @@
/*
* Copyright 2013-2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.example.config
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessage
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessageBuilder
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessaging
import org.springframework.jms.core.JmsTemplate
import org.springframework.stereotype.Component
import javax.jms.Message
import java.util.concurrent.TimeUnit
/**
* @author Marcin Grzejszczak
*/
@Component
public class ContractVerifierSpringMessaging<T> implements ContractVerifierMessaging<T, Message> {
private static final Logger log = LoggerFactory.getLogger(ContractVerifierSpringMessaging.class);
private final JmsTemplate jmsTemplate;
private final ContractVerifierMessageBuilder builder;
@Autowired
@SuppressWarnings("unchecked")
public ContractVerifierSpringMessaging(ContractVerifierMessageBuilder builder, JmsTemplate jmsTemplate) {
this.builder = builder
this.jmsTemplate = jmsTemplate
}
@Override
@SuppressWarnings("unchecked")
public void send(T payload, Map<String, Object> headers, String destination) {
send(builder.create(payload, headers), destination);
}
@Override
public void send(ContractVerifierMessage<T, Message> message, String destination) {
try {
jmsTemplate.send(destination, ((SpringMessage) message).messageCreator)
} catch (Exception e) {
log.error("Exception occurred while trying to send a message [" + message + "] " +
"to a channel with name [" + destination + "]", e);
throw e;
}
}
@Override
@SuppressWarnings("unchecked")
public ContractVerifierMessage<T, Message> receiveMessage(String destination, long timeout, TimeUnit timeUnit) {
try {
return builder.create(jmsTemplate.receive(destination));
} catch (Exception e) {
log.error("Exception occurred while trying to read a message from " +
" a channel with name [" + destination + "]", e);
throw new RuntimeException(e);
}
}
@Override
public ContractVerifierMessage<T, Message> receiveMessage(String destination) {
return receiveMessage(destination, 5, TimeUnit.SECONDS);
}
@Override
@SuppressWarnings("unchecked")
public ContractVerifierMessage<T, Message> create(T t, Map<String, Object> headers) {
return builder.create(t, headers);
}
@Override
@SuppressWarnings("unchecked")
public ContractVerifierMessage<T, Message> create(Message message) {
return builder.create(message);
}
}

35
samples/samples-messaging-spring/src/test/groovy/com/example/config/ManualContractVerifierConfiguration.groovy
View File

@@ -1,35 +0,0 @@
/*
* Copyright 2013-2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.example.config
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessaging
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.jms.core.JmsTemplate
/**
* @author Marcin Grzejszczak
*/
@Configuration
class ManualContractVerifierConfiguration {
@Bean
ContractVerifierMessaging contractVerifierMessaging(JmsTemplate jmsTemplate) {
return new ContractVerifierSpringMessaging(new ContractVerifierSpringMessageBuilder(), jmsTemplate);
}
}

68
samples/samples-messaging-spring/src/test/groovy/com/example/config/SpringMessage.groovy
View File

@@ -1,68 +0,0 @@
/*
* Copyright 2013-2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.example.config
import org.springframework.cloud.contract.verifier.messaging.ContractVerifierMessage
import org.springframework.jms.core.MessageCreator
import javax.jms.Message
import javax.jms.ObjectMessage
/**
* @author Marcin Grzejszczak
*/
public class SpringMessage<T> implements ContractVerifierMessage<T, Message> {
private final ObjectMessage messageDelegate;
final MessageCreator messageCreator;
public SpringMessage(Message messageDelegate) {
this.messageDelegate = (ObjectMessage) messageDelegate;
this.messageCreator = null
}
public SpringMessage(MessageCreator messageCreator) {
this.messageDelegate = null;
this.messageCreator = messageCreator
}
@Override
public T getPayload() {
return messageDelegate.getObject();
}
@Override
public Map<String, Object> getHeaders() {
Map<String, Object> headers = [:]
def enumeration = messageDelegate.propertyNames
while(enumeration.hasMoreElements()) {
String propertyName = enumeration.nextElement()
headers << [(propertyName) : messageDelegate.getObjectProperty(propertyName)]
}
return headers
}
@Override
Object getHeader(String key) {
return getHeaders().get(key)
}
@Override
public Message convert() {
return messageDelegate;
}
}