diff --git a/api/src/com/cloud/api/commands/CreatePortForwardingRuleCmd.java b/api/src/com/cloud/api/commands/CreatePortForwardingRuleCmd.java
index 55f0b23b5a7..3f3915a705d 100644
--- a/api/src/com/cloud/api/commands/CreatePortForwardingRuleCmd.java
+++ b/api/src/com/cloud/api/commands/CreatePortForwardingRuleCmd.java
@@ -66,7 +66,6 @@ public class CreatePortForwardingRuleCmd extends BaseAsyncCreateCmd implements P
     @Parameter(name = ApiConstants.PRIVATE_END_PORT, type = CommandType.INTEGER, required = false, description = "the ending port of port forwarding rule's private port range")
     private Integer privateEndPort;
 
-
     @Parameter(name = ApiConstants.PUBLIC_START_PORT, type = CommandType.INTEGER, required = true, 
             description = "the starting port of port forwarding rule's public port range")
     private Integer publicStartPort;
diff --git a/server/src/com/cloud/network/rules/RulesManagerImpl.java b/server/src/com/cloud/network/rules/RulesManagerImpl.java
index 6e570099591..3a61db9559b 100755
--- a/server/src/com/cloud/network/rules/RulesManagerImpl.java
+++ b/server/src/com/cloud/network/rules/RulesManagerImpl.java
@@ -244,6 +244,15 @@ public class RulesManagerImpl implements RulesManager, RulesService, Manager {
             } else {
                 dstIp = new Ip(guestNic.getIp4Address());
             }
+            
+            //source start port and source dest port should be the same. The same applies to dest ports
+            if (rule.getSourcePortStart().intValue() != rule.getDestinationPortStart()) {
+                throw new InvalidParameterValueException("Private port start should be equal to public port start", null);
+            }
+            
+            if (rule.getSourcePortEnd().intValue() != rule.getDestinationPortEnd()) {
+                throw new InvalidParameterValueException("Private port end should be equal to public port end", null);
+            }
 
             Transaction txn = Transaction.currentTxn();
             txn.start();