Merge pull request #43 from stkaushal/master

Public access modifier for IDs.java

src/main/java/io/iron/ironmq/Ids.java

@@ -1,13 +1,13 @@
 package io.iron.ironmq;
 
-class Ids {
+public class Ids {
     private String[] ids;
 
-    String getId(int i) {
+    public String getId(int i) {
         return ids[i];
     }
 
-    int getSize(){
+    public int getSize(){
         return ids.length;
     }
 

src/test/java/client/iron/ironmq/ClientIronMQTest.java

@@ -0,0 +1,56 @@
+package client.iron.ironmq;
+
+
+import io.iron.ironmq.*;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+public class ClientIronMQTest {
+
+    private String queueName = "java-testing-queue";
+    private String token = "";
+    private String projectId = "";
+
+    @Test
+    public void testPostMultipleMessagesAndIdsShouldNotBeNull() throws IOException {
+        setCredentials();
+        Client client = new Client(projectId, token, Cloud.ironAWSUSEast);
+        Queue queue = new Queue(client, queueName);
+        String body = "Hello, IronMQ!";
+        queue.push(body, 10);
+        QueueModel infoAboutQueue = queue.getInfoAboutQueue();
+        int queueSize = infoAboutQueue.getSize();
+
+        String[] messages = {"c", "d"};
+        Ids ids = queue.pushMessages(messages);
+
+        infoAboutQueue = queue.getInfoAboutQueue();
+        Assert.assertEquals(messages.length, ids.getSize());
+        Assert.assertEquals(queueSize + 2, infoAboutQueue.getSize());
+
+        queue.deleteMessages(ids);
+
+        infoAboutQueue = queue.getInfoAboutQueue();
+        Assert.assertEquals(queueSize, infoAboutQueue.getSize());
+        queue.destroy();
+    }
+    private void setCredentials() throws IOException {
+        Properties prop = new Properties();
+        InputStream input = null;
+        try {
+            input = new FileInputStream("config.properties");
+        } catch(FileNotFoundException fnfe) {
+            System.out.println("config.properties not found");
+            input = new FileInputStream("../../config.properties"); //maven release hack
+        }
+        prop.load(input);
+        token = prop.getProperty("token");
+        projectId = prop.getProperty("project_id");
+    }
+}