[BAEL-6138] - Receiving Push Notifications in PostreSQL with Spring Integration (eugenp#14467)

* [BAEL-4849] Article code

* [BAEL-4968] Article code

* [BAEL-4968] Article code

* [BAEL-4968] Article code

* [BAEL-4968] Remove extra comments

* [BAEL-5258] Article Code

* [BAEL-2765] PKCE Support for Secret Clients

* [BAEL-5698] Article code

* [BAEL-5698] Article code

* [BAEL-5905] Initial code

* [BAEL-5905] Article code

* [BAEL-5905] Relocate article code to new module

* [BAEL-6275] PostgreSQL NOTIFY/LISTEN

* [BAEL-6275] Minor correction

* BAEL-6138

* [BAEL-6138] WIP - LiveTest

* [BAEL-6138] Tutorial Code

* [BAEL-6138] Tutorial Code

---------

Co-authored-by: Philippe Sevestre <[email protected]>

Author: psevestre

messaging-modules/pom.xml

@@ -22,7 +22,7 @@
         <module>spring-amqp</module>
         <module>spring-apache-camel</module>
         <module>spring-jms</module>
-        <module>postgres-notify</module>
+		<module>postgres-notify</module>
     </modules>
 
 </project>

messaging-modules/postgres-notify/pom.xml

@@ -42,36 +42,37 @@
             <artifactId>lombok</artifactId>
             <optional>true</optional>
         </dependency>
-
+        
     </dependencies>
 
-    <properties>
-        <java.version>1.8</java.version>
-    </properties>
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-maven-plugin</artifactId>
-            </plugin>
-        </plugins>
-    </build>
-
-    <profiles>
-        <profile>
-            <id>instance1</id>
-            <build>
-                <plugins>
-                    <plugin>
-                        <groupId>org.springframework.boot</groupId>
-                        <artifactId>spring-boot-maven-plugin</artifactId>
-                        <configuration>
-                            <jvmArguments>-Dserver.port=8081</jvmArguments>
-                        </configuration>
-                    </plugin>
-                </plugins>
-            </build>
-        </profile>
 
-    </profiles>
+	<properties>
+		<java.version>1.8</java.version>
+	</properties>
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+	
+	<profiles>
+		<profile>
+			<id>instance1</id>
+			<build>
+				<plugins>
+					<plugin>
+						<groupId>org.springframework.boot</groupId>
+						<artifactId>spring-boot-maven-plugin</artifactId>
+						<configuration>
+							<jvmArguments>-Dserver.port=8081</jvmArguments>						
+						</configuration>						
+					</plugin>
+				</plugins>
+			</build>
+		</profile>
+		
+	</profiles>
 </project>

spring-integration/pom.xml

@@ -90,6 +90,11 @@
             <artifactId>jaxb-api</artifactId>
             <version>${jaxb-api.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <version>${postgresql.version}</version>
+        </dependency>
     </dependencies>
 
     <build>
@@ -126,6 +131,7 @@
         <javax-activation.version>1.1.1</javax-activation.version>
         <maven-eclipse-plugin.version>2.10</maven-eclipse-plugin.version>
         <jaxb-api.version>2.3.0</jaxb-api.version>
+        <postgresql.version>42.3.8</postgresql.version>
     </properties>
 
 </project>

spring-integration/src/main/java/com/baeldung/domain/Order.java

@@ -0,0 +1,92 @@
+package com.baeldung.domain;
+
+import java.math.BigDecimal;
+
+public class Order {
+
+    private Long id;
+    private String symbol;
+    private OrderType orderType;
+    private BigDecimal price;
+    private BigDecimal quantity;
+    
+    public Order() {}
+
+    public Order(Long id, String symbol, OrderType orderType, BigDecimal price, BigDecimal quantity) {
+        this.id = id;
+        this.symbol = symbol;
+        this.orderType = orderType;
+        this.price = price;
+        this.quantity = quantity;
+    }
+
+    /**
+     * @return the id
+     */
+    public Long getId() {
+        return id;
+    }
+
+    /**
+     * @param id the id to set
+     */
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    /**
+     * @return the symbol
+     */
+    public String getSymbol() {
+        return symbol;
+    }
+
+    /**
+     * @param symbol the symbol to set
+     */
+    public void setSymbol(String symbol) {
+        this.symbol = symbol;
+    }
+
+    /**
+     * @return the orderType
+     */
+    public OrderType getOrderType() {
+        return orderType;
+    }
+
+    /**
+     * @param orderType the orderType to set
+     */
+    public void setOrderType(OrderType orderType) {
+        this.orderType = orderType;
+    }
+
+    /**
+     * @return the price
+     */
+    public BigDecimal getPrice() {
+        return price;
+    }
+
+    /**
+     * @param price the price to set
+     */
+    public void setPrice(BigDecimal price) {
+        this.price = price;
+    }
+
+    /**
+     * @return the quantity
+     */
+    public BigDecimal getQuantity() {
+        return quantity;
+    }
+
+    /**
+     * @param quantity the quantity to set
+     */
+    public void setQuantity(BigDecimal quantity) {
+        this.quantity = quantity;
+    }
+}

spring-integration/src/main/java/com/baeldung/domain/OrderType.java

@@ -0,0 +1,16 @@
+package com.baeldung.domain;
+
+
+public enum OrderType {    
+    BUY('B'),
+    SELL('S');
+    private final char code;
+    
+    OrderType(char code) {
+        this.code = code;
+    }
+    
+    public char getCode() {
+        return code;
+    }
+}