Package org.frankframework.jms

Class MessagingSource

java.lang.Object

org.frankframework.jms.MessagingSource

Direct Known Subclasses:

JmsMessagingSource

public class MessagingSource
extends Object

Generic Source for JMS connection, to be shared for JMS Objects that can use the same.

Author:

Gerrit van Brakel

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLOSE
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MessagingSource(String id, Context context, jakarta.jms.ConnectionFactory connectionFactory, Map<String,MessagingSource> siblingMap, String authAlias, boolean createDestination)

Method Summary

Modifier and Type	Method	Description
boolean	cleanUpOnClose()
boolean	close()
protected boolean	connectionsArePooled()
protected jakarta.jms.Connection	createConnection()
boolean	createDestination()
jakarta.jms.Session	createSession(boolean transacted, int acknowledgeMode)
void	decreaseReferences()
String	getAuthAlias()
jakarta.jms.ConnectionFactory	getConnectionFactory()
Context	getContext()
jakarta.jms.Queue	getDynamicReplyQueue(jakarta.jms.Session session)
String	getId()
protected String	getLogPrefix()
Object	getManagedConnectionFactory()	Retrieve the 'original' ConnectionFactory, used by the console (to get the Tibco QCF) in order to display queue message count.
String	getPhysicalName()
void	increaseReferences()
void	releaseDynamicReplyQueue(jakarta.jms.Queue replyQueue)
void	releaseSession(jakarta.jms.Session session)
boolean	sessionsArePooled()
void	setAuthAlias(String authAlias)
protected boolean	useSingleDynamicReplyQueue()

Methods inherited from class java.lang.Object

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

Field Details

CLOSE

public static final String CLOSE

See Also:

• Constant Field Values

log

protected org.apache.logging.log4j.Logger log

Constructor Details

MessagingSource

protected MessagingSource(String id,
 Context context,
 jakarta.jms.ConnectionFactory connectionFactory,
 Map<String,MessagingSource> siblingMap,
 String authAlias,
 boolean createDestination)

Method Details

close

public boolean close()
              throws IbisException

Throws:

IbisException

increaseReferences

public void increaseReferences()

decreaseReferences

public void decreaseReferences()

getContext

public Context getContext()

getConnectionFactory

public jakarta.jms.ConnectionFactory getConnectionFactory()

getManagedConnectionFactory

public Object getManagedConnectionFactory()

Retrieve the 'original' ConnectionFactory, used by the console (to get the Tibco QCF) in order to display queue message count.

getPhysicalName

public String getPhysicalName()

createConnection

protected jakarta.jms.Connection createConnection()
                                           throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

createSession

public jakarta.jms.Session createSession(boolean transacted,
 int acknowledgeMode)
                                  throws IbisException

Throws:

IbisException

releaseSession

public void releaseSession(jakarta.jms.Session session)

connectionsArePooled

protected boolean connectionsArePooled()

sessionsArePooled

public boolean sessionsArePooled()

useSingleDynamicReplyQueue

protected boolean useSingleDynamicReplyQueue()

cleanUpOnClose

public boolean cleanUpOnClose()

createDestination

public boolean createDestination()

getDynamicReplyQueue

public jakarta.jms.Queue getDynamicReplyQueue(jakarta.jms.Session session)
                                       throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

releaseDynamicReplyQueue

public void releaseDynamicReplyQueue(jakarta.jms.Queue replyQueue)
                              throws JmsException

Throws:

JmsException

getLogPrefix

protected String getLogPrefix()

getAuthAlias

public String getAuthAlias()

setAuthAlias

public void setAuthAlias(String authAlias)

getId

public String getId()