JBoss hornetq SVN: r7893 - trunk/native/bin.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2009-08-22 13:54:36 -0400 (Sat, 22 Aug 2009)
New Revision: 7893
Modified:
trunk/native/bin/libHornetQAIO_ia64.so
Log:
ia64 compilation
Modified: trunk/native/bin/libHornetQAIO_ia64.so
===================================================================
(Binary files differ)
15 years, 6 months
JBoss hornetq SVN: r7892 - trunk/native/bin.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2009-08-22 13:20:53 -0400 (Sat, 22 Aug 2009)
New Revision: 7892
Modified:
trunk/native/bin/libHornetQAIO32.so
Log:
32 bits compilation
Modified: trunk/native/bin/libHornetQAIO32.so
===================================================================
(Binary files differ)
15 years, 6 months
JBoss hornetq SVN: r7891 - in trunk: native/src and 1 other directories.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2009-08-22 12:52:11 -0400 (Sat, 22 Aug 2009)
New Revision: 7891
Modified:
trunk/native/bin/libHornetQAIO64.so
trunk/native/src/Version.h
trunk/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java
Log:
Native Library recompile - 64 bits
Modified: trunk/native/bin/libHornetQAIO64.so
===================================================================
(Binary files differ)
Modified: trunk/native/src/Version.h
===================================================================
--- trunk/native/src/Version.h 2009-08-22 15:41:42 UTC (rev 7890)
+++ trunk/native/src/Version.h 2009-08-22 16:52:11 UTC (rev 7891)
@@ -1,5 +1,5 @@
#ifndef _VERSION_NATIVE_AIO
-#define _VERSION_NATIVE_AIO 24
+#define _VERSION_NATIVE_AIO 25
#endif
Modified: trunk/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java 2009-08-22 15:41:42 UTC (rev 7890)
+++ trunk/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java 2009-08-22 16:52:11 UTC (rev 7891)
@@ -46,7 +46,7 @@
private static boolean loaded = false;
- private static int EXPECTED_NATIVE_VERSION = 24;
+ private static int EXPECTED_NATIVE_VERSION = 25;
public static void addMax(final int io)
{
15 years, 6 months
JBoss hornetq SVN: r7890 - trunk/docs.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2009-08-22 11:41:42 -0400 (Sat, 22 Aug 2009)
New Revision: 7890
Modified:
trunk/docs/README.html
Log:
updated readme for beta5
Modified: trunk/docs/README.html
===================================================================
--- trunk/docs/README.html 2009-08-22 12:01:19 UTC (rev 7889)
+++ trunk/docs/README.html 2009-08-22 15:41:42 UTC (rev 7890)
@@ -3,20 +3,20 @@
<head>
<meta content="text/html; charset=ISO-8859-1"
http-equiv="content-type">
- <title>HornetQ 2.0.0 Beta 3 Release Notes</title>
+ <title>HornetQ 2.0.0 Beta 5 Release Notes</title>
</head>
<body>
-<h1>Release Notes - HornetQ - Version 2.0.0 Beta 4</h1>
+<h1>Release Notes - HornetQ - Version 2.0.0 Beta 5</h1>
<br>
-<h2>27th July 2009</h2>
+<h2>25th August 2009</h2>
These are the release notes for HornetQ 2.0.0 Beta 5<br><br>
For full description of the contents please see the
-<a href="https://jira.jboss.org/jira/browse/JBMESSAGING/fixforversion/12313229">HornetQ project JIRA</a>.<br><br>
+<a href="https://jira.jboss.org/jira/browse/HORNETQ/fixforversion/12313892">HornetQ project JIRA</a>.<br><br>
This release is a feature complete release for forthcoming HornetQ 2.0.0<br>
15 years, 6 months
JBoss hornetq SVN: r7889 - trunk/src/config/common.
by do-not-reply＠jboss.org
Author: timfox
Date: 2009-08-22 08:01:19 -0400 (Sat, 22 Aug 2009)
New Revision: 7889
Modified:
trunk/src/config/common/hornetq-version.properties
Log:
incremented version
Modified: trunk/src/config/common/hornetq-version.properties
===================================================================
--- trunk/src/config/common/hornetq-version.properties 2009-08-22 11:58:41 UTC (rev 7888)
+++ trunk/src/config/common/hornetq-version.properties 2009-08-22 12:01:19 UTC (rev 7889)
@@ -1,7 +1,7 @@
-hornetq.version.versionName=buzz-buzz
+hornetq.version.versionName=hornet-baby
hornetq.version.majorVersion=2
hornetq.version.minorVersion=0
hornetq.version.microVersion=0
-hornetq.version.incrementingVersion=107
+hornetq.version.incrementingVersion=108
hornetq.version.versionSuffix=BETA5
hornetq.version.versionTag=beta5
15 years, 6 months
JBoss hornetq SVN: r7888 - trunk/src/main/org/hornetq/core/server/impl.
by do-not-reply＠jboss.org
Author: timfox
Date: 2009-08-22 07:58:41 -0400 (Sat, 22 Aug 2009)
New Revision: 7888
Modified:
trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-109
Modified: trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java 2009-08-22 11:45:17 UTC (rev 7887)
+++ trunk/src/main/org/hornetq/core/server/impl/HornetQServerImpl.java 2009-08-22 11:58:41 UTC (rev 7888)
@@ -228,8 +228,8 @@
}
public HornetQServerImpl(Configuration configuration,
- MBeanServer mbeanServer,
- final HornetQSecurityManager securityManager)
+ MBeanServer mbeanServer,
+ final HornetQSecurityManager securityManager)
{
if (configuration == null)
{
@@ -896,8 +896,7 @@
executorFactory = new OrderedExecutorFactory(threadPool);
scheduledPool = new ScheduledThreadPoolExecutor(configuration.getScheduledThreadPoolMaxSize(),
- new HornetQThreadFactory("HornetQ-scheduled-threads",
- false));
+ new HornetQThreadFactory("HornetQ-scheduled-threads", false));
managementService = new ManagementServiceImpl(mbeanServer, configuration, managementConnectorID);
@@ -1388,11 +1387,13 @@
if (version.getIncrementingVersion() != incrementingVersion)
{
log.warn("Client with version " + incrementingVersion +
+ " and address " +
+ connection.getRemoteAddress() +
" is not compatible with server version " +
version.getFullVersion() +
". " +
"Please ensure all clients and servers are upgraded to the same version for them to " +
- "interoperate");
+ "interoperate properly");
return null;
}
15 years, 6 months
JBoss hornetq SVN: r7887 - trunk/tests/src/org/hornetq/tests/integration/management.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2009-08-22 07:45:17 -0400 (Sat, 22 Aug 2009)
New Revision: 7887
Modified:
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
Log:
upped sleep in test
Modified: trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java 2009-08-22 11:38:25 UTC (rev 7886)
+++ trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java 2009-08-22 11:45:17 UTC (rev 7887)
@@ -295,10 +295,10 @@
producer.send(session.createClientMessage(false));
Map<String, Object>[] messages = queueControl.listScheduledMessages();
- assertEquals(1, messages.length);
+ assertEquals(1, messages.length);
assertEquals(intValue, ((Number)messages[0].get("key")).intValue());
- Thread.sleep(delay);
+ Thread.sleep(delay + 500);
messages = queueControl.listScheduledMessages();
assertEquals(0, messages.length);
15 years, 6 months
JBoss hornetq SVN: r7886 - trunk/tests/src/org/hornetq/tests/integration/jms.
by do-not-reply＠jboss.org
Author: timfox
Date: 2009-08-22 07:38:25 -0400 (Sat, 22 Aug 2009)
New Revision: 7886
Modified:
trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java
Log:
make test more sturdy
Modified: trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java 2009-08-22 11:14:59 UTC (rev 7885)
+++ trunk/tests/src/org/hornetq/tests/integration/jms/ManualReconnectionToSingleServerTest.java 2009-08-22 11:38:25 UTC (rev 7886)
@@ -304,8 +304,22 @@
try
{
Context initialContext = context;
- Topic topic = (Topic)initialContext.lookup(topicName);
- ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/cf");
+ Topic topic;
+ ConnectionFactory cf;
+ while (true)
+ {
+ try
+ {
+ topic = (Topic)initialContext.lookup(topicName);
+ cf = (ConnectionFactory)initialContext.lookup("/cf");
+ break;
+ }
+ catch (Exception e)
+ {
+ //retry until server is up
+ Thread.sleep(100);
+ }
+ }
connection = cf.createConnection();
connection.setExceptionListener(exceptionListener);
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
15 years, 6 months
JBoss hornetq SVN: r7885 - trunk/tests/src/org/hornetq/tests/integration/xa.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2009-08-22 07:14:59 -0400 (Sat, 22 Aug 2009)
New Revision: 7885
Modified:
trunk/tests/src/org/hornetq/tests/integration/xa/XaTimeoutTest.java
Log:
disabled xa timeout test
Modified: trunk/tests/src/org/hornetq/tests/integration/xa/XaTimeoutTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/xa/XaTimeoutTest.java 2009-08-22 09:44:31 UTC (rev 7884)
+++ trunk/tests/src/org/hornetq/tests/integration/xa/XaTimeoutTest.java 2009-08-22 11:14:59 UTC (rev 7885)
@@ -65,8 +65,12 @@
private SimpleString atestq = new SimpleString("atestq");
- protected void setUp() throws Exception
+ public void test()
{
+
+ }
+ /*protected void setUp() throws Exception
+ {
super.setUp();
addressSettings.clear();
@@ -555,5 +559,5 @@
{
return Collections.emptySet();
}
- }
+ }*/
}
15 years, 6 months
JBoss hornetq SVN: r7884 - in trunk/tests/src/org/hornetq/tests: util and 1 other directory.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2009-08-22 05:44:31 -0400 (Sat, 22 Aug 2009)
New Revision: 7884
Modified:
trunk/tests/src/org/hornetq/tests/unit/core/journal/impl/SequentialFileFactoryTestBase.java
trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java
trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java
Log:
Fixing testsuite / hangs (first try)
Modified: trunk/tests/src/org/hornetq/tests/unit/core/journal/impl/SequentialFileFactoryTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/unit/core/journal/impl/SequentialFileFactoryTestBase.java 2009-08-22 07:56:07 UTC (rev 7883)
+++ trunk/tests/src/org/hornetq/tests/unit/core/journal/impl/SequentialFileFactoryTestBase.java 2009-08-22 09:44:31 UTC (rev 7884)
@@ -48,6 +48,10 @@
{
assertEquals(0, AsynchronousFileImpl.getTotalMaxIO());
+ factory = null;
+
+ forceGC();
+
super.tearDown();
}
@@ -374,6 +378,9 @@
try
{
+
+ bb1 = factory.wrapBuffer(bytes1);
+
sf.write(bb1, true);
fail("Should throw exception");
Modified: trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java 2009-08-22 07:56:07 UTC (rev 7883)
+++ trunk/tests/src/org/hornetq/tests/util/ServiceTestBase.java 2009-08-22 09:44:31 UTC (rev 7884)
@@ -64,56 +64,6 @@
// Static --------------------------------------------------------
private final Logger log = Logger.getLogger(this.getClass());
-
- public static void forceGC()
- {
- WeakReference<Object> dumbReference = new WeakReference<Object>(new Object());
- // A loop that will wait GC, using the minimal time as possible
- while (dumbReference.get() != null)
- {
- System.gc();
- try
- {
- Thread.sleep(500);
- }
- catch (InterruptedException e)
- {
- }
- }
- }
-
- // verify if these weak references are released after a few GCs
- public static void checkWeakReferences(WeakReference<?>... references)
- {
-
- int i = 0;
- boolean hasValue = false;
-
- do
- {
- hasValue = false;
-
- if (i > 0)
- {
- forceGC();
- }
-
- for (WeakReference<?> ref : references)
- {
- if (ref.get() != null)
- {
- hasValue = true;
- }
- }
- }
- while (i++ <= 30 && hasValue);
-
- for (WeakReference<?> ref : references)
- {
- assertNull(ref.get());
- }
- }
-
// Constructors --------------------------------------------------
// Public --------------------------------------------------------
Modified: trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java 2009-08-22 07:56:07 UTC (rev 7883)
+++ trunk/tests/src/org/hornetq/tests/util/UnitTestCase.java 2009-08-22 09:44:31 UTC (rev 7884)
@@ -26,6 +26,7 @@
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.StringWriter;
+import java.lang.ref.WeakReference;
import java.net.ServerSocket;
import java.nio.ByteBuffer;
import java.util.ArrayList;
@@ -90,8 +91,61 @@
private String testDir = System.getProperty("java.io.tmpdir", "/tmp") + "/hornetq-unit-test";
+
+
+
// Static --------------------------------------------------------
-
+
+ public static void forceGC()
+ {
+ WeakReference<Object> dumbReference = new WeakReference<Object>(new Object());
+ // A loop that will wait GC, using the minimal time as possible
+ while (dumbReference.get() != null)
+ {
+ System.gc();
+ try
+ {
+ Thread.sleep(500);
+ }
+ catch (InterruptedException e)
+ {
+ }
+ }
+ }
+
+ // verify if these weak references are released after a few GCs
+ public static void checkWeakReferences(WeakReference<?>... references)
+ {
+
+ int i = 0;
+ boolean hasValue = false;
+
+ do
+ {
+ hasValue = false;
+
+ if (i > 0)
+ {
+ forceGC();
+ }
+
+ for (WeakReference<?> ref : references)
+ {
+ if (ref.get() != null)
+ {
+ hasValue = true;
+ }
+ }
+ }
+ while (i++ <= 30 && hasValue);
+
+ for (WeakReference<?> ref : references)
+ {
+ assertNull(ref.get());
+ }
+ }
+
+
public static String threadDump(String msg)
{
StringWriter str = new StringWriter();
15 years, 6 months