[Java]: naming

schets · Aug 14, 2017 · f04eddc · f04eddc
1 parent ba4a6fe
commit f04eddc
Show file tree

Hide file tree

Showing 9 changed files with 11 additions and 11 deletions.
diff --git a/aeron-client/src/main/java/io/aeron/Subscription.java b/aeron-client/src/main/java/io/aeron/Subscription.java
@@ -355,7 +355,7 @@ public void forEachImage(final Consumer<Image> imageConsumer)
      * @param index in the array
      * @return image at given index
      */
-    public Image getImage(final int index)
+    public Image imageAtIndex(final int index)
     {
         return images[index];
     }

diff --git a/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveIpcThroughput.java b/aeron-samples/src/main/java/io/aeron/samples/EmbeddedExclusiveIpcThroughput.java
@@ -188,7 +188,7 @@ public void run()
                 Thread.yield();
             }
 
-            final Image image = subscription.getImage(0);
+            final Image image = subscription.imageAtIndex(0);
 
             long failedPolls = 0;
             long successfulPolls = 0;

diff --git a/aeron-samples/src/main/java/io/aeron/samples/EmbeddedIpcThroughput.java b/aeron-samples/src/main/java/io/aeron/samples/EmbeddedIpcThroughput.java
@@ -188,7 +188,7 @@ public void run()
                 Thread.yield();
             }
 
-            final Image image = subscription.getImage(0);
+            final Image image = subscription.imageAtIndex(0);
 
             long failedPolls = 0;
             long successfulPolls = 0;

diff --git a/aeron-samples/src/main/java/io/aeron/samples/EmbeddedPingPong.java b/aeron-samples/src/main/java/io/aeron/samples/EmbeddedPingPong.java
@@ -169,7 +169,7 @@ private static void roundTripMessages(
             Thread.yield();
         }
 
-        final Image image = pongSubscription.getImage(0);
+        final Image image = pongSubscription.imageAtIndex(0);
 
         for (int i = 0; i < numMessages; i++)
         {

diff --git a/aeron-samples/src/main/java/io/aeron/samples/Ping.java b/aeron-samples/src/main/java/io/aeron/samples/Ping.java
@@ -118,7 +118,7 @@ private static void roundTripMessages(
             Thread.yield();
         }
 
-        final Image image = subscription.getImage(0);
+        final Image image = subscription.imageAtIndex(0);
 
         for (int i = 0; i < count; i++)
         {

diff --git a/aeron-samples/src/main/java/io/aeron/samples/archive/EmbeddedReplayThroughput.java b/aeron-samples/src/main/java/io/aeron/samples/archive/EmbeddedReplayThroughput.java
@@ -145,7 +145,7 @@ private long makeRecording()
                 Thread.yield();
             }
 
-            final Image image = subscription.getImage(0);
+            final Image image = subscription.imageAtIndex(0);
 
             int i = 0;
             while (i < NUMBER_OF_MESSAGES)

diff --git a/aeron-system-tests/src/test/java/io/aeron/GapFillLossTest.java b/aeron-system-tests/src/test/java/io/aeron/GapFillLossTest.java
@@ -125,7 +125,7 @@ public void run()
                 idleStrategy.idle();
             }
 
-            final Image image = subscription.getImage(0);
+            final Image image = subscription.imageAtIndex(0);
 
             while (image.position() < FINAL_POSITION.get())
             {

diff --git a/aeron-system-tests/src/test/java/io/aeron/PubAndSubTest.java b/aeron-system-tests/src/test/java/io/aeron/PubAndSubTest.java
@@ -687,7 +687,7 @@ public void shouldReceivePublishedMessageOneForOneWithReSubscription(final Strin
                 TimeUnit.MILLISECONDS.toNanos(900));
         }
 
-        assertEquals(publication.position(), subscription.getImage(0).position());
+        assertEquals(publication.position(), subscription.imageAtIndex(0).position());
 
         subscription.close();
         stage.set(2);
@@ -698,7 +698,7 @@ public void shouldReceivePublishedMessageOneForOneWithReSubscription(final Strin
             Thread.yield();
         }
 
-        assertEquals(publication.position(), subscription.getImage(0).position());
+        assertEquals(publication.position(), subscription.imageAtIndex(0).position());
 
         for (int i = 0; i < numMessagesToSendStageTwo; i++)
         {
@@ -720,7 +720,7 @@ public void shouldReceivePublishedMessageOneForOneWithReSubscription(final Strin
                 TimeUnit.MILLISECONDS.toNanos(900));
         }
 
-        assertEquals(publication.position(), subscription.getImage(0).position());
+        assertEquals(publication.position(), subscription.imageAtIndex(0).position());
 
         verify(fragmentHandler, times(numMessagesToSendStageOne + numMessagesToSendStageTwo)).onFragment(
             any(DirectBuffer.class),

diff --git a/aeron-system-tests/src/test/java/io/aeron/archive/BasicArchiveTest.java b/aeron-system-tests/src/test/java/io/aeron/archive/BasicArchiveTest.java
@@ -118,7 +118,7 @@ public void shouldRecordAndReplay()
             recordingId, fromPosition, length, REPLAY_CHANNEL, REPLAY_STREAM_ID))
         {
             consume(subscription, messageCount, messagePrefix);
-            assertEquals(length, subscription.getImage(0).position());
+            assertEquals(length, subscription.imageAtIndex(0).position());
         }
     }