StropheCappuccino API 1.0.0
/tmp/tempDoc.doc/Build/StropheCappuccino.build/Release/CommonJS.environment/Sources/PubSub/TNPubSubController.j
Go to the documentation of this file.
00001 @STATIC;1.0;I;23;Foundation/Foundation.ji;31;../Resources/Strophe/strophe.jsi;24;../TNStropheConnection.ji;14;TNPubSubNode.jt;19813;objj_executeFile("Foundation/Foundation.j", NO);objj_executeFile("../Resources/Strophe/strophe.js", YES);objj_executeFile("../TNStropheConnection.j", YES);objj_executeFile("TNPubSubNode.j", YES);TNStrophePubSubBatchSubscribeCompleteNotification = "TNStrophePubSubBatchSubscribeCompleteNotification";
00002 TNStrophePubSubBatchUnsubscribeCompleteNotification = "TNStrophePubSubBatchUnsubscribeCompleteNotification";
00003 TNStrophePubSubNoOldSubscriptionsLeftNotification = "TNStrophePubSubNoOldSubscriptionsLeft";
00004 TNStrophePubSubSubscriptionsRetrievedNotification = "TNStrophePubSubSubscriptionsReceivedNotification";
00005 {var the_class = objj_allocateClassPair(CPObject, "TNPubSubController"),
00006 meta_class = the_class.isa;class_addIvars(the_class, [new objj_ivar("_nodes"), new objj_ivar("_servers"), new objj_ivar("_delegate"), new objj_ivar("_subscriptionBatches"), new objj_ivar("_unsubscriptionBatches"), new objj_ivar("_connection"), new objj_ivar("_numberOfPromptedServers")]);objj_registerClassPair(the_class);
00007 class_addMethods(the_class, [new objj_method(sel_getUid("nodes"), function $TNPubSubController__nodes(self, _cmd)
00008 {
00009     return self._nodes;
00010 }
00011 ,["CPArray"]), new objj_method(sel_getUid("_setNodes:"), function $TNPubSubController___setNodes_(self, _cmd, newValue)
00012 {
00013     self._nodes = newValue;
00014 }
00015 ,["void","CPArray"]), new objj_method(sel_getUid("servers"), function $TNPubSubController__servers(self, _cmd)
00016 {
00017     return self._servers;
00018 }
00019 ,["CPArray"]), new objj_method(sel_getUid("setServers:"), function $TNPubSubController__setServers_(self, _cmd, newValue)
00020 {
00021     self._servers = newValue;
00022 }
00023 ,["void","CPArray"]), new objj_method(sel_getUid("delegate"), function $TNPubSubController__delegate(self, _cmd)
00024 {
00025     return self._delegate;
00026 }
00027 ,["id"]), new objj_method(sel_getUid("setDelegate:"), function $TNPubSubController__setDelegate_(self, _cmd, newValue)
00028 {
00029     self._delegate = newValue;
00030 }
00031 ,["void","id"]), new objj_method(sel_getUid("initWithConnection:pubSubServer:"), function $TNPubSubController__initWithConnection_pubSubServer_(self, _cmd, aConnection, aPubSubServer)
00032 {
00033     if (self = objj_msgSendSuper({ receiver:self, super_class:objj_getClass("TNPubSubController").super_class }, "init"))
00034     {
00035         self._connection = aConnection;
00036         self._servers = CPArray.isa.objj_msgSend1(CPArray, "arrayWithObject:", aPubSubServer || TNStropheJID.isa.objj_msgSend1(TNStropheJID, "stropheJIDWithString:", "pubsub." + ((___r1 = (aConnection == null ? null : aConnection.isa.objj_msgSend0(aConnection, "JID"))), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "domain"))));
00037         self._numberOfPromptedServers = 0;
00038         self._nodes = CPArray.isa.objj_msgSend0(CPArray, "array");
00039         self._subscriptionBatches = CPDictionary.isa.objj_msgSend0(CPDictionary, "dictionary");
00040         self._unsubscriptionBatches = CPDictionary.isa.objj_msgSend0(CPDictionary, "dictionary");
00041     }
00042     return self;
00043     var ___r1;
00044 }
00045 ,["TNPubSubNode","TNStropheConnection","TNStropheJID"]), new objj_method(sel_getUid("_didSubscribeToNode:"), function $TNPubSubController___didSubscribeToNode_(self, _cmd, aNotification)
00046 {
00047     if (self._delegate && ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "respondsToSelector:", sel_getUid("pubSubController:subscribedToNode:"))))
00048         ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "pubSubController:subscribedToNode:", self, (aNotification == null ? null : aNotification.isa.objj_msgSend0(aNotification, "object"))));
00049     var ___r1;
00050 }
00051 ,["void","CPNotification"]), new objj_method(sel_getUid("_didUnsubscribeToNode:"), function $TNPubSubController___didUnsubscribeToNode_(self, _cmd, aNotification)
00052 {
00053     if (self._delegate && ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "respondsToSelector:", sel_getUid("pubSubController:unsubscribedFromNode:"))))
00054         ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "pubSubController:unsubscribedFromNode:", self, (aNotification == null ? null : aNotification.isa.objj_msgSend0(aNotification, "object"))));
00055     var ___r1;
00056 }
00057 ,["void","CPNotification"]), new objj_method(sel_getUid("_didBatchSubscribe:"), function $TNPubSubController___didBatchSubscribe_(self, _cmd, aNotification)
00058 {
00059     var node = (aNotification == null ? null : aNotification.isa.objj_msgSend0(aNotification, "object")),
00060         batchID = (aNotification == null ? null : aNotification.isa.objj_msgSend0(aNotification, "useInfo")),
00061         batch = ((___r1 = self._subscriptionBatches), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "valueForKey:", batchID)),
00062         params = CPDictionary.isa.objj_msgSend2(CPDictionary, "dictionaryWithObject:forKey:", batchID, "batchID");
00063     (batch == null ? null : batch.isa.objj_msgSend1(batch, "removeObjectIdenticalTo:", (node == null ? null : node.isa.objj_msgSend0(node, "name"))));
00064     if ((batch == null ? null : batch.isa.objj_msgSend0(batch, "count")) === 0)
00065         ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend3(___r1, "postNotificationName:object:userInfo:", TNStrophePubSubBatchSubscribeCompleteNotification, self, params));
00066     var ___r1;
00067 }
00068 ,["void","CPNotification"]), new objj_method(sel_getUid("_didBatchUnsubscribe:"), function $TNPubSubController___didBatchUnsubscribe_(self, _cmd, aNotification)
00069 {
00070     var node = (aNotification == null ? null : aNotification.isa.objj_msgSend0(aNotification, "object")),
00071         batchID = (aNotification == null ? null : aNotification.isa.objj_msgSend0(aNotification, "useInfo")),
00072         batch = ((___r1 = self._unsubscriptionBatches), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "valueForKey:", batchID)),
00073         params = CPDictionary.isa.objj_msgSend2(CPDictionary, "dictionaryWithObject:forKey:", batchID, "batchID");
00074     (batch == null ? null : batch.isa.objj_msgSend1(batch, "removeObjectIdenticalTo:", (node == null ? null : node.isa.objj_msgSend0(node, "name"))));
00075     if ((batch == null ? null : batch.isa.objj_msgSend0(batch, "count")) === 0)
00076         ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend3(___r1, "postNotificationName:object:userInfo:", TNStrophePubSubBatchUnsubscribeCompleteNotification, self, params));
00077     var ___r1;
00078 }
00079 ,["void","CPNotification"]), new objj_method(sel_getUid("containsServerJID:"), function $TNPubSubController__containsServerJID_(self, _cmd, aServerJID)
00080 {
00081     for (var i = 0; i < ((___r1 = self._servers), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "count")); i++)
00082         if (((___r1 = ((___r2 = self._servers), ___r2 == null ? null : ___r2.isa.objj_msgSend1(___r2, "objectAtIndex:", i))), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "node")) == (aServerJID == null ? null : aServerJID.isa.objj_msgSend0(aServerJID, "node")))
00083             return YES;
00084     return NO;
00085     var ___r1, ___r2;
00086 }
00087 ,["BOOL","TNStropheJID"]), new objj_method(sel_getUid("nodeWithName:server:"), function $TNPubSubController__nodeWithName_server_(self, _cmd, aNodeName, aServer)
00088 {
00089     for (var i = 0; i < ((___r1 = self._nodes), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "count")); i++)
00090     {
00091         var node = ((___r1 = self._nodes), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "objectAtIndex:", i));
00092         if ((node == null ? null : node.isa.objj_msgSend0(node, "name")) === aNodeName && (!aServer || ((___r1 = (node == null ? null : node.isa.objj_msgSend0(node, "server"))), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "equals:", aServer))))
00093             return node;
00094     }
00095     return;
00096     var ___r1;
00097 }
00098 ,["TNPubSubNode","CPString","TNStropheJID"]), new objj_method(sel_getUid("nodeWithName:"), function $TNPubSubController__nodeWithName_(self, _cmd, aNodeName)
00099 {
00100     return self.isa.objj_msgSend2(self, "nodeWithName:server:", aNodeName, nil);
00101 }
00102 ,["TNPubSubNode","CPString"]), new objj_method(sel_getUid("findOrCreateNodeWithName:server:"), function $TNPubSubController__findOrCreateNodeWithName_server_(self, _cmd, aNodeName, aServer)
00103 {
00104     var node = self.isa.objj_msgSend2(self, "nodeWithName:server:", aNodeName, aServer);
00105     if (!self.isa.objj_msgSend1(self, "containsServerJID:", aServer))
00106         ((___r1 = self._servers), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "addObject:", aServer));
00107     if (!node)
00108     {
00109         node = TNPubSubNode.isa.objj_msgSend3(TNPubSubNode, "pubSubNodeWithNodeName:connection:pubSubServer:", aNodeName, self._connection, aServer);
00110         ((___r1 = self._nodes), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "addObject:", node));
00111     }
00112     return node;
00113     var ___r1;
00114 }
00115 ,["TNPubSubNode","CPString","TNStropheJID"]), new objj_method(sel_getUid("retrieveSubscriptions"), function $TNPubSubController__retrieveSubscriptions(self, _cmd)
00116 {
00117     self._numberOfPromptedServers = 0;
00118     for (var i = 0; i < ((___r1 = self._servers), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "count")); i++)
00119     {
00120         var uid = ((___r1 = self._connection), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "getUniqueId")),
00121             stanza = TNStropheStanza.isa.objj_msgSend1(TNStropheStanza, "iqWithAttributes:", {"type": "get", "to": ((___r1 = self._servers), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "objectAtIndex:", i)), "id": uid}),
00122             params = CPDictionary.isa.objj_msgSend2(CPDictionary, "dictionaryWithObjectsAndKeys:", uid, "id");
00123         (stanza == null ? null : stanza.isa.objj_msgSend2(stanza, "addChildWithName:andAttributes:", "pubsub", {"xmlns": Strophe.NS.PUBSUB}));
00124         (stanza == null ? null : stanza.isa.objj_msgSend1(stanza, "addChildWithName:", "subscriptions"));
00125         ((___r1 = self._connection), ___r1 == null ? null : ___r1.isa.objj_msgSend3(___r1, "registerSelector:ofObject:withDict:", sel_getUid("_didRetrieveSubscriptions:"), self, params));
00126         ((___r1 = self._connection), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "send:", stanza));
00127     }
00128     var ___r1;
00129 }
00130 ,["void"]), new objj_method(sel_getUid("_didRetrieveSubscriptions:"), function $TNPubSubController___didRetrieveSubscriptions_(self, _cmd, aStanza)
00131 {
00132     if ((aStanza == null ? null : aStanza.isa.objj_msgSend0(aStanza, "type")) == "result")
00133     {
00134         var subscriptions = (aStanza == null ? null : aStanza.isa.objj_msgSend1(aStanza, "childrenWithName:", "subscription")),
00135             server = (aStanza == null ? null : aStanza.isa.objj_msgSend0(aStanza, "from"));
00136         for (var i = 0; i < (subscriptions == null ? null : subscriptions.isa.objj_msgSend0(subscriptions, "count")); i++)
00137         {
00138             var subscription = (subscriptions == null ? null : subscriptions.isa.objj_msgSend1(subscriptions, "objectAtIndex:", i)),
00139                 nodeName = (subscription == null ? null : subscription.isa.objj_msgSend1(subscription, "valueForAttribute:", "node")),
00140                 subid = (subscription == null ? null : subscription.isa.objj_msgSend1(subscription, "valueForAttribute:", "subid")),
00141                 node = self.isa.objj_msgSend2(self, "findOrCreateNodeWithName:server:", nodeName, server);
00142             (node == null ? null : node.isa.objj_msgSend1(node, "addSubscriptionID:", subid));
00143             ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend(___r1, "addObserver:selector:name:object:", self, sel_getUid("_didSubscribeToNode:"), TNStrophePubSubNodeSubscribedNotification, node));
00144             ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend(___r1, "addObserver:selector:name:object:", self, sel_getUid("_didUnsubscribeToNode:"), TNStrophePubSubNodeUnsubscribedNotification, node));
00145         }
00146         self._numberOfPromptedServers++;
00147         if (self._numberOfPromptedServers >= ((___r1 = self._servers), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "count")))
00148         {
00149             self._numberOfPromptedServers = 0;
00150             ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "postNotificationName:object:", TNStrophePubSubSubscriptionsRetrievedNotification, self));
00151             if (self._delegate && ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "respondsToSelector:", sel_getUid("pubSubController:retrievedSubscriptions:"))))
00152                 ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "pubSubController:retrievedSubscriptions:", self, YES));
00153         }
00154     }
00155     else
00156     {
00157         if (self._delegate && ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "respondsToSelector:", sel_getUid("pubSubController:retrievedSubscriptions:"))))
00158             ((___r1 = self._delegate), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "pubSubController:retrievedSubscriptions:", self, NO));
00159         CPLog.error("Cannot retrieve the contents of pubsub node");
00160         CPLog.error(aStanza);
00161     }
00162     return NO;
00163     var ___r1;
00164 }
00165 ,["BOOL","TNStropheStanza"]), new objj_method(sel_getUid("subscribeToNodeWithName:server:nodeDelegate:"), function $TNPubSubController__subscribeToNodeWithName_server_nodeDelegate_(self, _cmd, aNodeName, aServer, nodeDelegate)
00166 {
00167     var node = self.isa.objj_msgSend2(self, "findOrCreateNodeWithName:server:", aNodeName, aServer);
00168     (node == null ? null : node.isa.objj_msgSend1(node, "setDelegate:", nodeDelegate));
00169     (node == null ? null : node.isa.objj_msgSend0(node, "subscribe"));
00170     return node;
00171 }
00172 ,["TNPubSubNode","CPString","TNStropheJID","id"]), new objj_method(sel_getUid("subscribeToNodeWithName:server:"), function $TNPubSubController__subscribeToNodeWithName_server_(self, _cmd, aNodeName, aServer)
00173 {
00174     return self.isa.objj_msgSend3(self, "subscribeToNodeWithName:server:nodeDelegate:", aNodeName, aServer, nil);
00175 }
00176 ,["TNPubSubNode","CPString","TNStropheJID"]), new objj_method(sel_getUid("subscribeToNodesWithNames:nodesDelegate:"), function $TNPubSubController__subscribeToNodesWithNames_nodesDelegate_(self, _cmd, someNodes, aDelegate)
00177 {
00178     var batchID = ((___r1 = self._connection), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "getUniqueId")),
00179         servers = (someNodes == null ? null : someNodes.isa.objj_msgSend0(someNodes, "allKeys"));
00180     ((___r1 = self._subscriptionBatches), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "setValue:forKey:", someNodes, batchID));
00181     for (var k = 0; k < (servers == null ? null : servers.isa.objj_msgSend0(servers, "count")); k++)
00182     {
00183         var server = (servers == null ? null : servers.isa.objj_msgSend1(servers, "objectAtIndex:", k)),
00184             nodes = (servers == null ? null : servers.isa.objj_msgSend1(servers, "valueForKey:", server));
00185         for (var i = 0; i < (nodes == null ? null : nodes.isa.objj_msgSend0(nodes, "count")); i++)
00186         {
00187             var nodeName = (nodes == null ? null : nodes.isa.objj_msgSend1(nodes, "objectAtIndex:", i)),
00188                 node = self.isa.objj_msgSend3(self, "subscribeToNodeWithName:server:nodeDelegate:", nodeName, server, aDelegate);
00189             ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend(___r1, "addObserver:selector:name:object:userInfo:", self, sel_getUid("_didBatchSubscribe:"), TNStrophePubSubNodeSubscribedNotification, node, batchID));
00190         }
00191     }
00192     return batchID;
00193     var ___r1;
00194 }
00195 ,["CPString","CPDictionary","id"]), new objj_method(sel_getUid("unsubscribeFromNodeWithName:server:nodeDelegate:"), function $TNPubSubController__unsubscribeFromNodeWithName_server_nodeDelegate_(self, _cmd, aNodeName, aServer, nodeDelegate)
00196 {
00197     var node = self.isa.objj_msgSend2(self, "findOrCreateNodeWithName:server:", aNodeName, aServer);
00198     ((___r1 = self._nodes), ___r1 == null ? null : ___r1.isa.objj_msgSend1(___r1, "removeObject:", node));
00199     (node == null ? null : node.isa.objj_msgSend1(node, "setDelegate:", nodeDelegate));
00200     (node == null ? null : node.isa.objj_msgSend0(node, "unsubscribe"));
00201     return node;
00202     var ___r1;
00203 }
00204 ,["TNPubSubNode","CPString","TNStropheJID","id"]), new objj_method(sel_getUid("unsubscribeFromNodeWithName:server:"), function $TNPubSubController__unsubscribeFromNodeWithName_server_(self, _cmd, aNodeName, aServer)
00205 {
00206     return self.isa.objj_msgSend3(self, "unsubscribeFromNodeWithName:server:nodeDelegate:", aNodeName, aServer, nil);
00207 }
00208 ,["TNPubSubNode","CPString","TNStropheJID"]), new objj_method(sel_getUid("unsubscribeFromNodesWithNames:nodesDelegate:"), function $TNPubSubController__unsubscribeFromNodesWithNames_nodesDelegate_(self, _cmd, someNodes, aDelegate)
00209 {
00210     var batchID = ((___r1 = self._connection), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "getUniqueId")),
00211         servers = (someNodes == null ? null : someNodes.isa.objj_msgSend0(someNodes, "allKeys"));
00212     ((___r1 = self._unsubscriptionBatches), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "setValue:forKey:", someNodes, batchID));
00213     for (var k = 0; k < (servers == null ? null : servers.isa.objj_msgSend0(servers, "count")); k++)
00214     {
00215         var server = (servers == null ? null : servers.isa.objj_msgSend1(servers, "objectAtIndex:", k)),
00216             nodes = (servers == null ? null : servers.isa.objj_msgSend1(servers, "valueForKey:", server));
00217         for (var i = 0; i < (nodes == null ? null : nodes.isa.objj_msgSend0(nodes, "count")); i++)
00218         {
00219             var nodeName = (nodes == null ? null : nodes.isa.objj_msgSend1(nodes, "objectAtIndex:", i)),
00220                 node = self.isa.objj_msgSend3(self, "unsubscribeFromNodeWithName:server:nodeDelegate:", nodeName, server, aDelegate);
00221             ((___r1 = CPNotificationCenter.isa.objj_msgSend0(CPNotificationCenter, "defaultCenter")), ___r1 == null ? null : ___r1.isa.objj_msgSend(___r1, "addObserver:selector:name:object:userInfo:", self, sel_getUid("_didBatchUnsubscribe:"), TNStrophePubSubNodeUnsubscribedNotification, node, batchID));
00222         }
00223     }
00224     return batchID;
00225     var ___r1;
00226 }
00227 ,["CPString","CPDictionary","id"]), new objj_method(sel_getUid("unsubscribeFromAllNodes"), function $TNPubSubController__unsubscribeFromAllNodes(self, _cmd)
00228 {
00229     for (var i = 0; i < ((___r1 = self._nodes), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "count")); i++)
00230         ((___r1 = ((___r2 = self._nodes), ___r2 == null ? null : ___r2.isa.objj_msgSend1(___r2, "objectAtIndex:", i))), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "unsubscribe"));
00231     ((___r1 = self._nodes), ___r1 == null ? null : ___r1.isa.objj_msgSend0(___r1, "removeAllObjects"));
00232     var ___r1, ___r2;
00233 }
00234 ,["void"])]);
00235 class_addMethods(meta_class, [new objj_method(sel_getUid("pubSubControllerWithConnection:pubSubServer:"), function $TNPubSubController__pubSubControllerWithConnection_pubSubServer_(self, _cmd, aConnection, aPubSubServer)
00236 {
00237     return ((___r1 = TNPubSubController.isa.objj_msgSend0(TNPubSubController, "alloc")), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "initWithConnection:pubSubServer:", aConnection, aPubSubServer));
00238     var ___r1;
00239 }
00240 ,["TNPubSubNode","TNStropheConnection","CPString"]), new objj_method(sel_getUid("pubSubControllerWithConnection:"), function $TNPubSubController__pubSubControllerWithConnection_(self, _cmd, aConnection)
00241 {
00242     return ((___r1 = TNPubSubController.isa.objj_msgSend0(TNPubSubController, "alloc")), ___r1 == null ? null : ___r1.isa.objj_msgSend2(___r1, "initWithConnection:pubSubServer:", aConnection, nil));
00243     var ___r1;
00244 }
00245 ,["TNPubSubNode","TNStropheConnection"])]);
00246 }
 All Classes Namespaces Files Functions Variables