B4J Question Apache - Thrift class implemetation

[Asoka]

Hi Everybody!
I want to connect a running local server which communicates with apache thrift. The server uses port: 9096:

[CODE lang="b4x" title="1st try (with socket connect):"]Sub POS_Connect

Socket_POS.Connect("::1",9096,0)

Wait For SocketPOS_Connected (Successful As Boolean)
If Successful Then
POS_Connected = True
Log("Connection successful at: " & DateTime.Time(DateTime.Now))

Else
POS_Connected=False
Log("POS Connect Error: " & LastException)
End If
End Sub[/CODE]

The connection is successful, but how can I implement or subscribe a thrift class???

[CODE lang="b4x" title="2nd try (with MQTT):"]Sub MQTT_Connect_POS
Dim m As MqttConnectOptions
m.Initialize("","")

MQTT.Initialize("MQTT","tcp://::1:9096", "AutomataPosSrv")
MQTT.Connect

Wait For MQTT_Connected (Success As Boolean)
If Success = True Then
Log("Client connected!!!")
MainForm.Title = "Connected"
'MQTT.Subscribe("Some Thrift Class", 0)
Else
Log(LastException )
MainForm.Title = LastException

End If

End Sub[/CODE]

What is the correct wa to solve the problem?

Here is a working java sample:

try {
            Tsocket transport = new TSocket("::1", 9006);
            TProtocol protocol = new TBinaryProtocol(transport);
            transportOpen();
            AutomataPrinterSrv.Client
                client = new AutomataPosSrv.Client(protocol);
                
        } catch (Exception e) {
            e.printStackTrace();
        }

I must write this code in B4j ....
Thank You!

 

[Erel]

MQTT will not work unless you are connecting to a MQTT broker.

You need to find the exact details of the protocol used by the server and implement it with AsyncStreams.

 

[Asoka]

OK, Thank You!

I forget "MQTT".

Let's see step by step:

[CODE lang="b4x" title="There's a ServerSocket to listen:"]Listener.Initialize(9190, "Listener")
Listener.Listen [/CODE]

I connect to the Server Application which Communicates with thrift:

[CODE lang="b4x" title="The Server_POS is a socket:"]Sub POS_Connect

Socket_POS.Connect("::1",9096,0)
Wait For SocketPOS_Connected (Successful As Boolean)
If Successful Then
POS_Connected = True
Log("Connection successful at: " & DateTime.Time(DateTime.Now))
Else
POS_Connected=False
Log("POS Connect Error: " & LastException)
End If
End Sub[/CODE]

How can I implement server classes with AsyncStream?
The thrift is known, the protocol: "AutomataSrv.Client"
After sunbscribe the client I must call thrift functions.

The listener is only need for server async messages.

Thank You!

 

[Erel]

Sorry but I'm not familiar with Thrift protocol. Either find a library that implements this protocol or you will need to implement it yourself.

 

[Asoka]

Thank You for Your answer!
I'm searching ...
If i find a solution I write It.
Bye