[hornetq-commits] JBoss hornetq SVN: r8660 - in trunk: src/main/org/hornetq/core/server/impl and 4 other directories.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Dec 10 04:19:17 EST 2009
Author: timfox
Date: 2009-12-10 04:19:17 -0500 (Thu, 10 Dec 2009)
New Revision: 8660
Modified:
trunk/src/main/org/hornetq/core/journal/impl/SyncSpeedTest.java
trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java
trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
trunk/src/main/org/hornetq/core/server/impl/ServerProducerCreditManager.java
trunk/tests/src/org/hornetq/tests/integration/InterceptorTest.java
trunk/tests/src/org/hornetq/tests/integration/client/InVMPersistentMessageBufferTest.java
trunk/tests/src/org/hornetq/tests/integration/client/NettyNonPersistentMessageBufferTest.java
trunk/tests/src/org/hornetq/tests/integration/client/NettyPersistentMessageBufferTest.java
trunk/tests/src/org/hornetq/tests/integration/client/NettyProducerFlowControlTest.java
trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java
trunk/tests/src/org/hornetq/tests/integration/paging/NettyPagingSendTest.java
trunk/tests/src/org/hornetq/tests/opt/SendTest.java
Log:
Corrected author header
Modified: trunk/src/main/org/hornetq/core/journal/impl/SyncSpeedTest.java
===================================================================
--- trunk/src/main/org/hornetq/core/journal/impl/SyncSpeedTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/src/main/org/hornetq/core/journal/impl/SyncSpeedTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -32,7 +32,7 @@
* This class just provides some diagnostics on how fast your disk can sync
* Useful when determining performance issues
*
- * @author tim fox
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a> fox
*
*
*/
Modified: trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -16,7 +16,7 @@
/**
* A CreditsAvailableRunnable
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerConsumerImpl.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -340,15 +340,15 @@
// TODO - why is this executed on a different thread?
public synchronized void forceDelivery(final long sequence)
- {
- // The prompt delivery is called synchronously to ensure the "forced delivery" message is
- // sent after any queue delivery.
+ {
executor.execute(new Runnable()
{
public void run()
{
try
{
+ // The prompt delivery is called synchronously to ensure the "forced delivery" message is
+ // sent after any queue delivery.
promptDelivery(false);
ServerMessage forcedDeliveryMessage = new ServerMessageImpl(storageManager.generateUniqueID(), 50);
Modified: trunk/src/main/org/hornetq/core/server/impl/ServerProducerCreditManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ServerProducerCreditManager.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerProducerCreditManager.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -18,7 +18,7 @@
/**
* A ServerProducerCreditManager
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/integration/InterceptorTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/InterceptorTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/InterceptorTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -37,7 +37,7 @@
*
* A InterceptorTest
*
- * @author tim fox
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a> fox
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/integration/client/InVMPersistentMessageBufferTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/InVMPersistentMessageBufferTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/client/InVMPersistentMessageBufferTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -16,7 +16,7 @@
/**
* A InVMPersistentMessageBufferTest
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/integration/client/NettyNonPersistentMessageBufferTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/NettyNonPersistentMessageBufferTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/client/NettyNonPersistentMessageBufferTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -16,7 +16,7 @@
/**
* A NettyNonPersistentMessageBufferTest
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/integration/client/NettyPersistentMessageBufferTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/NettyPersistentMessageBufferTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/client/NettyPersistentMessageBufferTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -16,7 +16,7 @@
/**
* A NettyPersistentMessageBufferTest
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/integration/client/NettyProducerFlowControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/NettyProducerFlowControlTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/client/NettyProducerFlowControlTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -16,7 +16,7 @@
/**
* A NettyProducerFlowControlTest
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/client/ProducerFlowControlTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -39,7 +39,7 @@
*
* A ProducerFlowControlTest
*
- * @author tim fox
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a> fox
*
*/
public class ProducerFlowControlTest extends ServiceTestBase
Modified: trunk/tests/src/org/hornetq/tests/integration/paging/NettyPagingSendTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/paging/NettyPagingSendTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/integration/paging/NettyPagingSendTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -16,7 +16,7 @@
/**
* A NettyPagingSendTest
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
Modified: trunk/tests/src/org/hornetq/tests/opt/SendTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/opt/SendTest.java 2009-12-10 09:09:49 UTC (rev 8659)
+++ trunk/tests/src/org/hornetq/tests/opt/SendTest.java 2009-12-10 09:19:17 UTC (rev 8660)
@@ -48,7 +48,7 @@
/**
* A SendTest
*
- * @author tim
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*
*/
More information about the hornetq-commits
mailing list