JBoss hornetq SVN: r11266 - in branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server: management/impl and 1 other directory.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 19:07:45 -0400 (Wed, 31 Aug 2011)
New Revision: 11266
Modified:
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java
Log:
fixing a memory leak on management in case of server restarts (another intermittent failure)
Modified: branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java 2011-08-31 22:42:32 UTC (rev 11265)
+++ branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java 2011-08-31 23:07:45 UTC (rev 11266)
@@ -513,7 +513,7 @@
if (System.currentTimeMillis() - start >= timeout)
{
- log.warn("Timed out waiting for backup activation to exit");
+ threadDump("Timed out waiting for backup activation to exit");
}
nodeManager.stopBackup();
@@ -861,6 +861,10 @@
nodeManager.stop();
nodeManager = null;
+
+ addressSettingsRepository.clear();
+
+ addressSettingsRepository.clearCache();
HornetQServerImpl.log.info("HornetQ Server version " + getVersion().getFullVersion() + " [" + tempNodeID + "] stopped");
Modified: branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java 2011-08-31 22:42:32 UTC (rev 11265)
+++ branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java 2011-08-31 23:07:45 UTC (rev 11266)
@@ -621,7 +621,29 @@
messageCounterManager.clear();
}
+
+ listeners.clear();
+
+ registry.clear();
+ messagingServer = null;
+
+ securityRepository = null;
+
+ addressSettingsRepository = null;
+
+ messagingServerControl = null;
+
+ messageCounterManager = null;
+
+ postOffice = null;
+
+ pagingManager = null;
+
+ storageManager = null;
+
+ messagingServer = null;
+
registeredNames.clear();
started = false;
13 years, 3 months
JBoss hornetq SVN: r11265 - branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 18:42:32 -0400 (Wed, 31 Aug 2011)
New Revision: 11265
Modified:
branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java
Log:
fixing another intermittent failure
Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java 2011-08-31 20:11:58 UTC (rev 11264)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java 2011-08-31 22:42:32 UTC (rev 11265)
@@ -54,6 +54,11 @@
setupCluster();
startServers(0, 1, 2, 3, 4);
+
+ for (int i = 0 ; i < 5; i++)
+ {
+ waitForTopology(servers[i], 5);
+ }
setupSessionFactory(0, isNetty());
setupSessionFactory(1, isNetty());
@@ -97,7 +102,12 @@
setupCluster();
startServers(0, 1, 2, 3, 4);
-
+
+ for (int i = 0 ; i < 5; i++)
+ {
+ waitForTopology(servers[i], 5);
+ }
+
setupSessionFactory(0, isNetty());
setupSessionFactory(1, isNetty());
setupSessionFactory(2, isNetty());
13 years, 3 months
JBoss hornetq SVN: r11264 - branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/failover.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 16:11:58 -0400 (Wed, 31 Aug 2011)
New Revision: 11264
Modified:
branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
Log:
trying to fix a possible thread leakage
Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java 2011-08-31 18:59:24 UTC (rev 11263)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java 2011-08-31 20:11:58 UTC (rev 11264)
@@ -103,11 +103,14 @@
liveServer.setIdentity(this.getClass().getSimpleName() + "/liveServer");
liveServer.start();
+
+ waitForServer(liveServer.getServer());
if (backupServer != null)
{
backupServer.setIdentity(this.getClass().getSimpleName() + "/backupServer");
backupServer.start();
+ waitForServer(backupServer.getServer());
}
}
13 years, 3 months
JBoss hornetq SVN: r11263 - branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/cluster/impl.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 14:59:24 -0400 (Wed, 31 Aug 2011)
New Revision: 11263
Modified:
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java
Log:
removing system.out
Modified: branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java 2011-08-31 18:25:27 UTC (rev 11262)
+++ branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java 2011-08-31 18:59:24 UTC (rev 11263)
@@ -484,7 +484,6 @@
localMember = new TopologyMember(nodeConnector, null);
}
- System.out.println("Adding local member " + localMember);
topology.updateAsLive(nodeID, localMember);
}
13 years, 3 months
JBoss hornetq SVN: r11262 - branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 14:25:27 -0400 (Wed, 31 Aug 2011)
New Revision: 11262
Modified:
branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java
Log:
fixing thread leakage
Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java 2011-08-31 18:24:06 UTC (rev 11261)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java 2011-08-31 18:25:27 UTC (rev 11262)
@@ -230,6 +230,8 @@
log.warn("Can't stop server2", e);
}
+ Thread.sleep(500);
+
((HornetQConnectionFactory)cf1).close();
((HornetQConnectionFactory)cf2).close();
@@ -252,9 +254,9 @@
}
catch (Throwable e)
{
- log.warn("Can't stop server2", e);
+ log.warn("Can't stop server1", e);
}
-
+
server1 = null;
jmsServer1 = null;
13 years, 3 months
JBoss hornetq SVN: r11261 - branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 14:24:06 -0400 (Wed, 31 Aug 2011)
New Revision: 11261
Modified:
branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java
Log:
fixing thread leakage
Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java 2011-08-31 18:20:37 UTC (rev 11260)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java 2011-08-31 18:24:06 UTC (rev 11261)
@@ -113,9 +113,11 @@
jmsServer1.start();
jmsServer1.activated();
+ waitForServer(jmsServer1.getHornetQServer());
jmsServer2.start();
jmsServer2.activated();
+ waitForServer(jmsServer2.getHornetQServer());
cf1 = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
generateInVMParams(0)));
13 years, 3 months
JBoss hornetq SVN: r11260 - branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/paging/cursor/impl.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 14:20:37 -0400 (Wed, 31 Aug 2011)
New Revision: 11260
Modified:
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java
Log:
JBPAPP-6522 - fixing
Modified: branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java 2011-08-31 16:07:12 UTC (rev 11259)
+++ branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/paging/cursor/impl/PageCursorProviderImpl.java 2011-08-31 18:20:37 UTC (rev 11260)
@@ -373,8 +373,12 @@
if (complete)
{
- log.info("Address " + pagingStore.getAddress() +
+ if (log.isDebugEnabled())
+ {
+ log.debug("Address " + pagingStore.getAddress() +
" is leaving page mode as all messages are consumed and acknowledged from the page store");
+ }
+
pagingStore.forceAnotherPage();
Page currentPage = pagingStore.getCurrentPage();
13 years, 3 months
JBoss hornetq SVN: r11259 - in branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration: spring and 1 other directory.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 12:07:12 -0400 (Wed, 31 Aug 2011)
New Revision: 11259
Modified:
branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java
Log:
fixing thread leaks
Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2011-08-31 12:54:38 UTC (rev 11258)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2011-08-31 16:07:12 UTC (rev 11259)
@@ -94,6 +94,8 @@
protected void setUp() throws Exception
{
super.setUp();
+
+ forceGC();
UnitTestCase.checkFreePort(ClusterTestBase.PORTS);
@@ -2040,7 +2042,6 @@
log.info("started server " + node);
waitForServer(servers[node]);
- Thread.sleep(100);
}
@@ -2055,6 +2056,7 @@
for (ClusterConnection cc : servers[node].getClusterManager().getClusterConnections())
{
cc.stop();
+ cc.flushExecutor();
}
}
}
Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java 2011-08-31 12:54:38 UTC (rev 11258)
+++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/integration/spring/SpringIntegrationTest.java 2011-08-31 16:07:12 UTC (rev 11259)
@@ -2,6 +2,7 @@
import junit.framework.Assert;
+import org.hornetq.core.logging.Logger;
import org.hornetq.jms.client.HornetQConnectionFactory;
import org.hornetq.jms.server.embedded.EmbeddedJMS;
import org.hornetq.tests.util.UnitTestCase;
@@ -15,6 +16,16 @@
*/
public class SpringIntegrationTest extends UnitTestCase
{
+ Logger log = Logger.getLogger(SpringIntegrationTest.class);
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+ // Need to force GC as the connection on the spring needs to be cleared
+ // otherwise the sprint thread may leak here
+ forceGC();
+ }
+
public void testSpring() throws Exception
{
System.out.println("Creating bean factory...");
13 years, 3 months
JBoss hornetq SVN: r11258 - branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-08-31 08:54:38 -0400 (Wed, 31 Aug 2011)
New Revision: 11258
Modified:
branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java
Log:
fixing thread leakage
Modified: branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java 2011-08-31 04:46:11 UTC (rev 11257)
+++ branches/Branch_2_2_EAP_cluster_clean3/src/main/org/hornetq/core/server/management/impl/ManagementServiceImpl.java 2011-08-31 12:54:38 UTC (rev 11258)
@@ -304,11 +304,14 @@
public void unregisterAcceptors()
{
List<String> acceptors = new ArrayList<String>();
- for (String resourceName : registry.keySet())
+ synchronized (this)
{
- if (resourceName.startsWith(ResourceNames.CORE_ACCEPTOR))
+ for (String resourceName : registry.keySet())
{
- acceptors.add(resourceName);
+ if (resourceName.startsWith(ResourceNames.CORE_ACCEPTOR))
+ {
+ acceptors.add(resourceName);
+ }
}
}
@@ -508,7 +511,7 @@
registry.put(resourceName, managedResource);
}
- public void unregisterFromRegistry(final String resourceName)
+ public synchronized void unregisterFromRegistry(final String resourceName)
{
registry.remove(resourceName);
}
13 years, 3 months
JBoss hornetq SVN: r11257 - branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp.
by do-not-reply＠jboss.org
Author: gaohoward
Date: 2011-08-31 00:46:11 -0400 (Wed, 31 Aug 2011)
New Revision: 11257
Added:
branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/HornetQStompException.java
branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompVersions.java
Modified:
branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/Stomp.java
branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompConnection.java
branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompProtocolManager.java
Log:
stomp 1.1 impl changes
Added: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/HornetQStompException.java
===================================================================
--- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/HornetQStompException.java (rev 0)
+++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/HornetQStompException.java 2011-08-31 04:46:11 UTC (rev 11257)
@@ -0,0 +1,49 @@
+package org.hornetq.core.protocol.stomp;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class HornetQStompException extends Exception {
+
+ private static final long serialVersionUID = -274452327574950068L;
+
+ private List<Header> headers = new ArrayList<Header>(10);
+ private String body;
+
+ public HornetQStompException(String msg)
+ {
+ super(msg);
+ }
+
+ public HornetQStompException(String msg, Throwable t)
+ {
+ super(msg, t);
+ }
+
+ public HornetQStompException(Throwable t)
+ {
+ super(t);
+ }
+
+ public void addHeader(String header, String value)
+ {
+ headers.add(new Header(header, value));
+ }
+
+ public void setBody(String body)
+ {
+ this.body = body;
+ }
+
+ private class Header
+ {
+ public String key;
+ public String val;
+
+ public Header(String key, String val)
+ {
+ this.key = key;
+ this.val = val;
+ }
+ }
+}
Modified: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/Stomp.java
===================================================================
--- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/Stomp.java 2011-08-31 04:43:40 UTC (rev 11256)
+++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/Stomp.java 2011-08-31 04:46:11 UTC (rev 11257)
@@ -159,6 +159,10 @@
String CLIENT_ID = "client-id";
String REQUEST_ID = "request-id";
+
+ //1.1
+ String ACCEPT_VERSION = "accept-version";
+ String HOST = "host";
}
public interface Error
Modified: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompConnection.java
===================================================================
--- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompConnection.java 2011-08-31 04:43:40 UTC (rev 11256)
+++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompConnection.java 2011-08-31 04:46:11 UTC (rev 11257)
@@ -15,7 +15,10 @@
import java.util.ArrayList;
import java.util.Collections;
+import java.util.HashSet;
import java.util.List;
+import java.util.Set;
+import java.util.StringTokenizer;
import java.util.concurrent.CopyOnWriteArrayList;
import org.hornetq.api.core.HornetQBuffer;
@@ -64,6 +67,8 @@
private final Object failLock = new Object();
private volatile boolean dataReceived;
+
+ private StompVersions version = StompVersions.V1_0;
public StompDecoder getDecoder()
{
@@ -349,4 +354,61 @@
}
}
+ /*
+ * accept-version value takes form of "v1,v2,v3..."
+ * we need to return the highest supported version
+ */
+ public void negotiateVersion(String acceptVersion) throws HornetQStompException
+ {
+ if (acceptVersion == null)
+ {
+ this.version = StompVersions.V1_0;
+ }
+ else
+ {
+ Set<String> requestVersions = new HashSet<String>();
+ StringTokenizer tokenizer = new StringTokenizer(acceptVersion, ",");
+ while (tokenizer.hasMoreTokens())
+ {
+ requestVersions.add(tokenizer.nextToken());
+ }
+
+ if (requestVersions.contains("1.1"))
+ {
+ this.version = StompVersions.V1_1;
+ }
+ else if (requestVersions.contains("1.0"))
+ {
+ this.version = StompVersions.V1_0;
+ }
+ else
+ {
+ //not a supported version!
+ HornetQStompException error = new HornetQStompException("Stomp versions not supported: " + acceptVersion);
+ error.addHeader("version", acceptVersion);
+ error.addHeader("content-type", "text/plain");
+ error.setBody("Supported protocol version are " + manager.getSupportedVersionsAsString());
+ throw error;
+ }
+ }
+ }
+
+ //reject if the host doesn't match
+ public void setHost(String host) throws HornetQStompException
+ {
+ if (host == null)
+ {
+ HornetQStompException error = new HornetQStompException("Header host is null");
+ error.setBody("Cannot accept null as host");
+ throw error;
+ }
+
+ String localHost = manager.getVirtualHostName();
+ if (!host.equals(localHost))
+ {
+ HornetQStompException error = new HornetQStompException("Header host doesn't match server host");
+ error.setBody("host " + host + " doesn't match server host name");
+ throw error;
+ }
+ }
}
Modified: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompProtocolManager.java
===================================================================
--- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompProtocolManager.java 2011-08-31 04:43:40 UTC (rev 11256)
+++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompProtocolManager.java 2011-08-31 04:46:11 UTC (rev 11257)
@@ -577,6 +577,9 @@
String passcode = (String)headers.get(Stomp.Headers.Connect.PASSCODE);
String clientID = (String)headers.get(Stomp.Headers.Connect.CLIENT_ID);
String requestID = (String)headers.get(Stomp.Headers.Connect.REQUEST_ID);
+ //since 1.1
+ String acceptVersion = (String)headers.get(Stomp.Headers.Connect.ACCEPT_VERSION);
+ String host = (String)headers.get(Stomp.Headers.Connect.HOST);
HornetQSecurityManager sm = server.getSecurityManager();
@@ -586,6 +589,8 @@
sm.validateUser(login, passcode);
}
+ connection.negotiateVersion(acceptVersion);
+ connection.setHost(host);
connection.setLogin(login);
connection.setPasscode(passcode);
connection.setClientID(clientID);
@@ -665,5 +670,16 @@
}
});
}
+
+ public String getSupportedVersionsAsString()
+ {
+ return "v1.0 v1.1";
+ }
+
+ public String getVirtualHostName()
+ {
+ return "hornetq";
+ }
+
// Inner classes -------------------------------------------------
}
Added: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompVersions.java
===================================================================
--- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompVersions.java (rev 0)
+++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompVersions.java 2011-08-31 04:46:11 UTC (rev 11257)
@@ -0,0 +1,26 @@
+/*
+ * Copyright 2010 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.hornetq.core.protocol.stomp;
+
+/**
+ * Stomp Spec Versions
+ *
+ * @author <a href="mailto:hgao@redhat.com">Howard Gao</a>
+ *
+ */
+public enum StompVersions
+{
+ V1_0,
+ V1_1
+}
13 years, 3 months