Chronicle-Network: How to send a message asynchronously on a acceptor

[maxim...@gmail.com]

Hi,

I want to use Chronicle-Network to create a basic FIX server to testing purpose.

I use Chronicle-Network because I need it to have the better performance (Low Latency).

I have read documentation/example and I create my own server (AcceptorEventHandler) without Chronicle-Wire (direct TcpHandler implementation).

I succeed to read FIX Messages (thanks to SAXophone)  but I want to write FIX message asynchronously.

To my understanding, the only way to write messages is to use "Bytes out" on "net.openhft.chronicle.network.api.TcpHandler":

public void process(Bytes in, Bytes out, SessionDetailsProvider sessionDetails) {

In my usage, I need to send messages/bytes outside of this method.

I check source code but I did not find a way to send bytes on the SocketChannel created by AcceptorEventHandler.

I mean that I have no access to SocketChannel objects.

Could you explain how to directly send messages to SocketChannels created by AcceptorEventHandler?

Regards,

Maxime

[Rob Austin]

Maxime

We have an enterprise product that ( should do ) what you want, would you be interested in having further discussions about this 

Rob

 

--
You received this message because you are subscribed to the Google Groups "Chronicle" group.
To unsubscribe from this group and stop receiving emails from it, send an email to java-chronicl...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Peter Lawrey]

Hello Maxime,

   What is the problem with writing to the Bytes buffer instead of the SocketChannel? You will need to use a ByteBuffer either way, the only limitation is you have to use the one provided.

Regards,

   Peter.

--

[maxim...@gmail.com]

Hi,

I copy "Bytes out" on "TcpHandler" "process" method to another Object to keep a reference on it:

public void process(Bytes in, Bytes out, SessionDetailsProvider sessionDetails) {

And when I want to write messages asynchronously, I do :

out.write(bytes)

But it does not write anything on socket.

When I debug my application on "TcpEventHandler" I see that "outBBB" is correctly filled, but this is only "outBB" that is written on  "WriteEventHandler".

I am not familiar with ByteBuffer, so I am sure I am doing "bad things" but I do not understand my error.

Rob, for Enterprise product (Chronicle-FIX I guess) I have to check with my company (Top-Managers) to see if we can buy Enterprise Licence. 

But I will be pleased to test it :-)

To be honest, as the "Decision Center" is based on USA (big world-wide company), I do not know the exact policy about library licensing, but I will ask about it.

Regards,

Maxime

[maxim...@gmail.com]

Hi,

Sorry to annoying you (again) with that, but could you help me with Chronicle-Network?

Here is my issue:

I copy "Bytes out" on "TcpHandler" "process" method to another Object to keep a reference on it:

public void process(Bytes in, Bytes out, SessionDetailsProvider sessionDetails) {

And when I want to write messages asynchronously, I do :

out.write(bytes)

But it does not write anything on socket.

When I debug my application on "TcpEventHandler" I see that "outBBB" is correctly filled, but this is only "outBB" that is written on  "WriteEventHandler".

I am not familiar with ByteBuffer, so I am sure I am doing "bad things" but I do not understand my error.

Regards,

Maxime

[Rob Austin]

if you wanted to copy to a byte array 

this.copyTo(new byte[(int)this.readRemaining()]);

Tob

[Rob Austin]

or rather

out.copyTo(new byte[(int)this.readRemaining()]);

[maxim...@gmail.com]

Hi,

There is a misunderstanding here, I want to write asynchronously on "net.openhft.chronicle.network.api.TcpHandler".

Indeed, I create a server with "net.openhft.chronicle.network.AcceptorEventHandler" that accepts "TcpHandler".

When I receive a message on "public void process(Bytes in, Bytes out, SessionDetailsProvider sessionDetails)" I read the message thanks to "Bytes in" and I transfer this message to another thread.

This other thread after some processing want to send a message on the same socket.

I am blocked on this point because I do not succeed to send this message, 

I try to save the "Bytes out" from last "process" function called to read, but it did not work.

Have you an example of this kind of code?

Regards,

Maxime