You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2022/10/13 16:32:41 UTC
[activemq-artemis] branch main updated: ARTEMIS-4013 proper cxn unwrap in PostgresLargeObjectManager
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 <jo...@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();
}
}