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

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;