nl.nn.adapterframework.extensions.ifsa.jms

Class IfsaMessagingSource

java.lang.Object

nl.nn.adapterframework.jms.MessagingSource

nl.nn.adapterframework.extensions.ifsa.jms.IfsaMessagingSource

public class IfsaMessagingSource
extends MessagingSource

MessagingSource for IFSA connections. IFSA related IBIS objects can obtain an connection from this class. The physical connection is shared between all IBIS objects that have the same ApplicationID.

Author:

Gerrit van Brakel

Field Summary

Fields inherited from class nl.nn.adapterframework.jms.MessagingSource

log

Constructor Summary

Constructors

Constructor and Description
IfsaMessagingSource(String applicationId, com.ing.ifsa.IFSAContext context, com.ing.ifsa.IFSAQueueConnectionFactory connectionFactory, Map messagingSourceMap, boolean preJms22Api, boolean xaEnabled)

Method Summary

Modifier and Type	Method and Description
boolean	canUseIfsaModeSessions()
boolean	cleanUpOnClose()
void	closeReplyReceiver(javax.jms.QueueReceiver receiver)
javax.jms.Queue	getClientReplyQueue(javax.jms.QueueSession session) Retrieves the reply queue for a client connection.
protected javax.jms.ConnectionFactory	getConnectionFactoryDelegate()
javax.jms.QueueReceiver	getReplyReceiver(javax.jms.QueueSession session, javax.jms.Message sentMessage) Gets the queueReceiver, by utilizing the getInputQueue() method. For serverside getQueueReceiver() the creating of the QueueReceiver is done without the selector information, as this is not allowed by IFSA. For a clientconnection, the receiver is done with the getClientReplyQueue
boolean	hasDynamicReplyQueue()
boolean	isNotXaEnabledForSure()
boolean	isXaEnabled()
boolean	isXaEnabledForSure()
com.ing.ifsa.IFSAQueue	lookupProviderInput()
com.ing.ifsa.IFSAQueue	lookupService(String serviceId)
String	polishServiceId(String serviceId)
protected void	releaseClientReplyQueue(javax.jms.Queue replyQueue)
protected String	replaceLast(String string, char from, char to)
boolean	xaCapabilityCanBeDetermined()

Methods inherited from class nl.nn.adapterframework.jms.MessagingSource

close, connectionsArePooled, createConnection, createDestination, createSession, decreaseReferences, getConnectionFactory, getContext, getDynamicReplyQueue, getLogPrefix, getManagedConnectionFactory, getPhysicalName, increaseReferences, releaseDynamicReplyQueue, releaseSession, sessionsArePooled, useJms102, useSingleDynamicReplyQueue

Methods inherited from class java.lang.Object

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

Constructor Detail

IfsaMessagingSource

public IfsaMessagingSource(String applicationId,
                           com.ing.ifsa.IFSAContext context,
                           com.ing.ifsa.IFSAQueueConnectionFactory connectionFactory,
                           Map messagingSourceMap,
                           boolean preJms22Api,
                           boolean xaEnabled)

Method Detail

hasDynamicReplyQueue

public boolean hasDynamicReplyQueue()
                             throws IfsaException

Throws:

IfsaException

canUseIfsaModeSessions

public boolean canUseIfsaModeSessions()
                               throws IfsaException

Throws:

IfsaException

getClientReplyQueue

public javax.jms.Queue getClientReplyQueue(javax.jms.QueueSession session)
                                    throws IfsaException

Retrieves the reply queue for a client connection. If the client is transactional the replyqueue is retrieved from IFSA, otherwise a temporary (dynamic) queue is created.

Throws:

IfsaException

releaseClientReplyQueue

protected void releaseClientReplyQueue(javax.jms.Queue replyQueue)
                                throws IfsaException

Throws:

IfsaException

getReplyReceiver

public javax.jms.QueueReceiver getReplyReceiver(javax.jms.QueueSession session,
                                                javax.jms.Message sentMessage)
                                         throws IfsaException

Gets the queueReceiver, by utilizing the getInputQueue() method.
For serverside getQueueReceiver() the creating of the QueueReceiver is done without the selector information, as this is not allowed by IFSA.
For a clientconnection, the receiver is done with the getClientReplyQueue

Throws:

IfsaException

closeReplyReceiver

public void closeReplyReceiver(javax.jms.QueueReceiver receiver)
                        throws IfsaException

Throws:

IfsaException

lookupService

public com.ing.ifsa.IFSAQueue lookupService(String serviceId)
                                     throws IfsaException

Throws:

IfsaException

lookupProviderInput

public com.ing.ifsa.IFSAQueue lookupProviderInput()
                                           throws IfsaException

Throws:

IfsaException

replaceLast

protected String replaceLast(String string,
                             char from,
                             char to)

polishServiceId

public String polishServiceId(String serviceId)

cleanUpOnClose

public boolean cleanUpOnClose()

Overrides:

cleanUpOnClose in class MessagingSource

getConnectionFactoryDelegate

protected javax.jms.ConnectionFactory getConnectionFactoryDelegate()
                                                            throws IllegalArgumentException,
                                                                   SecurityException,
                                                                   IllegalAccessException,
                                                                   NoSuchFieldException

Overrides:

getConnectionFactoryDelegate in class MessagingSource

Throws:

IllegalArgumentException

SecurityException

IllegalAccessException

NoSuchFieldException

xaCapabilityCanBeDetermined

public boolean xaCapabilityCanBeDetermined()

isXaEnabled

public boolean isXaEnabled()

isXaEnabledForSure

public boolean isXaEnabledForSure()

isNotXaEnabledForSure

public boolean isNotXaEnabledForSure()