activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r418123 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
Date Thu, 29 Jun 2006 19:51:13 GMT
Author: chirino
Date: Thu Jun 29 12:51:13 2006
New Revision: 418123

URL: http://svn.apache.org/viewvc?rev=418123&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-781

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java?rev=418123&r1=418122&r2=418123&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
Thu Jun 29 12:51:13 2006
@@ -256,10 +256,12 @@
                     String str=new String(packet.getData(),packet.getOffset(),packet.getLength());
                     processData(str);
                 }
-            }catch(SocketTimeoutException se){
+            } catch(SocketTimeoutException se){
                 // ignore
-            }catch(IOException e){
-                log.error("failed to process packet: "+e);
+            } catch(IOException e){
+            	if( started.get() ) {
+            		log.error("failed to process packet: "+e);
+            	}
             }
         }
     }



Mime
View raw message