Adding ApnsService.testConnection

src/main/java/com/notnoop/apns/ApnsService.java

@@ -153,4 +153,13 @@ public interface ApnsService {
      *      while retrieving invalid device connection
      */
     Map<String, Date> getInactiveDevices() throws NetworkIOException;
+
+    /**
+     * Test that the service is setup properly and the Apple servers
+     * are reachable.
+     *
+     * @throws NetworkIOException   if the Apple servers aren't reachable
+     *      or the service cannot send notifications for now
+     */
+    void testConnection() throws NetworkIOException;
 }

src/main/java/com/notnoop/apns/internal/AbstractApnsService.java

@@ -72,5 +72,4 @@ public void push(Collection<byte[]> deviceTokens, byte[] payload) throws Network
     public Map<String, Date> getInactiveDevices() throws NetworkIOException {
         return feedback.getInactiveDevices();
     }
-
 }

src/main/java/com/notnoop/apns/internal/ApnsConnection.java

@@ -37,5 +37,6 @@
 
 public interface ApnsConnection extends Closeable {
     void sendMessage(ApnsNotification m) throws NetworkIOException;
+    void testConnection() throws NetworkIOException;
     ApnsConnection copy();
 }

src/main/java/com/notnoop/apns/internal/ApnsConnectionImpl.java

@@ -133,4 +133,10 @@ public synchronized void sendMessage(ApnsNotification m) throws NetworkIOExcepti
     public ApnsConnectionImpl copy() {
         return new ApnsConnectionImpl(factory, host, port, reconnectPolicy, delegate);
     }
+
+    public void testConnection() throws NetworkIOException {
+        ApnsConnectionImpl testConnection = new ApnsConnectionImpl(factory, host, port, reconnectPolicy, ApnsDelegate.EMPTY);
+        testConnection.sendMessage(new ApnsNotification(new byte[] {0}, new byte[]{0}));
+        testConnection.close();
+    }
 }

src/main/java/com/notnoop/apns/internal/ApnsPooledConnection.java

@@ -61,4 +61,8 @@ public void close() {
         }
         Utilities.close(prototype);
     }
+
+    public void testConnection() {
+        prototype.testConnection();
+    }
 }

src/main/java/com/notnoop/apns/internal/ApnsServiceImpl.java

@@ -52,4 +52,8 @@ public void start() {
     public void stop() {
         Utilities.close(connection);
     }
+
+    public void testConnection() {
+        connection.testConnection();
+    }
 }

src/main/java/com/notnoop/apns/internal/MinaAdaptor.java

@@ -11,6 +11,7 @@
 import org.apache.mina.transport.socket.nio.NioSocketConnector;
 
 import com.notnoop.apns.ApnsNotification;
+import com.notnoop.exceptions.NetworkIOException;
 
 public class MinaAdaptor extends AbstractApnsService {
     NioSocketConnector connector;
@@ -58,4 +59,8 @@ public void stop() {
         cf.getSession().close(false).awaitUninterruptibly(100000);
         connector.dispose();
     }
+
+    public void testConnection() throws NetworkIOException {
+        // TODO: Implement me in a bit
+    }
 }

src/main/java/com/notnoop/apns/internal/QueuedApnsService.java

@@ -94,4 +94,8 @@ public Map<String, Date> getInactiveDevices() throws NetworkIOException {
         return service.getInactiveDevices();
     }
 
+    public void testConnection() throws NetworkIOException {
+        service.testConnection();
+    }
+
 }

src/test/java/com/notnoop/apns/internal/QueuedApnsServiceTest.java

@@ -10,6 +10,7 @@
 
 import com.notnoop.apns.ApnsNotification;
 import com.notnoop.apns.ApnsService;
+import com.notnoop.exceptions.NetworkIOException;
 
 public class QueuedApnsServiceTest {
 
@@ -96,6 +97,6 @@ public ApnsConnection copy() {
         }
 
         public void close() throws IOException {}
-
+        public void testConnection() throws NetworkIOException {}
     }
 }