mirror of
https://github.com/danieleteti/delphimvcframework.git
synced 2024-11-17 00:35:55 +01:00
116 lines
2.5 KiB
ObjectPascal
116 lines
2.5 KiB
ObjectPascal
|
unit MainForm;
|
||
|
|
||
|
interface
|
||
|
|
||
|
uses
|
||
|
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
|
||
|
Dialogs, StdCtrls, StompClient, StompTypes;
|
||
|
|
||
|
type
|
||
|
TfrmMain = class(TForm)
|
||
|
Edit1: TEdit;
|
||
|
Button2: TButton;
|
||
|
Button3: TButton;
|
||
|
Button4: TButton;
|
||
|
chkPersistent: TCheckBox;
|
||
|
Memo1: TMemo;
|
||
|
Button6: TButton;
|
||
|
Button1: TButton;
|
||
|
procedure FormCreate(Sender: TObject);
|
||
|
procedure FormClose(Sender: TObject; var Action: TCloseAction);
|
||
|
procedure Button6Click(Sender: TObject);
|
||
|
procedure Button2Click(Sender: TObject);
|
||
|
procedure Button3Click(Sender: TObject);
|
||
|
procedure Button4Click(Sender: TObject);
|
||
|
procedure Button1Click(Sender: TObject);
|
||
|
private
|
||
|
stomp: TStompClient;
|
||
|
tr: string;
|
||
|
public
|
||
|
{ Public declarations }
|
||
|
end;
|
||
|
|
||
|
var
|
||
|
frmMain: TfrmMain;
|
||
|
|
||
|
implementation
|
||
|
|
||
|
{$R *.dfm}
|
||
|
|
||
|
procedure TfrmMain.Button1Click(Sender: TObject);
|
||
|
var
|
||
|
h: IStompHeaders;
|
||
|
I: Integer;
|
||
|
msg: string;
|
||
|
begin
|
||
|
|
||
|
h := StompUtils.StompHeaders;
|
||
|
if chkPersistent.Checked then
|
||
|
h.Add(shPersistent);
|
||
|
|
||
|
for I := 1 to 10 do
|
||
|
begin
|
||
|
msg := format('%2.2d - %s',[i, Memo1.Lines.Text]);
|
||
|
if tr <> '' then
|
||
|
Stomp.Send(Edit1.Text, msg, tr, h)
|
||
|
else
|
||
|
Stomp.Send(Edit1.Text, msg, h);
|
||
|
end;
|
||
|
end;
|
||
|
|
||
|
procedure TfrmMain.Button2Click(Sender: TObject);
|
||
|
begin
|
||
|
if InputQuery('Begin transaction',
|
||
|
'Write a transaction identifier for this transaction', tr) then
|
||
|
Stomp.BeginTransaction(tr);
|
||
|
end;
|
||
|
|
||
|
procedure TfrmMain.Button3Click(Sender: TObject);
|
||
|
begin
|
||
|
if InputQuery('Abort transaction',
|
||
|
'Write a transaction identifier for this transaction', tr) then
|
||
|
begin
|
||
|
Stomp.AbortTransaction(tr);
|
||
|
tr := '';
|
||
|
end;
|
||
|
end;
|
||
|
|
||
|
procedure TfrmMain.Button4Click(Sender: TObject);
|
||
|
begin
|
||
|
if InputQuery('Commit transaction',
|
||
|
'Write a transaction identifier for this transaction', tr) then
|
||
|
begin
|
||
|
Stomp.CommitTransaction(tr);
|
||
|
tr := '';
|
||
|
end;
|
||
|
end;
|
||
|
|
||
|
procedure TfrmMain.Button6Click(Sender: TObject);
|
||
|
var
|
||
|
h: IStompHeaders;
|
||
|
begin
|
||
|
h := StompUtils.StompHeaders;
|
||
|
if chkPersistent.Checked then
|
||
|
h.Add(shPersistent);
|
||
|
if tr <> '' then
|
||
|
Stomp.Send(Edit1.Text, Memo1.Lines.Text, tr, h)
|
||
|
else
|
||
|
Stomp.Send(Edit1.Text, Memo1.Lines.Text, h);
|
||
|
end;
|
||
|
|
||
|
procedure TfrmMain.FormClose(Sender: TObject; var Action: TCloseAction);
|
||
|
begin
|
||
|
stomp.Disconnect;
|
||
|
stomp.Free;
|
||
|
end;
|
||
|
|
||
|
procedure TfrmMain.FormCreate(Sender: TObject);
|
||
|
begin
|
||
|
stomp := TStompClient.Create;
|
||
|
stomp.Connect('localhost');
|
||
|
tr := '';
|
||
|
end;
|
||
|
|
||
|
end.
|
||
|
|