[hornetq-commits] JBoss hornetq SVN: r8660 - in trunk: src/main/org/hornetq/core/server/impl and 4 other directories.

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@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@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@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@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@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@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@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@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@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@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@jboss.com">Tim Fox</a> * * */