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
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)
protected Context	getContext()
jakarta.jms.Queue	getDynamicReplyQueue(jakarta.jms.Session session)
protected String	getLogPrefix()
void	increaseReferences()
void	releaseDynamicReplyQueue(jakarta.jms.Queue replyQueue)
void	releaseSession(jakarta.jms.Session session)
boolean	sessionsArePooled()
protected boolean	useSingleDynamicReplyQueue()

Methods inherited from class java.lang.Object

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

Field Details

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()

getContext

protected Context getContext()

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()