[activemq-artemis] branch main updated: ARTEMIS-4013 proper cxn unwrap in PostgresLargeObjectManager

[jbertram]

This is an automated email from the ASF dual-hosted git repository.

jbertram pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new 9a44d3e0ea ARTEMIS-4013 proper cxn unwrap in PostgresLargeObjectManager
     new d968f0c901 This closes #4231
9a44d3e0ea is described below

commit 9a44d3e0ea3259f6b187f48ae5f18e7f3c1a51b0
Author: Johannes Edmeier <johannes.edme...@steadybit.com>
AuthorDate: Fri Sep 23 16:21:10 2022 +0200

    ARTEMIS-4013 proper cxn unwrap in PostgresLargeObjectManager
---
 .../artemis/jdbc/store/file/PostgresLargeObjectManager.java         | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/PostgresLargeObjectManager.java
 
b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/PostgresLargeObjectManager.java
index 65d2d1e695..01583ac3ea 100644
--- 
a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/PostgresLargeObjectManager.java
+++ 
b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/PostgresLargeObjectManager.java
@@ -66,7 +66,7 @@ public class PostgresLargeObjectManager {
             throw new SQLException("Couldn't access 
org.postgresql.largeobject.LargeObjectManager", ex);
          }
       } else {
-         return ((PGConnection) 
unwrap(connection)).getLargeObjectAPI().createLO();
+         return 
(connection.unwrap(PGConnection.class)).getLargeObjectAPI().createLO();
       }
    }
 
@@ -80,7 +80,7 @@ public class PostgresLargeObjectManager {
             throw new SQLException("Couldn't access 
org.postgresql.largeobject.LargeObjectManager", ex);
          }
       } else {
-         return ((PGConnection) 
unwrap(connection)).getLargeObjectAPI().open(oid, mode);
+         return 
(connection.unwrap(PGConnection.class)).getLargeObjectAPI().open(oid, mode);
       }
    }
 
@@ -172,7 +172,7 @@ public class PostgresLargeObjectManager {
             throw new SQLException("Couldn't access 
org.postgresql.largeobject.LargeObjectManager", ex);
          }
       } else {
-         return ((PGConnection) unwrap(connection)).getLargeObjectAPI();
+         return (connection.unwrap(PGConnection.class)).getLargeObjectAPI();
       }
    }