[hornetq-commits] JBoss hornetq SVN: r11817 - in branches/HORNETQ-316: hornetq-core/src/main/java/org/hornetq/core/client/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: igarashitm
Date: 2011-12-02 16:07:27 -0500 (Fri, 02 Dec 2011)
New Revision: 11817

Modified:
   branches/HORNETQ-316/
   branches/HORNETQ-316/hornetq-core/src/main/java/org/hornetq/core/client/impl/StaticServerLocatorImpl.java
Log:
make serializable



Property changes on: branches/HORNETQ-316
___________________________________________________________________
Modified: svn:mergeinfo
   - /branches/HORNETQ-720_Replication:10878-11528
/branches/STOMP11:11225-11517
/trunk:11696-11800
   + /branches/HORNETQ-720_Replication:10878-11528
/branches/STOMP11:11225-11517
/trunk:11696-11816

Modified: branches/HORNETQ-316/hornetq-core/src/main/java/org/hornetq/core/client/impl/StaticServerLocatorImpl.java
===================================================================
--- branches/HORNETQ-316/hornetq-core/src/main/java/org/hornetq/core/client/impl/StaticServerLocatorImpl.java	2011-12-02 16:01:11 UTC (rev 11816)
+++ branches/HORNETQ-316/hornetq-core/src/main/java/org/hornetq/core/client/impl/StaticServerLocatorImpl.java	2011-12-02 21:07:27 UTC (rev 11817)
@@ -65,34 +65,7 @@
          setStaticTransportConfigurations(initialConnectors.toArray(new TransportConfiguration[0]));
       }
 
-      setDiscoveryGroup(new DiscoveryGroup()
-      {
-         @Override public void setNotificationService(NotificationService notificationService) {}
-         @Override public void start() throws Exception {}
-         @Override public void stop() throws Exception {}
-         @Override public void registerListener(DiscoveryListener listener) {}
-         @Override public void unregisterListener(DiscoveryListener listener) {}
-         @Override
-         public String getName()
-         {
-            return "StaticDiscoveryGroup";
-         }
-         @Override
-         public List<DiscoveryEntry> getDiscoveryEntries()
-         {
-            return null;
-         }
-         @Override
-         public boolean isStarted()
-         {
-            return true;
-         }
-         @Override
-         public boolean waitForBroadcast(long timeout)
-         {
-            return true;
-         }
-      });
+      setDiscoveryGroup(new StaticDiscovceryGroup());
 
       e.fillInStackTrace();
    }
@@ -148,6 +121,45 @@
       staticConnector.disconnect();
    }
 
+   private final class StaticDiscovceryGroup implements DiscoveryGroup, Serializable
+   {
+      private static final long serialVersionUID = -2886661316861662880L;
+
+      @Override public void setNotificationService(NotificationService notificationService) {}
+
+      @Override public void start() throws Exception {}
+
+      @Override public void stop() throws Exception {}
+
+      @Override public void registerListener(DiscoveryListener listener) {}
+
+      @Override public void unregisterListener(DiscoveryListener listener) {}
+
+      @Override
+      public String getName()
+      {
+         return "StaticDiscoveryGroup";
+      }
+
+      @Override
+      public List<DiscoveryEntry> getDiscoveryEntries()
+      {
+         return null;
+      }
+
+      @Override
+      public boolean isStarted()
+      {
+         return true;
+      }
+
+      @Override
+      public boolean waitForBroadcast(long timeout)
+      {
+         return true;
+      }
+   }
+
    private final class StaticConnector implements Serializable
    {
       private static final long serialVersionUID = 6772279632415242634l;
@@ -317,8 +329,10 @@
          super.finalize();
       }
 
-      private class Connector
+      private class Connector implements Serializable
       {
+         private static final long serialVersionUID = -8050491153483326679L;
+
          private final TransportConfiguration initialConnector;
 
          private volatile ClientSessionFactoryInternal factory;