Class TibcoUtils
java.lang.Object
org.frankframework.extensions.tibco.TibcoUtils
Some utilities for working with TIBCO.
- Author:
- Peter Leeuwenburgh, Jaco de Groot
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected static com.tibco.tibjms.admin.TibjmsAdmin
getActiveServerAdmin
(String url, CredentialFactory cf, Map<String, Object> connectionProperties) static jakarta.jms.Connection
getConnection
(String provUrl, String authAlias, String userName, String password) protected static long
getQueueFirstMessageAge
(jakarta.jms.Session jSession, String queueName) protected static long
getQueueFirstMessageAge
(jakarta.jms.Session jSession, String queueName, long currentTime) protected static long
getQueueFirstMessageAge
(jakarta.jms.Session jSession, String queueName, String messageSelector) protected static long
getQueueFirstMessageAge
(jakarta.jms.Session jSession, String queueName, String messageSelector, long currentTime) protected static long
getQueueFirstMessageAge
(jakarta.jms.Session jSession, String queueName, String messageSelector, long currentTime, boolean warn) static long
getQueueFirstMessageAge
(String provUrl, String authAlias, String userName, String password, String queueName) static long
getQueueFirstMessageAge
(String provUrl, String authAlias, String userName, String password, String queueName, String messageSelector) return -1: no message found return -2: message found, but not of type Message.protected static String
getQueueFirstMessageAgeAsString
(jakarta.jms.Session jSession, String queueName, long currentTime) protected static long
getQueueMessageCount
(jakarta.jms.Session jSession, String queueName, String messageSelector) static long
getQueueMessageCount
(String provUrl, String authAlias, String userName, String password, String queueName, String messageSelector)
-
Constructor Details
-
TibcoUtils
public TibcoUtils()
-
-
Method Details
-
getQueueFirstMessageAge
public static long getQueueFirstMessageAge(String provUrl, String authAlias, String userName, String password, String queueName) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAge
public static long getQueueFirstMessageAge(String provUrl, String authAlias, String userName, String password, String queueName, String messageSelector) throws jakarta.jms.JMSException return -1: no message found return -2: message found, but not of type Message.- Throws:
jakarta.jms.JMSException
-
getConnection
public static jakarta.jms.Connection getConnection(String provUrl, String authAlias, String userName, String password) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAge
protected static long getQueueFirstMessageAge(jakarta.jms.Session jSession, String queueName) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAge
protected static long getQueueFirstMessageAge(jakarta.jms.Session jSession, String queueName, String messageSelector) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAge
protected static long getQueueFirstMessageAge(jakarta.jms.Session jSession, String queueName, long currentTime) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAge
protected static long getQueueFirstMessageAge(jakarta.jms.Session jSession, String queueName, String messageSelector, long currentTime) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAge
protected static long getQueueFirstMessageAge(jakarta.jms.Session jSession, String queueName, String messageSelector, long currentTime, boolean warn) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueFirstMessageAgeAsString
-
getQueueMessageCount
public static long getQueueMessageCount(String provUrl, String authAlias, String userName, String password, String queueName, String messageSelector) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getQueueMessageCount
protected static long getQueueMessageCount(jakarta.jms.Session jSession, String queueName, String messageSelector) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
getActiveServerAdmin
protected static com.tibco.tibjms.admin.TibjmsAdmin getActiveServerAdmin(String url, CredentialFactory cf, Map<String, Object> connectionProperties) throws com.tibco.tibjms.admin.TibjmsAdminException- Throws:
com.tibco.tibjms.admin.TibjmsAdminException
-