com.github.automately.java

Class MessageBus

java.lang.Object

com.github.automately.java.MessageBus

public class MessageBus
extends Object

The MessageBus is a pretty powerful feature that Automately offers. It is basically a clustered messaging system that allows your code to communicate at scale.

Constructor Summary

Constructors

Constructor and Description
MessageBus()

Method Summary

Modifier and Type	Method and Description
MessageBus	initialize(String publicKey, io.jsync.Handler<Boolean> callback)
MessageBus	initialize(String publicKey, String key, io.jsync.Handler<Boolean> callback)
boolean	initialized()
MessageBus	publish(String identifier, Object message)
MessageBus	registerHandler(String identifier, io.jsync.Handler<Object> handler)
MessageBus	send(String identifier, Object message)
MessageBus	send(String identifier, Object message, io.jsync.Handler<Object> handler)
MessageBus	stop()
boolean	stopping()
MessageBus	unregisterHandler(String identifier, io.jsync.Handler<Object> handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageBus

public MessageBus()

Method Detail

stopping

public boolean stopping()

initialized

public boolean initialized()

initialize

public MessageBus initialize(String publicKey,
                             io.jsync.Handler<Boolean> callback)

initialize

public MessageBus initialize(String publicKey,
                             String key,
                             io.jsync.Handler<Boolean> callback)

registerHandler

public MessageBus registerHandler(String identifier,
                                  io.jsync.Handler<Object> handler)

unregisterHandler

public MessageBus unregisterHandler(String identifier,
                                    io.jsync.Handler<Object> handler)

publish

public MessageBus publish(String identifier,
                          Object message)

send

public MessageBus send(String identifier,
                       Object message)

send

public MessageBus send(String identifier,
                       Object message,
                       io.jsync.Handler<Object> handler)

stop

public MessageBus stop()