package Ġcom . la uren ce g arm strong . kw amp . router . core . con versations . scripts Ċ Ċ import Ġcom . la uren ce g arm strong . kw amp . con versations . core . Test Connection Ċ import Ġcom . la uren ce g arm strong . kw amp . con versations . core . default Router Ċ import Ġcom . la uren ce g arm strong . kw amp . core . Uri Ċ import Ġcom . la uren ce g arm strong . kw amp . core . messages . Subscribe Ċ import Ġcom . la uren ce g arm strong . kw amp . core . messages . Sub scribed Ċ import Ġcom . la uren ce g arm strong . kw amp . core . messages . Un subscribe Ċ import Ġcom . la uren ce g arm strong . kw amp . core . messages . Un subscribed Ċ import Ġcom . la uren ce g arm strong . kw amp . router . core . con versations . infrastructure . Router Conversation Ċ import Ġio . kot lint est . be Ċ import Ġio . kot lint est . should Ċ import Ġio . kot lint est . specs . String Spec Ċ Ċ class ĠSub Un Sub Ġ: ĠString Spec ({ ĊĠĠĠ Ġ" Test ĠSub scri bing Ġand Ġun sub scri bing " Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġclient Ġ= ĠTest Connection () ĊĠĠĠĠĠĠĠ ĠRouter Conversation ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdefault Router (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġclient ĊĠĠĠĠĠĠĠ Ġ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġclient . starts AS ession () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġvar Ġsubscription : ĠLong ? Ġ= Ġnull ĊĠĠĠĠĠĠĠĠĠĠĠ Ġclient Ġwill Send Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠSubscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 2 3 L , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġempty Map (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠUri (" sub . topic ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġclient Ġshould Receive Message Ġ{ Ġmessage : ĠSub scribed Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmessage . requestId Ġshould Ġbe ( 1 2 3 L ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscription Ġ= Ġmessage . subscription ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġclient Ġwill Send Ġ{ ĠUn subscribe ( 4 5 6 L , Ġsubscription !! ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġclient Ġshould Receive Message Ġ{ Ġmessage : ĠUn subscribed Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmessage . requestId Ġshould Ġbe ( 4 5 6 L ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }) ĊĊ