[jboss-cvs] JBoss Messaging SVN: r5504 - in trunk: src/main/org/jboss/messaging/integration/transports/mina and 2 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Dec 10 09:15:58 EST 2008
Author: timfox
Date: 2008-12-10 09:15:58 -0500 (Wed, 10 Dec 2008)
New Revision: 5504
Modified:
trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java
trunk/src/main/org/jboss/messaging/integration/transports/mina/TransportConstants.java
trunk/src/main/org/jboss/messaging/integration/transports/netty/TransportConstants.java
trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java
Log:
Change netty and mina default port
Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java 2008-12-10 14:12:17 UTC (rev 5503)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java 2008-12-10 14:15:58 UTC (rev 5504)
@@ -345,7 +345,6 @@
flowControl(header.length);
currentChunkMessage = createFileMessage(header);
-
}
public synchronized void handleLargeMessageContinuation(final SessionReceiveContinuationMessage chunk) throws Exception
Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java 2008-12-10 14:12:17 UTC (rev 5503)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientProducerImpl.java 2008-12-10 14:15:58 UTC (rev 5504)
@@ -268,8 +268,7 @@
{
final int chunkLength;
final boolean lastChunk;
-
-
+
final int bytesToWrite = bodySize - pos;
if (bytesToWrite < minLargeMessageSize)
Modified: trunk/src/main/org/jboss/messaging/integration/transports/mina/TransportConstants.java
===================================================================
--- trunk/src/main/org/jboss/messaging/integration/transports/mina/TransportConstants.java 2008-12-10 14:12:17 UTC (rev 5503)
+++ trunk/src/main/org/jboss/messaging/integration/transports/mina/TransportConstants.java 2008-12-10 14:15:58 UTC (rev 5504)
@@ -53,7 +53,7 @@
public static final String DEFAULT_HOST = "localhost";
- public static final int DEFAULT_PORT = 5400;
+ public static final int DEFAULT_PORT = 5445;
public static final String DEFAULT_KEYSTORE_PATH = "messaging.keystore";
Modified: trunk/src/main/org/jboss/messaging/integration/transports/netty/TransportConstants.java
===================================================================
--- trunk/src/main/org/jboss/messaging/integration/transports/netty/TransportConstants.java 2008-12-10 14:12:17 UTC (rev 5503)
+++ trunk/src/main/org/jboss/messaging/integration/transports/netty/TransportConstants.java 2008-12-10 14:15:58 UTC (rev 5504)
@@ -67,7 +67,7 @@
public static final String DEFAULT_HOST = "localhost";
- public static final int DEFAULT_PORT = 5400;
+ public static final int DEFAULT_PORT = 5445;
public static final String DEFAULT_KEYSTORE_PATH = "messaging.keystore";
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java 2008-12-10 14:12:17 UTC (rev 5503)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java 2008-12-10 14:15:58 UTC (rev 5504)
@@ -216,7 +216,6 @@
testChunks(true, false, false, 100, 262144, true, RECEIVE_WAIT_TIME, 0);
}
-
public void testMessageChunkFilePersistenceBlockedPreCommit() throws Exception
{
testChunks(true, false, true, 100, 262144, true, RECEIVE_WAIT_TIME, 0);
More information about the jboss-cvs-commits
mailing list