Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

added patch for AMQ-1434 to allow transport listeners to be used with a connection factory for easy integration with Spring JmsTemplate etc 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@579498 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2007-09-26 08:08:14 +00:00
parent 2b063efafa
commit d48322690f
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
View File

@ -41,6 +41,7 @@ import org.apache.activemq.management.StatsCapable;
import org.apache.activemq.management.StatsImpl; import org.apache.activemq.management.StatsImpl;
import org.apache.activemq.transport.Transport; import org.apache.activemq.transport.Transport;
import org.apache.activemq.transport.TransportFactory; import org.apache.activemq.transport.TransportFactory;
import org.apache.activemq.transport.TransportListener;
import org.apache.activemq.util.IdGenerator; import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.util.IntrospectionSupport; import org.apache.activemq.util.IntrospectionSupport;
import org.apache.activemq.util.JMSExceptionSupport; import org.apache.activemq.util.JMSExceptionSupport;
@ -104,6 +105,7 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
private boolean watchTopicAdvisories = true; private boolean watchTopicAdvisories = true;
private int producerWindowSize = DEFAULT_PRODUCER_WINDOW_SIZE; private int producerWindowSize = DEFAULT_PRODUCER_WINDOW_SIZE;
private long warnAboutUnstartedConnectionTimeout = 500L; private long warnAboutUnstartedConnectionTimeout = 500L;
private TransportListener transportListener;
// ///////////////////////////////////////////// // /////////////////////////////////////////////
// //
@ -299,6 +301,9 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
connection.setWatchTopicAdvisories(isWatchTopicAdvisories()); connection.setWatchTopicAdvisories(isWatchTopicAdvisories());
connection.setProducerWindowSize(getProducerWindowSize()); connection.setProducerWindowSize(getProducerWindowSize());
connection.setWarnAboutUnstartedConnectionTimeout(getWarnAboutUnstartedConnectionTimeout()); connection.setWarnAboutUnstartedConnectionTimeout(getWarnAboutUnstartedConnectionTimeout());
if (transportListener != null) {
connection.addTransportListener(transportListener);
}
} }
// ///////////////////////////////////////////// // /////////////////////////////////////////////
@ -800,4 +805,20 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
public void setWarnAboutUnstartedConnectionTimeout(long warnAboutUnstartedConnectionTimeout) { public void setWarnAboutUnstartedConnectionTimeout(long warnAboutUnstartedConnectionTimeout) {
this.warnAboutUnstartedConnectionTimeout = warnAboutUnstartedConnectionTimeout; this.warnAboutUnstartedConnectionTimeout = warnAboutUnstartedConnectionTimeout;
} }
public TransportListener getTransportListener() {
return transportListener;
}
/**
* Allows a listener to be configured on the ConnectionFactory so that when this factory is used
* with frameworks which don't expose the Connection such as Spring JmsTemplate, you can still register
* a transport listener.
*
* @param transportListener sets the listener to be registered on all connections
* created by this factory
*/
public void setTransportListener(TransportListener transportListener) {
this.transportListener = transportListener;
}
} }