ketty.client

Class IPCClient<T>

ketty.client.IPCClient<T>

Type Parameters:

T - The call type class, typically string, numbers and enums.

public class IPCClient<T>

The IPC Client class send messages to IPC server can execute callback when response was received.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IPCClient.Companion

Field Summary

Fields

Modifier and Type	Field and Description
static IPCClient.Companion	Companion

Method Summary

Modifier and Type	Method and Description
void	close() Close IPC client and release all related resources..
java.lang.String	getSessionId()
boolean	isConnected() Check connection is well.
void	send(RequestType<T> type, Body body, kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback) Send request packet to server.
void	send(RequestType<T> type, Body body, Callback callback) Send request packet to server.
void	send(RequestType<T> type, io.netty.buffer.ByteBuf data, kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback) Send request packet to server.
void	send(RequestType<T> type, io.netty.buffer.ByteBuf data, Callback callback) Send request packet to server.
void	send(RequestType<T> type, java.nio.ByteBuffer data, kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback) Send request packet to server.
void	send(RequestType<T> type, java.nio.ByteBuffer data, Callback callback) Send request packet to server.
void	send(RequestType<T> type, byte[] data, kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback) Send request packet to server.
void	send(RequestType<T> type, byte[] data, Callback callback) Send request packet to server.
java.util.concurrent.Future<ketty.common.Packet>	send(RequestType<T> type, Body body) Send request packet to server.
java.util.concurrent.Future<ketty.common.Packet>	send(RequestType<T> type, io.netty.buffer.ByteBuf data) Send request packet to server.
java.util.concurrent.Future<ketty.common.Packet>	send(RequestType<T> type, java.nio.ByteBuffer data) Send request packet to server.
java.util.concurrent.Future<ketty.common.Packet>	send(RequestType<T> type, byte[] data) Send request packet to server.
Packet<NonExistentClass>	sendSync(RequestType<T> type, Body body) Send request packet to server.
Packet<NonExistentClass>	sendSync(RequestType<T> type, io.netty.buffer.ByteBuf data) Send request packet to server.
Packet<NonExistentClass>	sendSync(RequestType<T> type, java.nio.ByteBuffer data) Send request packet to server.
Packet<NonExistentClass>	sendSync(RequestType<T> type, byte[] data) Send request packet to server.

Field Detail

Companion

public static IPCClient.Companion Companion

Method Detail

getSessionId

public java.lang.String getSessionId()

send

public void send(RequestType<T> type,
                 Body body,
                 kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback)

Send request packet to server.

Parameters:

type - call type

body - request body

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 Body body,
                 Callback callback)

Send request packet to server.

Parameters:

type - call type

body - request body

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 io.netty.buffer.ByteBuf data,
                 kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback)

Send request packet to server.

Parameters:

type - call type

data - request data

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 io.netty.buffer.ByteBuf data,
                 Callback callback)

Send request packet to server.

Parameters:

type - call type

data - request data

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 java.nio.ByteBuffer data,
                 kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback)

Send request packet to server.

Parameters:

type - call type

data - request data

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 java.nio.ByteBuffer data,
                 Callback callback)

Send request packet to server.

Parameters:

type - call type

data - request data

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 byte[] data,
                 kotlin.jvm.functions.Function1<? super ketty.common.Packet<error.NonExistentClass>,? extends java.lang.Object> callback)

Send request packet to server.

Parameters:

type - call type

data - request data

callback - code block to handle response packet

send

public void send(RequestType<T> type,
                 byte[] data,
                 Callback callback)

Send request packet to server.

Parameters:

type - call type

data - request data

callback - code block to handle response packet

send

public java.util.concurrent.Future<ketty.common.Packet> send(RequestType<T> type,
                                                             Body body)

Send request packet to server.

Parameters:

type - call type

body - request body

Returns:

Future object of response packet

send

public java.util.concurrent.Future<ketty.common.Packet> send(RequestType<T> type,
                                                             io.netty.buffer.ByteBuf data)

Send request packet to server.

Parameters:

type - call type

data - request data

Returns:

Future object of response packet

send

public java.util.concurrent.Future<ketty.common.Packet> send(RequestType<T> type,
                                                             java.nio.ByteBuffer data)

Send request packet to server.

Parameters:

type - call type

data - request data

Returns:

Future object of response packet

send

public java.util.concurrent.Future<ketty.common.Packet> send(RequestType<T> type,
                                                             byte[] data)

Send request packet to server.

Parameters:

type - call type

data - request data

Returns:

Future object of response packet

sendSync

public Packet<NonExistentClass> sendSync(RequestType<T> type,
                                         Body body)

Send request packet to server.

Parameters:

type - call type

body - request body

Returns:

response packet

sendSync

public Packet<NonExistentClass> sendSync(RequestType<T> type,
                                         io.netty.buffer.ByteBuf data)

Send request packet to server.

Parameters:

type - call type

data - request data

Returns:

response packet

sendSync

public Packet<NonExistentClass> sendSync(RequestType<T> type,
                                         java.nio.ByteBuffer data)

Send request packet to server.

Parameters:

type - call type

data - request data

Returns:

response packet

sendSync

public Packet<NonExistentClass> sendSync(RequestType<T> type,
                                         byte[] data)

Send request packet to server.

Parameters:

type - call type

data - request data

Returns:

response packet

close

public void close()

Close IPC client and release all related resources..

isConnected

public boolean isConnected()

Check connection is well.

Returns:

true is connected.