Delphi/delphimvcframework
1
0
Fork 0
mirror of https://github.com/danieleteti/delphimvcframework.git synced 2024-11-15 15:55:54 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Refactoring

Browse Source
This commit is contained in:
danieleteti 2016-08-09 13:11:11 +02:00
parent 6cbfffdb50
commit 617bfe47e6
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
sources/MVCFramework.MessagingController.pas
View File

@ -313,20 +313,21 @@ end;
procedure TMVCBUSController.InternalSubscribeUserToTopic(clientid, topicname: string;
StompClient: IStompClient);
var
LDurSubHeader: string;
LHeaders: IStompHeaders;
//var
// LDurSubHeader: string;
// LHeaders: IStompHeaders;
begin
LHeaders := TStompHeaders.Create;
LDurSubHeader := GetUniqueDurableHeader(clientid, topicname);
LHeaders.Add(TStompHeaders.NewDurableSubscriptionHeader(LDurSubHeader));
if topicname.StartsWith('/topic') then
LHeaders.Add('id', clientid); //https://www.rabbitmq.com/stomp.html
StompClient.Subscribe(topicname, amClient, LHeaders);
LogE('SUBSCRIBE TO ' + clientid + '@' + topicname + ' dursubheader:' + LDurSubHeader);
AddTopicToUserSubscriptions(topicname);
raise EMVCException.Create('Not implemented');
// LHeaders := TStompHeaders.Create;
// LDurSubHeader := GetUniqueDurableHeader(clientid, topicname);
// LHeaders.Add(TStompHeaders.NewDurableSubscriptionHeader(LDurSubHeader));
//
// if topicname.StartsWith('/topic') then
// LHeaders.Add('id', clientid); //https://www.rabbitmq.com/stomp.html
//
// StompClient.Subscribe(topicname, amClient, LHeaders);
// LogE('SUBSCRIBE TO ' + clientid + '@' + topicname + ' dursubheader:' + LDurSubHeader);
// AddTopicToUserSubscriptions(topicname);
end;
procedure TMVCBUSController.UnSubscribeFromTopic(CTX: TWebContext);