A B C D E F H I M O P R S T U V W

A

AbstractServerSocket<T> - Interface in io.cettia

AbstractSocket consists of a set of common functionality of Sentence and ServerSocket.

all(Action<ServerSocket>) - Method in class io.cettia.ClusteredServer

all() - Method in class io.cettia.DefaultServer

all(Action<ServerSocket>) - Method in class io.cettia.DefaultServer

all() - Method in interface io.cettia.Server

Returns a sentence that every socket in this server has to follow.

all(Action<ServerSocket>) - Method in interface io.cettia.Server

Executes the given action retrieving every socket in this server.

B

BaseServerTransport - Class in io.cettia.transport

Base class for ServerTransport.

BaseServerTransport() - Constructor for class io.cettia.transport.BaseServerTransport

binaryActions - Variable in class io.cettia.transport.BaseServerTransport

byTag(String[], Action<ServerSocket>) - Method in class io.cettia.ClusteredServer

byTag(String...) - Method in class io.cettia.DefaultServer

byTag(String, Action<ServerSocket>) - Method in class io.cettia.DefaultServer

byTag(String[], Action<ServerSocket>) - Method in class io.cettia.DefaultServer

byTag(String...) - Method in interface io.cettia.Server

Returns a sentence that the socket tagged with the given tags in this server have to follow.

byTag(String, Action<ServerSocket>) - Method in interface io.cettia.Server

Executes the given action retrieving the socket tagged with the given tag in this server.

byTag(String[], Action<ServerSocket>) - Method in interface io.cettia.Server

Executes the given action retrieving the socket tagged with the given tags in this server.

C

close() - Method in interface io.cettia.AbstractServerSocket

Closes the socket.

close() - Method in class io.cettia.Sentence

close() - Method in class io.cettia.transport.BaseServerTransport

close() - Method in interface io.cettia.transport.ServerTransport

Closes the connection.

closeActions - Variable in class io.cettia.transport.BaseServerTransport

ClusteredServer - Class in io.cettia

Server implementation for clustering.

ClusteredServer() - Constructor for class io.cettia.ClusteredServer

D

data() - Method in interface io.cettia.ServerSocket.Reply

The original data.

DefaultServer - Class in io.cettia

Default implementation of Server.

DefaultServer() - Constructor for class io.cettia.DefaultServer

doClose() - Method in class io.cettia.transport.BaseServerTransport

doSend(String) - Method in class io.cettia.transport.BaseServerTransport

doSend(ByteBuffer) - Method in class io.cettia.transport.BaseServerTransport

E

errorActions - Variable in class io.cettia.transport.BaseServerTransport

F

formatQuery(Map<String, String>) - Static method in class io.cettia.transport.http.HttpTransportServer

For internal use only.

H

HeartbeatFailedException - Exception in io.cettia

An exception to be thrown when heartbeat operations fails.

HeartbeatFailedException() - Constructor for exception io.cettia.HeartbeatFailedException

HttpTransportServer - Class in io.cettia.transport.http

HTTP implementation of TransportServer.

HttpTransportServer() - Constructor for class io.cettia.transport.http.HttpTransportServer

I

io.cettia - package io.cettia

io.cettia.transport - package io.cettia.transport

io.cettia.transport.http - package io.cettia.transport.http

io.cettia.transport.websocket - package io.cettia.transport.websocket

M

messageAction() - Method in class io.cettia.ClusteredServer

An action to receive a message published from one of nodes in the cluster.

O

off(String, Action<T>) - Method in interface io.cettia.ServerSocket

Removes a given event handler for a given event.

on(ServerTransport) - Method in class io.cettia.DefaultServer

on(String, Action<T>) - Method in interface io.cettia.ServerSocket

Adds a given event handler for a given event.

on(ServerHttpExchange) - Method in class io.cettia.transport.http.HttpTransportServer

on(ServerWebSocket) - Method in class io.cettia.transport.websocket.WebSocketTransportServer

onbinary(Action<ByteBuffer>) - Method in class io.cettia.transport.BaseServerTransport

onbinary(Action<ByteBuffer>) - Method in interface io.cettia.transport.ServerTransport

Attaches an action for the binary message.

oncache(Action<Object[]>) - Method in interface io.cettia.ServerSocket

Adds a cache event handler to be called if one of send methods is called when there is no connection.

onclose(Action<Void>) - Method in interface io.cettia.ServerSocket

Adds a close event handler to be called when the underlying transport is closed for any reason.

onclose(Action<Void>) - Method in class io.cettia.transport.BaseServerTransport

onclose(Action<Void>) - Method in interface io.cettia.transport.ServerTransport

Attaches an action for the close event.

ondelete(Action<Void>) - Method in interface io.cettia.ServerSocket

Adds a delete event handler to be called when the socket is in the closed state for a long time i.e.

onerror(Action<Throwable>) - Method in interface io.cettia.ServerSocket

Adds an error event handler to be called if there was any error on the socket.

onerror(Action<Throwable>) - Method in class io.cettia.transport.BaseServerTransport

onerror(Action<Throwable>) - Method in interface io.cettia.transport.ServerTransport

Executed if there was any error on the connection.

onopen(Action<Void>) - Method in interface io.cettia.ServerSocket

Adds an open event handler to be called when the handshake is performed successfully and communication is possible.

onpublish(Action<Map<String, Object>>) - Method in class io.cettia.ClusteredServer

Adds an action to be called with a message to be published to every node in the cluster.

onsocket(Action<ServerSocket>) - Method in class io.cettia.DefaultServer

onsocket(Action<ServerSocket>) - Method in interface io.cettia.Server

Adds a socket event handler to be called when the socket has been created in this server.

ontext(Action<String>) - Method in class io.cettia.transport.BaseServerTransport

ontext(Action<String>) - Method in interface io.cettia.transport.ServerTransport

Attaches an action for the text message.

ontransport(Action<ServerTransport>) - Method in class io.cettia.transport.http.HttpTransportServer

ontransport(Action<ServerTransport>) - Method in interface io.cettia.transport.TransportServer

Registers an action to be called when the transport has been opened.

ontransport(Action<ServerTransport>) - Method in class io.cettia.transport.websocket.WebSocketTransportServer

P

parseQuery(String) - Static method in class io.cettia.transport.http.HttpTransportServer

For internal use only.

R

reject() - Method in interface io.cettia.ServerSocket.Reply

Rejects.

reject(Object) - Method in interface io.cettia.ServerSocket.Reply

Rejects with the reason.

resolve() - Method in interface io.cettia.ServerSocket.Reply

Resolves.

resolve(Object) - Method in interface io.cettia.ServerSocket.Reply

Resolves with the value.

S

send(String) - Method in interface io.cettia.AbstractServerSocket

Sends a given event without data.

send(String, Object) - Method in interface io.cettia.AbstractServerSocket

Sends a given event with data.

send(String) - Method in class io.cettia.Sentence

send(String, Object) - Method in class io.cettia.Sentence

send(String, Object, Action<T>) - Method in interface io.cettia.ServerSocket

Sends a given event with data attaching resolved callback.

send(String, Object, Action<T>, Action<U>) - Method in interface io.cettia.ServerSocket

Sends a given event with data attaching resolved callback and rejected callback.

send(String) - Method in class io.cettia.transport.BaseServerTransport

send(ByteBuffer) - Method in class io.cettia.transport.BaseServerTransport

send(String) - Method in interface io.cettia.transport.ServerTransport

Sends a text message through the connection.

send(ByteBuffer) - Method in interface io.cettia.transport.ServerTransport

Sends a binary message through the connection.

Sentence - Class in io.cettia

Sentence is a series of predicates that a group of socket have to follow.

Server - Interface in io.cettia

Interface used to interact with sockets.

ServerSocket - Interface in io.cettia

Interface used to interact with the remote socket.

ServerSocket.Reply<T> - Interface in io.cettia

Interface to deal with reply.

ServerSocket.State - Enum in io.cettia

Enumeration of the state of the socket.

ServerTransport - Interface in io.cettia.transport

Represents a server-side full duplex message channel ensuring there is no message loss and no idle connection.

set_heartbeat(int) - Method in class io.cettia.DefaultServer

To speed up the protocol tests.

setHeartbeat(int) - Method in class io.cettia.DefaultServer

A heartbeat interval in milliseconds to maintain a connection alive and prevent server from holding idle connections.

state() - Method in interface io.cettia.ServerSocket

The current state of the socket.

T

tag(String...) - Method in interface io.cettia.AbstractServerSocket

Attaches given tags to the socket.

tag(String...) - Method in class io.cettia.Sentence

tags() - Method in interface io.cettia.ServerSocket

A modifiable set of tag names.

textActions - Variable in class io.cettia.transport.BaseServerTransport

TransportServer<T> - Interface in io.cettia.transport

Interface used to interact with transports.

U

untag(String...) - Method in interface io.cettia.AbstractServerSocket

Detaches given tags from the socket.

untag(String...) - Method in class io.cettia.Sentence

unwrap(Class<T>) - Method in interface io.cettia.ServerSocket

Returns the underlying component.

unwrap(Class<T>) - Method in interface io.cettia.transport.ServerTransport

Returns the underlying component.

uri() - Method in interface io.cettia.ServerSocket

A URI used to connect.

uri() - Method in interface io.cettia.transport.ServerTransport

A URI used to connect.

V

valueOf(String) - Static method in enum io.cettia.ServerSocket.State

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.cettia.ServerSocket.State

Returns an array containing the constants of this enum type, in the order they are declared.

W

WebSocketTransportServer - Class in io.cettia.transport.websocket

Websocket implementation of TransportServer.

WebSocketTransportServer() - Constructor for class io.cettia.transport.websocket.WebSocketTransportServer

A B C D E F H I M O P R S T U V W