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

Bumping versions

Browse Source
This commit is contained in:
buildmaster
2020-09-17 00:23:53 +00:00
parent 3a1e3c9640
commit ffd6574532
460 changed files with 3789 additions and 6477 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
tests/samples-messaging-amqp/src/main/java/com/example/AmqpMessagingApplication.java
View File

@@ -40,8 +40,7 @@ public class AmqpMessagingApplication {
@Bean
public MessageConverter messageConverter() {
final Jackson2JsonMessageConverter jsonMessageConverter = new Jackson2JsonMessageConverter(
new ObjectMapper());
final Jackson2JsonMessageConverter jsonMessageConverter = new Jackson2JsonMessageConverter(new ObjectMapper());
jsonMessageConverter.setCreateMessageIds(true);
final ContentTypeDelegatingMessageConverter messageConverter = new ContentTypeDelegatingMessageConverter(
jsonMessageConverter);
@@ -50,8 +49,7 @@ public class AmqpMessagingApplication {
}
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory,
MessageConverter messageConverter) {
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(messageConverter);
return rabbitTemplate;

14
tests/samples-messaging-amqp/src/main/java/com/example/Issue178ListenerConfiguration.java
View File

@@ -39,8 +39,8 @@ import org.springframework.context.annotation.Configuration;
class Issue178ListenerConfiguration {
@Bean
SimpleMessageListenerContainer messageListenerContainer(
ConnectionFactory connectionFactory, RabbitTemplate rabbitTemplate) {
SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory,
RabbitTemplate rabbitTemplate) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.addQueueNames("rated-item-service.rated-item-event.exchange");
@@ -54,12 +54,10 @@ class Issue178ListenerConfiguration {
public void onMessage(Message message) {
System.out.println("received: " + message);
try {
String payload = new ObjectMapper().writeValueAsString(new MyPojo(
"992e46d8-ab05-4a26-a740-6ef7b0daeab3", "CREATED"));
Message outputMessage = MessageBuilder.withBody(payload.getBytes())
.build();
rabbitTemplate.send(issue178OutputExchange().getName(), "routingkey",
outputMessage);
String payload = new ObjectMapper()
.writeValueAsString(new MyPojo("992e46d8-ab05-4a26-a740-6ef7b0daeab3", "CREATED"));
Message outputMessage = MessageBuilder.withBody(payload.getBytes()).build();
rabbitTemplate.send(issue178OutputExchange().getName(), "routingkey", outputMessage);
}
catch (JsonProcessingException e) {
throw new RuntimeException(e);

16
tests/samples-messaging-amqp/src/main/java/com/example/RabbitManager.java
View File

@@ -61,22 +61,18 @@ public class RabbitManager {
this.rabbitTemplate = rabbitTemplate;
}
@RabbitListener(
bindings = @QueueBinding(
value = @Queue, exchange = @Exchange(value = "input",
durable = "true", autoDelete = "false", type = "topic"),
key = "event"))
@RabbitListener(bindings = @QueueBinding(value = @Queue,
exchange = @Exchange(value = "input", durable = "true", autoDelete = "false", type = "topic"),
key = "event"))
public void newBook(Book book, @Headers Map<String, String> headers) {
LOG.info("Received new book with bookname = " + book.getName());
LOG.info("Headers = " + headers);
this.service.sendBook(book, headers.get("amqp_replyTo"));
}
@RabbitListener(
bindings = @QueueBinding(
value = @Queue, exchange = @Exchange(value = "input",
durable = "true", autoDelete = "false", type = "topic"),
key = "event2"))
@RabbitListener(bindings = @QueueBinding(value = @Queue,
exchange = @Exchange(value = "input", durable = "true", autoDelete = "false", type = "topic"),
key = "event2"))
public void newBook2(Book book, @Headers Map<String, String> headers) {
LOG.info("newBook2 Received new book with bookname = " + book.getName());
LOG.info("newBook2 Headers = " + headers);