Package org.frankframework.extensions.tibco

Class TibcoUtils

java.lang.Object

org.frankframework.extensions.tibco.TibcoUtils

public class TibcoUtils
extends Object

Some utilities for working with TIBCO.

Author:

Peter Leeuwenburgh, Jaco de Groot

Method Summary

Modifier and Type	Method	Description
protected static void	closeAdminClient(com.tibco.tibjms.admin.TibjmsAdmin admin)
protected 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

protected static String getQueueFirstMessageAgeAsString(jakarta.jms.Session jSession,
 String queueName,
 long currentTime)

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

@Nullable
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

closeAdminClient

protected static void closeAdminClient(@Nullable
 com.tibco.tibjms.admin.TibjmsAdmin admin)