FromFilesMessageBodySource => LocalFilesMessageBodySource

Author: michaelklishin

src/main/java/com/rabbitmq/perf/FromFilesMessageBodySource.java renamed to src/main/java/com/rabbitmq/perf/LocalFilesMessageBodySource.java

@@ -22,13 +22,13 @@
 /**
  *
  */
-public class FromFilesMessageBodySource implements MessageBodySource {
+public class LocalFilesMessageBodySource implements MessageBodySource {
 
     private final List<byte[]> bodies;
 
     private final String contentType;
 
-    public FromFilesMessageBodySource(List<String> filesNames, String contentType) throws IOException {
+    public LocalFilesMessageBodySource(List<String> filesNames, String contentType) throws IOException {
         bodies = new ArrayList<byte[]>(filesNames.size());
         for (String fileName : filesNames) {
             File file = new File(fileName.trim());
@@ -51,7 +51,7 @@ public FromFilesMessageBodySource(List<String> filesNames, String contentType) t
         this.contentType = contentType;
     }
 
-    public FromFilesMessageBodySource(List<String> filesNames) throws IOException {
+    public LocalFilesMessageBodySource(List<String> filesNames) throws IOException {
         this(filesNames, null);
     }
 

src/main/java/com/rabbitmq/perf/MulticastParams.java

@@ -225,7 +225,7 @@ public Producer createProducer(Connection connection, Stats stats, String id) th
         }
         MessageBodySource messageBodySource = null;
         if (bodyFiles.size() > 0) {
-            messageBodySource = new FromFilesMessageBodySource(bodyFiles, bodyContentType);
+            messageBodySource = new LocalFilesMessageBodySource(bodyFiles, bodyContentType);
         } else {
             messageBodySource = new SequenceTimeMessageBodySource(minMsgSize);
         }

src/test/java/com/rabbitmq/perf/FromFilesMessageBodySourceTest.java renamed to src/test/java/com/rabbitmq/perf/LocalFilesMessageBodySourceTest.java

@@ -31,7 +31,7 @@
 /**
  *
  */
-public class FromFilesMessageBodySourceTest {
+public class LocalFilesMessageBodySourceTest {
 
     @Rule
     public TemporaryFolder folder = new TemporaryFolder();
@@ -40,7 +40,7 @@ public class FromFilesMessageBodySourceTest {
         File file = folder.newFile("content.txt");
         String content = "dummy content";
         write(file, content);
-        MessageBodySource creator = new FromFilesMessageBodySource(asList(file.getAbsolutePath()));
+        MessageBodySource creator = new LocalFilesMessageBodySource(asList(file.getAbsolutePath()));
         byte[] body1 = creator.create(1).getBody();
         byte[] body2 = creator.create(1).getBody();
         assertEquals(content, new String(body1, "UTF-8"));
@@ -56,7 +56,7 @@ public class FromFilesMessageBodySourceTest {
             files.add(file.getAbsolutePath());
         }
 
-        MessageBodySource creator = new FromFilesMessageBodySource(files);
+        MessageBodySource creator = new LocalFilesMessageBodySource(files);
         byte[] body0 = creator.create(0).getBody();
         assertEquals("content0", new String(body0, "UTF-8"));
         byte[] body1 = creator.create(1).getBody();
@@ -70,7 +70,7 @@ public class FromFilesMessageBodySourceTest {
     @Test public void createFileDoesNotExist() throws Exception {
         File file = new File(folder.getRoot(), "dummy.txt");
         try {
-            new FromFilesMessageBodySource(asList(file.getAbsolutePath()));
+            new LocalFilesMessageBodySource(asList(file.getAbsolutePath()));
             fail("File does not exist, exception should have thrown");
         } catch (IllegalArgumentException e) {
             // ok