JBoss hornetq SVN: r10761 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-06-01 14:26:38 -0400 (Wed, 01 Jun 2011)
New Revision: 10761
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ServerMessageImpl.java
Log:
Adding useful debug for printPages and PrintData
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ServerMessageImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ServerMessageImpl.java 2011-06-01 17:33:20 UTC (rev 10760)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/impl/ServerMessageImpl.java 2011-06-01 18:26:38 UTC (rev 10761)
@@ -273,7 +273,8 @@
@Override
public String toString()
{
- return "ServerMessage[messageID=" + messageID + ", durable=" + durable + ", address=" + getAddress() + ",properties=" + properties.toString() + "]";
+ return "ServerMessage[messageID=" + messageID + ",priority=" + this.getPriority() +
+ ",expiration" + this.getExpiration() + ", durable=" + durable + ", address=" + getAddress() + ",properties=" + properties.toString() + "]";
}
// FIXME - this is stuff that is only used in large messages
13 years, 9 months
JBoss hornetq SVN: r10760 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-06-01 13:33:20 -0400 (Wed, 01 Jun 2011)
New Revision: 10760
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java
Log:
HORNETQ-705 - Reverting a change on blocking messages on the bridges
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-06-01 17:32:43 UTC (rev 10759)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-06-01 17:33:20 UTC (rev 10760)
@@ -362,8 +362,6 @@
serverLocator.setBackup(server.getConfiguration().isBackup());
serverLocator.setInitialConnectAttempts(-1);
serverLocator.setConfirmationWindowSize(0);
- serverLocator.setBlockOnDurableSend(false);
- serverLocator.setBlockOnNonDurableSend(false);
if(retryInterval > 0)
{
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java 2011-06-01 17:32:43 UTC (rev 10759)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterManagerImpl.java 2011-06-01 17:33:20 UTC (rev 10760)
@@ -684,8 +684,6 @@
serverLocator.setRetryIntervalMultiplier(config.getRetryIntervalMultiplier());
serverLocator.setClientFailureCheckPeriod(config.getClientFailureCheckPeriod());
serverLocator.setInitialConnectAttempts(config.getReconnectAttempts());
- serverLocator.setBlockOnDurableSend(false);
- serverLocator.setBlockOnNonDurableSend(false);
clusterLocators.add(serverLocator);
Bridge bridge = new BridgeImpl(serverLocator,
nodeUUID,
13 years, 9 months
JBoss hornetq SVN: r10759 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-06-01 13:32:43 -0400 (Wed, 01 Jun 2011)
New Revision: 10759
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java
Log:
Change on test
Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java 2011-06-01 15:27:02 UTC (rev 10758)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java 2011-06-01 17:32:43 UTC (rev 10759)
@@ -1031,9 +1031,9 @@
server1.start();
server0.start();
- final int numMessages = 10000;
+ final int numMessages = 1000;
- final int totalrepeats = 10;
+ final int totalrepeats = 3;
final AtomicInteger errors = new AtomicInteger(0);
13 years, 9 months
JBoss hornetq SVN: r10758 - branches.
by do-not-reply＠jboss.org
Author: gaohoward
Date: 2011-06-01 11:27:02 -0400 (Wed, 01 Jun 2011)
New Revision: 10758
Added:
branches/HORNETQ-681/
Log:
fix jira
13 years, 9 months