org.myrobotlab.service

Class Shoutbox

java.lang.Object

org.myrobotlab.framework.Service

org.myrobotlab.service.Shoutbox

All Implemented Interfaces:

Serializable, Runnable, Attachable, Broadcaster, Invoker, LoggingSink, MessageSender, MessageSubscriber, NameProvider, NameTypeProvider, ServiceInterface, ServiceQueue, ServiceStatus, StatePublisher, StateSaver, StatusPublisher, TypeProvider, QueueReporter

public class Shoutbox
extends Service

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Shoutbox.DefaultNameProvider
static interface	Shoutbox.NameProvider
static class	Shoutbox.Shout POJO Shout is the most common message structure being sent from client to WSServer and from WSServer broadcasted to clients - therefore instead of a seperate system message we will have system data components of the shout - these are to display server data on the clients

Field Summary

Fields

Modifier and Type	Field and Description
protected Calendar	cal
static org.slf4j.Logger	log
static String	ORGIN_WEB
static String	ORGIN_XMPP
protected SimpleDateFormat	tsFormatter
static String	TYPE_SYSTEM
static String	TYPE_USER

Fields inherited from class org.myrobotlab.framework.Service

authProvider, defaultLocalization, dnaPool, fs, id, inbox, interfaceSet, isVirtual, lastError, lastErrorTs, lastStatus, lastStatusTs, locale, localization, methodSet, outbox, ps, ready, serviceClass, serviceType, serviceVersion, simpleName, statusBroadcastLimitMs, thisThread

Constructor Summary

Constructors

Constructor and Description
Shoutbox(String n, String id)

Method Summary

Modifier and Type	Method and Description
String	addXMPPRelay(String user)
void	archive(Shoutbox.Shout shout)
Shoutbox.Shout	createShout(String type, String msg)
String	findChatBotName(String msg)
void	getXMPPRelays()
void	loadShouts() archiving restores last json file back into newly started shoutbox
static void	main(String[] args)
static String	makeKey(String ws)
void	mimicTuring(String msg)
Response	onResponse(Response response)
void	onXMPPMsg(Xmpp.XmppMsg xmppMsg)
Shoutbox.Shout	publishShout(Shoutbox.Shout shout)
void	quickStart(String xmpp, String password)
String	removeXMPPRelay(String user)
void	savePredicates()
void	sendTo(String type, String key, Object data)
void	setNameProvider(Shoutbox.NameProvider nameProvider2)
Shoutbox.NameProvider	setNameProvider(String classname)
void	setNickName(String nickname)
void	shout(String msg)
void	shout(String clientId, String msg)
void	startChatBot()
void	startService()
void	startXMPP(String user, String password)

Methods inherited from class org.myrobotlab.framework.Service

addListener, addListener, addListener, addListener, addTask, addTask, addTask, addTaskOneShot, attach, attach, broadcast, broadcast, broadcastState, broadcastStatus, buildDna, buildDna, buildDnaKeys, buildDnaNames, clearLastError, close, containsTask, copyResource, copyShallowFrom, createPeer, createPeer, createRootReserved, detach, detach, detach, echoHeartbeat, error, error, error, export, export, exportAll, exportAll, getAttached, getCountry, getDataDir, getDataDir, getDataInstanceDir, getDeclaredMethodNames, getDeclaredMethods, getDescription, getDisplayLanguage, getDna, getDnaString, getFile, getFullName, getHomeDir, getHostName, getId, getInbox, getInstanceId, getIntanceName, getInterfaceSet, getLanguage, getLastError, getLocale, getLocaleTag, getMessageSet, getMetaData, getMethodMap, getMethodNames, getMethods, getMethodToolTip, getMsg, getName, getNotifyList, getNotifyListKeySet, getOutbox, getPeer, getPeerKey, getPeerName, getResource, getResource, getResource, getResourceAsString, getResourceAsString, getResourceAsString, getResourceDir, getResourceDir, getResourceDir, getResourceDir, getResourceDirList, getResourceDirList, getResourceImage, getResourceRoot, getRootDataDir, getServiceIcon, getServiceIcon, getServiceIcon, getServiceScript, getServiceScript, getServiceScript, getSimpleName, getSwagger, getTasks, getThisThread, getType, hasError, hasInternet, hasPeers, hasSubscribed, help, in, info, info, invoke, invoke, invoke, invokeOn, invokeOn, invokePeer, invokePeer, isAttached, isAttached, isDev, isHeadless, isLocal, isReady, isRunning, isRuntime, isVirtual, load, load, loadAndStart, loadFromJson, loadFromJson, loadLocalizations, localize, localize, logTimeEnable, mergeDna, mergeDna, mergePeerDna, movePeerDna, out, out, preProcessHook, preRoutingHook, preShutdown, publishError, publishQueueStats, publishState, publishStats, publishStatus, purgeTask, purgeTasks, releasePeer, releasePeers, releaseService, removeAllListeners, removeListener, removeListener, requiresSecurity, reserve, reserve, reserveRoot, reserveRoot, reserveRootAs, run, save, save, save, send, send, send, sendBlocking, sendBlocking, sendBlocking, sendBlocking, sendPeer, sendToPeer, sendToPeer, setId, setInstanceId, setLocale, setName, setOrder, setPeer, setReady, setSecurityProvider, setState, setThisThread, setVirtual, sleep, sleep, stackToString, startPeer, startPeer, startPeers, stopService, subscribe, subscribe, subscribe, subscribeTo, subscribeToRuntime, toString, unsubscribe, unsubscribe, unsubscribe, unsubscribeTo, unsubscribeToRuntime, updateStats, warn, warn

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final org.slf4j.Logger log

TYPE_SYSTEM

public static final String TYPE_SYSTEM

See Also:

Constant Field Values

TYPE_USER

public static final String TYPE_USER

See Also:

Constant Field Values

ORGIN_XMPP

public static final String ORGIN_XMPP

See Also:

Constant Field Values

ORGIN_WEB

public static final String ORGIN_WEB

See Also:

Constant Field Values

tsFormatter

protected transient SimpleDateFormat tsFormatter

cal

protected transient Calendar cal

Constructor Detail

Shoutbox

public Shoutbox(String n,
                String id)

Method Detail

makeKey

public static String makeKey(String ws)

addXMPPRelay

public String addXMPPRelay(String user)

archive

public void archive(Shoutbox.Shout shout)

createShout

public Shoutbox.Shout createShout(String type,
                                  String msg)

findChatBotName

public String findChatBotName(String msg)

getXMPPRelays

public void getXMPPRelays()

loadShouts

public void loadShouts()

archiving restores last json file back into newly started shoutbox

setNickName

public void setNickName(String nickname)

mimicTuring

public void mimicTuring(String msg)

onResponse

public Response onResponse(Response response)

onXMPPMsg

public void onXMPPMsg(Xmpp.XmppMsg xmppMsg)

shout

public void shout(String msg)

shout

public void shout(String clientId,
                  String msg)

publishShout

public Shoutbox.Shout publishShout(Shoutbox.Shout shout)
                            throws org.jivesoftware.smack.SmackException.NotConnectedException,
                                   org.jivesoftware.smack.XMPPException,
                                   IOException

Throws:

org.jivesoftware.smack.SmackException.NotConnectedException

org.jivesoftware.smack.XMPPException

IOException

quickStart

public void quickStart(String xmpp,
                       String password)
                throws Exception

Throws:

Exception

removeXMPPRelay

public String removeXMPPRelay(String user)

savePredicates

public void savePredicates()

sendTo

public void sendTo(String type,
                   String key,
                   Object data)

setNameProvider

public void setNameProvider(Shoutbox.NameProvider nameProvider2)

setNameProvider

public Shoutbox.NameProvider setNameProvider(String classname)
                                      throws ClassNotFoundException,
                                             InstantiationException,
                                             IllegalAccessException

Throws:

ClassNotFoundException

InstantiationException

IllegalAccessException

startChatBot

public void startChatBot()
                  throws IOException

Throws:

IOException

startService

public void startService()

Specified by:

startService in interface ServiceInterface

Overrides:

startService in class Service

startXMPP

public void startXMPP(String user,
                      String password)
               throws Exception

Throws:

Exception

main

public static void main(String[] args)