Spring/spring-amqp-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

3.0.0-M4; Boot 3.0.0-M4

Browse Source
This commit is contained in:
Gary Russell
2022-09-19 15:40:29 -04:00
parent 14a803637b
commit 70006cd7e5
8 changed files with 40 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
helloworld/pom.xml
View File

@@ -5,7 +5,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>org.springframework.samples.spring</groupId>
<artifactId>spring-rabbit-helloworld</artifactId>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>jar</packaging>
<name>Spring AMQP Hello World</name>
<url>https://www.spring.io</url>
@@ -16,7 +16,7 @@
</description>
<properties>
<maven.test.failure.ignore>true</maven.test.failure.ignore>
<spring.amqp.version>3.0.0-M3</spring.amqp.version>
<spring.amqp.version>3.0.0-M4</spring.amqp.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
<maven.test.failure.ignore>false</maven.test.failure.ignore>

6
log4j2/pom.xml
View File

@@ -5,7 +5,7 @@
<groupId>org.springframework.amqp.samples</groupId>
<artifactId>log4j2</artifactId>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>jar</packaging>
<name>log4j2</name>
@@ -14,7 +14,7 @@
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.0-M2</version>
<version>3.0.0-M4</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
@@ -22,7 +22,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
<spring.framework.version>5.3.13</spring.framework.version>
<spring.amqp.version>3.0.0-M3</spring.amqp.version>
<spring.amqp.version>3.0.0-M4</spring.amqp.version>
</properties>
<dependencies>

2
pom.xml
View File

@@ -4,7 +4,7 @@
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-amqp-samples</artifactId>
<name>Spring AMQP Samples</name>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>pom</packaging>
<modules>
<module>helloworld</module>

12
spring-rabbit-confirms-returns/pom.xml
View File

@@ -5,7 +5,7 @@
<groupId>org.springframework.amqp.samples</groupId>
<artifactId>spring-rabbit-confirms-returns</artifactId>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>jar</packaging>
<name>spring-rabbit-confirms-returns</name>
@@ -14,7 +14,7 @@
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.0-M2</version>
<version>3.0.0-M4</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
@@ -22,7 +22,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring.amqp.version>3.0.0-M3</spring.amqp.version>
<spring.amqp.version>3.0.0-M4</spring.amqp.version>
</properties>
<dependencies>
@@ -43,6 +43,12 @@
<version>${spring.amqp.version}</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-observation</artifactId>
<version>1.10.0-M5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>

9
spring-rabbit-confirms-returns/src/main/java/org/springframework/amqp/samples/confirms/SpringRabbitConfirmsReturnsApplication.java
View File

@@ -67,7 +67,7 @@ public class SpringRabbitConfirmsReturnsApplication {
return message;
}, correlationData);
correlationData.getFuture().get(10, TimeUnit.SECONDS);
System.out.println("Return received:" + correlationData.getReturnedMessage());
System.out.println("Return received:" + correlationData.getReturned());
}
private void setupCallbacks() {
@@ -79,9 +79,10 @@ public class SpringRabbitConfirmsReturnsApplication {
System.out.println("Received " + (ack ? " ack " : " nack ") + "for correlation: " + correlation);
}
});
this.rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
System.out.println("Returned: " + message + "\nreplyCode: " + replyCode
+ "\nreplyText: " + replyText + "\nexchange/rk: " + exchange + "/" + routingKey);
this.rabbitTemplate.setReturnsCallback(returned -> {
System.out.println("Returned: " + returned.getMessage() + "\nreplyCode: " + returned.getReplyCode()
+ "\nreplyText: " + returned.getReplyText() + "\nexchange/rk: "
+ returned.getExchange() + "/" + returned.getRoutingKey());
});
}

12
spring-rabbit-global-errorhandler/pom.xml
View File

@@ -5,7 +5,7 @@
<groupId>com.example</groupId>
<artifactId>spring-rabbit-global-errorhandler</artifactId>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>jar</packaging>
<name>spring-rabbit-global-errorhandler</name>
@@ -14,7 +14,7 @@
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.0-M2</version>
<version>3.0.0-M4</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
@@ -22,7 +22,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring.amqp.version>3.0.0-M3</spring.amqp.version>
<spring.amqp.version>3.0.0-M4</spring.amqp.version>
</properties>
<dependencies>
@@ -48,6 +48,12 @@
<version>${spring.amqp.version}</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-observation</artifactId>
<version>1.10.0-M5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>

12
spring-rabbit-json/pom.xml
View File

@@ -5,7 +5,7 @@
<groupId>com.example</groupId>
<artifactId>spring-rabbit-json</artifactId>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>jar</packaging>
<name>spring-rabbit-json</name>
@@ -14,7 +14,7 @@
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.0-M2</version>
<version>3.0.0-M4</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
@@ -22,7 +22,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring.amqp.version>3.0.0-M3</spring.amqp.version>
<spring.amqp.version>3.0.0-M4</spring.amqp.version>
</properties>
<dependencies>
@@ -48,6 +48,12 @@
<version>${spring.amqp.version}</version>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-observation</artifactId>
<version>1.10.0-M5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>

4
stocks/pom.xml
View File

@@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>org.springframework.samples.spring</groupId>
<artifactId>spring-rabbit-stocks</artifactId>
<version>3.0.0-M3</version>
<version>3.0.0-M4</version>
<packaging>war</packaging>
<name>Spring Rabbit Stocks</name>
<url>https://www.spring.io</url>
@@ -16,7 +16,7 @@
<properties>
<maven.test.failure.ignore>true</maven.test.failure.ignore>
<spring.framework.version>6.0.0-M2</spring.framework.version>
<spring.amqp.version>3.0.0-M3</spring.amqp.version>
<spring.amqp.version>3.0.0-M4</spring.amqp.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
<maven.test.failure.ignore>false</maven.test.failure.ignore>