nl.nn.adapterframework.jms

Class MessagingSource

java.lang.Object

nl.nn.adapterframework.jms.MessagingSource

Direct Known Subclasses:

IfsaMessagingSource, 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 and Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	cleanUpOnClose()
boolean	close()
protected boolean	connectionsArePooled()
protected javax.jms.Connection	createConnection()
boolean	createDestination()
javax.jms.Session	createSession(boolean transacted, int acknowledgeMode)
void	decreaseReferences()
javax.jms.ConnectionFactory	getConnectionFactory()
Context	getContext()
javax.jms.Queue	getDynamicReplyQueue(javax.jms.Session session)
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(javax.jms.Queue replyQueue)
void	releaseSession(javax.jms.Session session)
boolean	sessionsArePooled()
boolean	useJms102()
protected boolean	useSingleDynamicReplyQueue()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

MessagingSource

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

Method Detail

close

public boolean close()
              throws IbisException

Throws:

IbisException

increaseReferences

public void increaseReferences()

decreaseReferences

public void decreaseReferences()

getContext

public Context getContext()

getConnectionFactory

public javax.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 javax.jms.Connection createConnection()
                                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createSession

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

Throws:

IbisException

releaseSession

public void releaseSession(javax.jms.Session session)

connectionsArePooled

protected boolean connectionsArePooled()

sessionsArePooled

public boolean sessionsArePooled()

useSingleDynamicReplyQueue

protected boolean useSingleDynamicReplyQueue()

cleanUpOnClose

public boolean cleanUpOnClose()

createDestination

public boolean createDestination()

useJms102

public boolean useJms102()

getDynamicReplyQueue

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

Throws:

javax.jms.JMSException

releaseDynamicReplyQueue

public void releaseDynamicReplyQueue(javax.jms.Queue replyQueue)
                              throws IfsaException

Throws:

IfsaException

getLogPrefix

protected String getLogPrefix()