Module: Quark::MdkRtp

Defined in:
lib/mdk_rtp.rb

Class Method Summary collapse

Class Method Details

.getRTPParser ⇒ Object

Create a JSONParser that can read all messages to/from the MCP.



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/mdk_rtp.rb', line 14

def self.getRTPParser()
    
    parser = ::Quark.mdk_protocol.JSONParser.new()
    parser.register("open", ::Quark.quark.reflect.QuarkClass.get("mdk_protocol.Open"))
    parser.register("mdk.protocol.Open", ::Quark.quark.reflect.QuarkClass.get("mdk_protocol.Open"))
    parser.register("close", ::Quark.quark.reflect.QuarkClass.get("mdk_protocol.Close"))
    parser.register("mdk.protocol.Close", ::Quark.quark.reflect.QuarkClass.get("mdk_protocol.Close"))
    parser.register("discovery.protocol.Close", ::Quark.quark.reflect.QuarkClass.get("mdk_protocol.Close"))
    parser.register("active", ::Quark.quark.reflect.QuarkClass.get("mdk_discovery.protocol.Active"))
    parser.register("discovery.protocol.Expire", ::Quark.quark.reflect.QuarkClass.get("mdk_discovery.protocol.Expire"))
    parser.register("expire", ::Quark.quark.reflect.QuarkClass.get("mdk_discovery.protocol.Expire"))
    parser.register("discovery.protocol.Expire", ::Quark.quark.reflect.QuarkClass.get("mdk_discovery.protocol.Expire"))
    parser.register("clear", ::Quark.quark.reflect.QuarkClass.get("mdk_discovery.protocol.Clear"))
    parser.register("discovery.protocol.Clear", ::Quark.quark.reflect.QuarkClass.get("mdk_discovery.protocol.Clear"))
    parser.register("log", ::Quark.quark.reflect.QuarkClass.get("mdk_tracing.protocol.LogEvent"))
    parser.register("logack", ::Quark.quark.reflect.QuarkClass.get("mdk_tracing.protocol.LogAck"))
    parser.register("mdk_tracing.protocol.LogAckEvent", ::Quark.quark.reflect.QuarkClass.get("mdk_tracing.protocol.LogAck"))
    parser.register("subscribe", ::Quark.quark.reflect.QuarkClass.get("mdk_tracing.protocol.Subscribe"))
    parser.register("interactionevent", ::Quark.quark.reflect.QuarkClass.get("mdk_metrics.InteractionEvent"))
    parser.register("interactionack", ::Quark.quark.reflect.QuarkClass.get("mdk_metrics.InteractionAck"))
    return parser


    nil
end