public class MessagingSource extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.logging.log4j.Logger |
log |
Modifier | Constructor and Description |
---|---|
protected |
MessagingSource(String id,
Context context,
javax.jms.ConnectionFactory connectionFactory,
Map<String,MessagingSource> siblingMap,
String authAlias,
boolean createDestination,
boolean useJms102) |
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() |
public boolean close() throws IbisException
IbisException
public void increaseReferences()
public void decreaseReferences()
public Context getContext()
public javax.jms.ConnectionFactory getConnectionFactory()
public Object getManagedConnectionFactory()
public String getPhysicalName()
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws IbisException
IbisException
public void releaseSession(javax.jms.Session session)
protected boolean connectionsArePooled()
public boolean sessionsArePooled()
protected boolean useSingleDynamicReplyQueue()
public boolean cleanUpOnClose()
public boolean createDestination()
public boolean useJms102()
public javax.jms.Queue getDynamicReplyQueue(javax.jms.Session session) throws javax.jms.JMSException
javax.jms.JMSException
public void releaseDynamicReplyQueue(javax.jms.Queue replyQueue) throws IfsaException
IfsaException
protected String getLogPrefix()
Copyright © 2023 Frank!Framework. All rights reserved.