Index: activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java
===================================================================
--- activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java	(revision 583366)
+++ activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java	(working copy)
@@ -131,7 +131,9 @@
         }
         
         VMTransport vmtransport=server.connect();
-        IntrospectionSupport.setProperties(vmtransport,options);
+        IntrospectionSupport.setProperties(vmtransport,new HashMap(options));
+        IntrospectionSupport.setProperties(vmtransport.peer,options);
+        server.configureTransport(vmtransport.getPeer());
         Transport transport=vmtransport;
         if(vmtransport.isMarshal()){
             HashMap optionsCopy=new HashMap(options);
Index: activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java
===================================================================
--- activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java	(revision 583366)
+++ activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java	(working copy)
@@ -88,10 +88,13 @@
         VMTransport server = new VMTransport(location);
         client.setPeer(server);
         server.setPeer(client);
-        al.onAccept(configure(server));
         return client;
     }
     
+    public void configureTransport(VMTransport server) throws IOException {
+        acceptListener.onAccept(configure(server));
+    }
+    
     /**
      * Configure transport
      * @param transport