From d6b4e65f3fd1ff4a2763f8068cd6b3f7fe0b84e0 Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Mon, 8 Jan 2007 17:02:26 +0000 Subject: QPID-255 : Patch Supplied by Rob Godfrey - Change to use bespoke AMQShortString rather than converting to String git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@494121 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/cluster/ClusterCapabilityTest.java | 5 +++-- .../test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java | 3 ++- 2 files changed, 5 insertions(+), 3 deletions(-) (limited to 'java/cluster/src/test') diff --git a/java/cluster/src/test/java/org/apache/qpid/server/cluster/ClusterCapabilityTest.java b/java/cluster/src/test/java/org/apache/qpid/server/cluster/ClusterCapabilityTest.java index 76b1da8754..830a00f4c2 100644 --- a/java/cluster/src/test/java/org/apache/qpid/server/cluster/ClusterCapabilityTest.java +++ b/java/cluster/src/test/java/org/apache/qpid/server/cluster/ClusterCapabilityTest.java @@ -21,13 +21,14 @@ package org.apache.qpid.server.cluster; import junit.framework.TestCase; +import org.apache.qpid.framing.AMQShortString; public class ClusterCapabilityTest extends TestCase { public void testStartWithNull() { MemberHandle peer = new SimpleMemberHandle("myhost:9999"); - String c = ClusterCapability.add(null, peer); + AMQShortString c = ClusterCapability.add(null, peer); assertTrue(ClusterCapability.contains(c)); assertTrue(peer.matches(ClusterCapability.getPeer(c))); } @@ -35,7 +36,7 @@ public class ClusterCapabilityTest extends TestCase public void testStartWithText() { MemberHandle peer = new SimpleMemberHandle("myhost:9999"); - String c = ClusterCapability.add("existing text", peer); + AMQShortString c = ClusterCapability.add(new AMQShortString("existing text"), peer); assertTrue(ClusterCapability.contains(c)); assertTrue(peer.matches(ClusterCapability.getPeer(c))); } diff --git a/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java b/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java index c427285f4a..70209cd2a3 100644 --- a/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java +++ b/java/cluster/src/test/java/org/apache/qpid/server/cluster/SimpleClusterTest.java @@ -21,6 +21,7 @@ package org.apache.qpid.server.cluster; import org.apache.qpid.AMQException; +import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.url.URLSyntaxException; import org.apache.qpid.client.AMQConnection; import org.apache.qpid.client.AMQSession; @@ -36,7 +37,7 @@ public class SimpleClusterTest extends TestCase AMQConnection con = new AMQConnection("localhost:9000", "guest", "guest", "test", "/test"); AMQSession session = (AMQSession) con.createSession(false, AMQSession.NO_ACKNOWLEDGE); System.out.println("Session created"); - session.declareExchange("my_exchange", "direct"); + session.declareExchange(new AMQShortString("my_exchange"), new AMQShortString("direct")); System.out.println("Exchange declared"); con.close(); System.out.println("Connection closed"); -- cgit v1.2.1