Add in-vm-server for starting an embedded server

claj · Jan 18, 2011 · 8a09797 · 8a09797
1 parent b38c9d4
commit 8a09797
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/server/src/hornetq_clj/server.clj b/server/src/hornetq_clj/server.clj
@@ -37,6 +37,11 @@
 (def netty-acceptor-factory
   "org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory")
 
+(def in-vm-connector-factory
+  "org.hornetq.core.remoting.impl.invm.InVMConnectorFactory")
+(def in-vm-acceptor-factory
+  "org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory")
+
 (defn stomp-server
   [options]
   (server (merge-with
@@ -48,3 +53,12 @@
                         {:factory-class-name netty-acceptor-factory
                          :protocol "stomp"
                          :port 61613}]})))
+
+(defn in-vm-server
+  [options]
+  (server (merge-with
+           conj
+           options
+           {:connectors [{:name "invm-connector"
+                          :factory-class-name in-vm-connector-factory}]
+            :acceptors [{:factory-class-name in-vm-acceptor-factory}]})))