uses
sgcWebSocket, sgcWebSocket_Classes,
sgcWebSocket_Protocol_sgc_Client;
procedure TForm1.FormCreate(Sender: TObject);
begin
FClient := TsgcWebSocketClient.Create(Self);
FClient.Host := 'www.esegece.com';
FClient.Port := 2053;
FClient.TLS := True;
FClient.OnConnect := ClientConnect;
FProtocol := TsgcWSPClient_sgc.Create(Self);
FProtocol.Client := FClient;
FProtocol.OnMessage := ProtocolMessage;
FClient.Active := True;
end;
procedure TForm1.ClientConnect(Connection: TsgcWSConnection);
begin
FProtocol.Subscribe('orders');
FProtocol.Broadcast('{"id":42,"status":"filled"}', 'orders');
end;
procedure TForm1.ProtocolMessage(Connection: TsgcWSConnection;
const Text: string);
begin
Memo1.Lines.Add(Text);
end;
// uses: sgcWebSocket, sgcWebSocket_Classes,
// sgcWebSocket_Protocol_sgc_Client
FClient = new TsgcWebSocketClient(this);
FClient->Host = "www.esegece.com";
FClient->Port = 2053;
FClient->TLS = true;
FClient->OnConnect = ClientConnect;
FProtocol = new TsgcWSPClient_sgc(this);
FProtocol->Client = FClient;
FProtocol->OnMessage = ProtocolMessage;
FClient->Active = true;
void __fastcall TForm1::ClientConnect(TsgcWSConnection *Connection)
{
FProtocol->Subscribe("orders");
FProtocol->Broadcast("{\"id\":42,\"status\":\"filled\"}", "orders");
}
void __fastcall TForm1::ProtocolMessage(TsgcWSConnection *Connection,
const UnicodeString Text)
{
Memo1->Lines->Add(Text);
}
using esegece.sgcWebSockets;
var client = new TsgcWebSocketClient();
client.Host = "www.esegece.com";
client.Port = 2053;
client.TLS = true;
var protocol = new TsgcWSPClient_sgc();
protocol.Client = client;
protocol.OnMessage += (conn, text) => Console.WriteLine(text);
client.OnConnect += (conn) =>
{
protocol.Subscribe("orders");
protocol.Broadcast("{\"id\":42,\"status\":\"filled\"}", "orders");
};
client.Active = true;