--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/runtime/WampClient.py	Thu Feb 05 23:32:31 2015 +0100
@@ -0,0 +1,74 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+import sys
+from twisted.python import log
+
+from twisted.internet import reactor, ssl
+from autobahn.twisted import wamp
+from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS
+from autobahn.wamp import types
+import json
+
+_WampSession = None
+_PySrv = None
+
+class WampSession(wamp.ApplicationSession):
+    def onJoin(self, details):
+        global _WampSession
+        _WampSession = self
+        print 'WAMP session joined by :', self.config.extra["ID"]
+
+    def onLeave(self, details):
+        global _WampSession
+        _WampSession = None
+        print 'WAMP session left'
+
+
+def RegisterWampClient(wampconf):
+
+    WSClientConf = json.load(open(wampconf))
+
+    ## TODO log to PLC console instead
+    ## 0) start logging to console
+    log.startLogging(sys.stdout)
+
+    ## 1) create a WAMP application session factory
+    component_config = types.ComponentConfig(
+        realm = WSClientConf["realm"],
+        extra = {"ID":WSClientConf["ID"]})
+    session_factory = wamp.ApplicationSessionFactory(
+        config = component_config)
+    session_factory.session = WampSession
+
+    ## TODO select optimum serializer for passing session lists
+    ## optional: use specific set of serializers
+    #from autobahn.wamp.serializer import *
+    #serializers = []
+    ##serializers.append(JsonSerializer(batched = True))
+    ##serializers.append(MsgPackSerializer(batched = True))
+    #serializers.append(JsonSerializer())
+    ##serializers.append(MsgPackSerializer())
+    serializers = None
+
+    ## 2) create a WAMP-over-WebSocket transport client factory
+    transport_factory = WampWebSocketClientFactory(
+        session_factory,
+        url = WSClientConf["url"],
+        serializers = serializers,
+        debug = False,
+        debug_wamp = False)
+
+    ## 3) start the client from a Twisted endpoint
+    conn = connectWS(transport_factory)
+    print "WAMP clien connecting to :",WSClientConf["url"]
+    return conn
+
+def GetSession():
+    global _WampSession
+    return _WampSession
+
+def SetServer(pysrv):
+    global _PySrv
+    _PySrv = pysrv
+