A B C D E F H I M O P R S T U 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 have 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.
onclose(Action<Void>) - Method in interface io.cettia.ServerSocket
Executed if the socket 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.
onerror(Action<Throwable>) - Method in interface io.cettia.ServerSocket
Executed 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.
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
Registers an action to be called when the socket has been opened 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.
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.

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.

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 W 

Copyright 2015, The Cettia Project