make helper functions protected instead of private

Author: rade

test/src/com/rabbitmq/client/test/functional/ExchangeExchangeBindings.java

@@ -53,7 +53,7 @@ public class ExchangeExchangeBindings extends BrokerTestCase {
     private QueueingConsumer[] consumers = new QueueingConsumer[] { null, null,
             null };
 
-    private void publishWithMarker(String x, String rk) throws IOException {
+    protected void publishWithMarker(String x, String rk) throws IOException {
         basicPublishVolatile(x, rk);
         basicPublishVolatile(MARKER, x, rk);
     }
@@ -86,7 +86,7 @@ protected void releaseResources() throws IOException {
         }
     }
 
-    private void consumeNoDuplicates(QueueingConsumer consumer)
+    protected void consumeNoDuplicates(QueueingConsumer consumer)
             throws ShutdownSignalException, InterruptedException {
         assertNotNull(consumer.nextDelivery(TIMEOUT));
         Delivery markerDelivery = consumer.nextDelivery(TIMEOUT);
@@ -217,7 +217,7 @@ public void testTopicExchange() throws IOException, ShutdownSignalException,
         channel.exchangeDelete("e");
     }
 
-    private void publishAndConsumeAll(String exchange)
+    protected void publishAndConsumeAll(String exchange)
         throws IOException, ShutdownSignalException, InterruptedException {
 
         for (String e : exchanges) {

test/src/com/rabbitmq/client/test/functional/ExchangeExchangeBindingsAutoDelete.java

@@ -38,19 +38,19 @@
 
 public class ExchangeExchangeBindingsAutoDelete extends BrokerTestCase {
 
-    private void declareExchanges(String[] names) throws IOException {
+    protected void declareExchanges(String[] names) throws IOException {
         for (String e : names) {
             channel.exchangeDeclare(e, "fanout", false, true, null);
         }
     }
 
-    private void assertExchangesNotExist(String[] names) throws IOException {
+    protected void assertExchangesNotExist(String[] names) throws IOException {
         for (String e : names) {
             assertExchangeNotExists(e);
         }
     }
 
-    private void assertExchangeNotExists(String name) throws IOException {
+    protected void assertExchangeNotExists(String name) throws IOException {
         try {
             connection.createChannel().exchangeDeclarePassive(name);
             fail("Exchange " + name + " still exists.");