Merge pull request #10 from red5pro/develop

Develop

pom.xml

@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.infrared5.rtmpbee</groupId>
     <artifactId>rtmpbee</artifactId>
-    <version>3.1.0-RELEASE</version>
+    <version>4.0.0-RELEASE</version>
     <packaging>jar</packaging>
     <name>rtmpbee</name>
     <url>http://infrared5.com</url>

src/main/java/com/infrared5/rtmpbee/Red5Bee.java

@@ -71,7 +71,6 @@ public Red5Bee(String streamManagerURL, int numBullets, int timeout) throws Exce
         this.streamManagerURL = streamManagerURL;
         this.numBullets = numBullets;
         this.timeout = timeout;
-        modifyEndpointProperties(this.streamManagerURL);
     }
 
     /**
@@ -146,10 +145,16 @@ private void loadMachineGun() {
         // load our bullets into the gun
         for (int i = 0; i < numBullets; i++) {
             // build a bullet
-            Bullet bullet = Bullet.Builder.build((i + 1), url, port, application, streamName, timeout);
-            bullet.setCompleteHandler(this);
-            bullet.setFailHandler(this);
-            machineGun.put(i, bullet);
+        	try {
+        		modifyEndpointProperties(this.streamManagerURL);
+        		Bullet bullet = Bullet.Builder.build((i + 1), url, port, application, streamName, timeout);
+        		bullet.setCompleteHandler(this);
+        		bullet.setFailHandler(this);
+        		machineGun.put(i, bullet);
+        	}
+        	catch (Exception e) {
+        		System.out.printf("[WARNING] Could not assemble bullet for firing: %s\n", e.getMessage());
+        	}
         }
     }
 
@@ -278,7 +283,7 @@ else if (args.length < 5) {
             return;
         }
         else {
-            System.out.println("Determined its an original attack...");
+            System.out.println("Determined its an original attack...\n");
             url = args[0];
             port = Integer.parseInt(args[1]);
             application = args[2];