diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
index 56767ce0e5..0e15e76d9c 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
@@ -77,6 +77,8 @@ public class VMTransport implements Transport{
             }else {
                 queue.add(command);
             }
+        } else {
+            throw new IOException("Peer disconnected.");
         }
     }
 
diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java b/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java
index 30350565ca..c6a67cfc5e 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java
@@ -143,7 +143,7 @@ public class VMTransportFactory extends TransportFactory{
      */
     private TransportServer bind(URI location,boolean dispose) throws IOException{
         String host=location.getHost();
-        log.info("binding to broker: " + host);
+        log.debug("binding to broker: " + host);
         VMTransportServer server=new VMTransportServer(location,dispose);
         Object currentBoundValue=servers.get(host);
         if(currentBoundValue!=null){
@@ -155,10 +155,10 @@ public class VMTransportFactory extends TransportFactory{
 
     public static void stopped(VMTransportServer server){
         String host=server.getBindURI().getHost();
-        log.info("Shutting down VM connectors for broker: "  +host);
         servers.remove(host);
         TransportConnector connector=(TransportConnector) connectors.remove(host);
         if(connector!=null){
+            log.debug("Shutting down VM connectors for broker: "  +host);
             ServiceSupport.dispose(connector);
             BrokerService broker=(BrokerService) brokers.remove(host);
             if(broker!=null){
@@ -168,10 +168,10 @@ public class VMTransportFactory extends TransportFactory{
     }
 
     public static void stopped(String host){
-        log.info("Shutting down VM connectors for broker: "  +host);
         servers.remove(host);
         TransportConnector connector=(TransportConnector) connectors.remove(host);
         if(connector!=null){
+            log.debug("Shutting down VM connectors for broker: "  +host);
             ServiceSupport.dispose(connector);
             BrokerService broker=(BrokerService) brokers.remove(host);
             if(broker!=null){