com.github.automately.java.eventbus

Class EventBus

java.lang.Object

com.github.automately.java.eventbus.EventBus

public class EventBus
extends Object

The EventBus class provides a way to connect to the Automately Cluster's underlying jsync.io EventBus system. The EventBus provides an interface for authentication, handler registering, and more. This class is very important.

Field Summary

Fields

Modifier and Type	Field and Description
static long	CLOSED
static long	CLOSING
static long	CONNECTING
static String	DEFAULT_HOST
static int	DEFAULT_PORT
static long	OPEN
static boolean	USE_SSL

Constructor Summary

Constructors

Constructor and Description
EventBus()
EventBus(io.jsync.Async async)

Method Summary

Modifier and Type	Method and Description
void	authenticate(String publicApiKey, String apikey, Event<Object> replyHandler)
void	authorise(Event<Object> replyHandler)
void	close()
void	connect()
void	login(String publicApiKey, Event<Object> replyHandler)
void	logout(Event<Object> replyHandler)
void	onClose(Runnable handler)
void	onOpen(Runnable handler)
void	publish(String address, Object message, Event<Object> replyHandler)
long	readyState()
void	registerHandler(String address, Event<Object> handler)
void	send(String address, Object message, Event<Object> replyHandler)
String	sessionID()
void	unregisterHandler(String address, Event<Object> handler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONNECTING

public static final long CONNECTING

See Also:

Constant Field Values

OPEN

public static final long OPEN

See Also:

Constant Field Values

CLOSING

public static final long CLOSING

See Also:

Constant Field Values

CLOSED

public static final long CLOSED

See Also:

Constant Field Values

DEFAULT_HOST

public static String DEFAULT_HOST

DEFAULT_PORT

public static int DEFAULT_PORT

USE_SSL

public static boolean USE_SSL

Constructor Detail

EventBus

public EventBus()

EventBus

public EventBus(io.jsync.Async async)

Method Detail

connect

public void connect()

onOpen

public void onOpen(Runnable handler)

onClose

public void onClose(Runnable handler)

readyState

public long readyState()

login

public void login(String publicApiKey,
                  Event<Object> replyHandler)

authenticate

public void authenticate(String publicApiKey,
                         String apikey,
                         Event<Object> replyHandler)

logout

public void logout(Event<Object> replyHandler)

authorise

public void authorise(Event<Object> replyHandler)

send

public void send(String address,
                 Object message,
                 Event<Object> replyHandler)

publish

public void publish(String address,
                    Object message,
                    Event<Object> replyHandler)

registerHandler

public void registerHandler(String address,
                            Event<Object> handler)

unregisterHandler

public void unregisterHandler(String address,
                              Event<Object> handler)

sessionID

public String sessionID()

close

public void close()
           throws Exception

Throws:

Exception