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() |
protected javax.jms.ConnectionFactory |
getConnectionFactoryDelegate() |
Context |
getContext() |
javax.jms.Queue |
getDynamicReplyQueue(javax.jms.Session session) |
protected String |
getLogPrefix() |
Object |
getManagedConnectionFactory() |
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()
protected javax.jms.ConnectionFactory getConnectionFactoryDelegate() throws IllegalArgumentException, SecurityException, IllegalAccessException, NoSuchFieldException
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.