svn commit: r418124 - /incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java

[chirino]

Author: chirino
Date: Thu Jun 29 12:52:10 2006
New Revision: 418124

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

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

Modified: 
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java?rev=418124&r1=418123&r2=418124&view=diff
==============================================================================
--- 
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
 (original)
+++ 
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
 Thu Jun 29 12:52:10 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);
+               }
             }
         }
     }