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.log
Constructor and Description |
---|
IfsaMessagingSource(String applicationId,
com.ing.ifsa.IFSAContext context,
com.ing.ifsa.IFSAQueueConnectionFactory connectionFactory,
Map messagingSourceMap,
boolean preJms22Api,
boolean xaEnabled) |
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() |
close, connectionsArePooled, createConnection, createDestination, createSession, decreaseReferences, getConnectionFactory, getContext, getDynamicReplyQueue, getLogPrefix, getManagedConnectionFactory, getPhysicalName, increaseReferences, releaseDynamicReplyQueue, releaseSession, sessionsArePooled, useJms102, useSingleDynamicReplyQueue
public boolean hasDynamicReplyQueue() throws IfsaException
IfsaException
public boolean canUseIfsaModeSessions() throws IfsaException
IfsaException
public javax.jms.Queue getClientReplyQueue(javax.jms.QueueSession session) throws IfsaException
IfsaException
protected void releaseClientReplyQueue(javax.jms.Queue replyQueue) throws IfsaException
IfsaException
public javax.jms.QueueReceiver getReplyReceiver(javax.jms.QueueSession session, javax.jms.Message sentMessage) throws IfsaException
getInputQueue()
method.selector
information, as this is not allowed
by IFSA.getClientReplyQueue
IfsaException
public void closeReplyReceiver(javax.jms.QueueReceiver receiver) throws IfsaException
IfsaException
public com.ing.ifsa.IFSAQueue lookupService(String serviceId) throws IfsaException
IfsaException
public com.ing.ifsa.IFSAQueue lookupProviderInput() throws IfsaException
IfsaException
public boolean cleanUpOnClose()
cleanUpOnClose
in class MessagingSource
protected javax.jms.ConnectionFactory getConnectionFactoryDelegate() throws IllegalArgumentException, SecurityException, IllegalAccessException, NoSuchFieldException
public boolean xaCapabilityCanBeDetermined()
public boolean isXaEnabled()
public boolean isXaEnabledForSure()
public boolean isNotXaEnabledForSure()
Copyright © 2023 Frank!Framework. All rights reserved.