You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ve...@apache.org on 2008/06/17 12:46:55 UTC
svn commit: r668613 - in
/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport:
amqp/AMQPListener.java fix/FIXTransportListener.java jms/JMSListener.java
mail/MailTransportListener.java vfs/VFSTransportListener.java
Author: veithen
Date: Tue Jun 17 03:46:55 2008
New Revision: 668613
URL: http://svn.apache.org/viewvc?rev=668613&view=rev
Log:
AbstractTransportListener based transports: Removed unnecessary checks in startListeningForService implementations ("private" services are now consistently ignored in AbstractTransportListener).
Modified:
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/amqp/AMQPListener.java
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSListener.java
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/mail/MailTransportListener.java
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/amqp/AMQPListener.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/amqp/AMQPListener.java?rev=668613&r1=668612&r2=668613&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/amqp/AMQPListener.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/amqp/AMQPListener.java Tue Jun 17 03:46:55 2008
@@ -80,10 +80,6 @@
@Override
protected void startListeningForService(AxisService service)
{
- if (service.getName().startsWith("__")) {
- return;
- }
-
AMQPConnection con = getConnectionFactory(service);
if (con == null) {
String msg = "Service " + service.getName() + " does not specify" +
Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java?rev=668613&r1=668612&r2=668613&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java Tue Jun 17 03:46:55 2008
@@ -76,11 +76,6 @@
* @param service the service for which to listen for messages
*/
protected void startListeningForService(AxisService service) {
-
- if (service.getName().startsWith("__")) {
- return;
- }
-
fixSessionFactory.createFIXAcceptor(service);
}
Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSListener.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSListener.java?rev=668613&r1=668612&r2=668613&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSListener.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSListener.java Tue Jun 17 03:46:55 2008
@@ -146,10 +146,6 @@
* @param service the service for which to listen for messages
*/
protected void startListeningForService(AxisService service) {
- if (service.getName().startsWith("__")) {
- return;
- }
-
JMSConnectionFactory cf = getConnectionFactory(service);
if (cf == null) {
String msg = "Service " + service.getName() + " does not specify" +
Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/mail/MailTransportListener.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/mail/MailTransportListener.java?rev=668613&r1=668612&r2=668613&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/mail/MailTransportListener.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/mail/MailTransportListener.java Tue Jun 17 03:46:55 2008
@@ -487,10 +487,6 @@
protected void startListeningForService(AxisService service) {
- if (service.getName().startsWith("__")) {
- return;
- }
-
Parameter param = service.getParameter(BaseConstants.TRANSPORT_POLL_INTERVAL);
long pollInterval = BaseConstants.DEFAULT_POLL_INTERVAL;
if (param != null && param.getValue() instanceof String) {
Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java?rev=668613&r1=668612&r2=668613&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java Tue Jun 17 03:46:55 2008
@@ -521,10 +521,6 @@
protected void startListeningForService(AxisService service) {
- if (service.getName().startsWith("__")) {
- return;
- }
-
Parameter param = service.getParameter(BaseConstants.TRANSPORT_POLL_INTERVAL);
long pollInterval = BaseConstants.DEFAULT_POLL_INTERVAL;
if (param != null && param.getValue() instanceof String) {