org.myrobotlab.service

Class PythonProxy

java.lang.Object

org.myrobotlab.framework.MessageService

org.myrobotlab.framework.Service

org.myrobotlab.service.PythonProxy

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable, Attachable, Invoker, LoggingSink, MessageSender, MessageSubscriber, NameProvider, NameTypeProvider, ServiceInterface, ServiceQueue, StateSaver, TypeProvider, QueueReporter

Direct Known Subclasses:

_TemplateProxy, GoogleAssistant

public class PythonProxy
extends Service

This class exists as a proxy to control native MRL services connected through the web API. Methods of that native service are called through this class's exec(String, Object[]) method. FIXME - although this is a great idea & implementation, something more general needs to exist in order to interoperate between processes - it will be coming as a network overlay & addressing system in the next release

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PythonProxy.InputQueueThread

Field Summary

Fields

Modifier and Type	Field and Description
int	retTimeout
boolean	startNativeService
boolean	startTerminal
static WebGui	webgui

Fields inherited from class org.myrobotlab.framework.Service

cfgDir, dnaPool, MESSAGE_RECORDING_FORMAT_BINARY, MESSAGE_RECORDING_FORMAT_XML

Constructor Summary

Constructors

Constructor and Description
PythonProxy(java.lang.String n)

Method Summary

Modifier and Type	Method and Description
static ServiceType	addMetaData(ServiceType meta)
java.lang.Object	exec(Message msg) Execute Message msg on the native service this class represents.
java.lang.Object	exec(java.lang.String method, java.lang.Object[] dat) Execute method with params dat on the native service this class represents.
static org.slf4j.Logger	getLogger()
static ServiceType	getMetaData() This static method returns all the details of the class without it having to be constructed.
void	handshake() This is called by the native service to start the handshake sequence.
void	log(java.lang.String txt)
static void	main(java.lang.String[] args)
boolean	preProcessHook(Message msg) preProcessHook is used to intercept messages and process or route them before being processed/invoked in the Service.
void	returnData(java.lang.Object obj)
void	startNativeService() This is used to start the native service.
void	startService()

Methods inherited from class org.myrobotlab.framework.Service

addListener, addListener, addTask, addTask, addTask, addTaskOneShot, allowDisplay, allowDisplay, attach, attach, broadcastState, buildDna, buildDna, buildDnaKeys, buildDnaNames, clearLastError, close, containsTask, copyShallowFrom, createPeer, createPeer, createRootReserved, detach, detach, detach, echoHeartbeat, error, error, error, getAttached, getCfgDir, getComm, getDeclaredMethodNames, getDeclaredMethods, getDescription, getDna, getDnaString, getHostName, getInbox, getInstanceId, getIntanceName, getInterfaceSet, getLastError, getMessageSet, getMetaData, getMethodMap, getMethodNames, getMethods, getMethodToolTip, getMsg, getName, getNotifyList, getNotifyListKeySet, getOutbox, getPeerKey, getPeerName, getServiceResourceFile, getSimpleName, getTasks, getThisThread, getType, hasError, hasPeers, help, help, in, info, info, invoke, invoke, invoke, invokeOn, isAttached, isAttached, isLocal, isReady, isRunning, isRuntime, isVirtual, load, load, logTimeEnable, mergeDna, mergeDna, mergePeerDna, movePeerDna, out, out, preRoutingHook, publishError, publishQueueStats, publishState, publishStats, publishStatus, purgeTask, purgeTasks, releasePeers, releaseService, removeAllListeners, removeListener, requiresSecurity, reserve, reserve, reserveRoot, reserveRoot, reserveRootAs, run, save, save, save, send, send, send, send, sendBlocking, sendBlocking, sendBlocking, sendBlocking, sendPeer, setInstanceId, setName, setPeer, setSecurityProvider, setState, setThisThread, setVirtual, sleep, stackToString, startHeartbeat, startPeer, startPeer, startRecording, stopHeartbeat, stopMsgRecording, stopService, subscribe, subscribe, subscribe, toString, unsubscribe, unsubscribe, unsubscribe, updateStats, warn, warn

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

webgui

public static WebGui webgui

startNativeService

public boolean startNativeService

startTerminal

public boolean startTerminal

retTimeout

public int retTimeout

Constructor Detail

PythonProxy

public PythonProxy(java.lang.String n)

Method Detail

preProcessHook

public boolean preProcessHook(Message msg)

preProcessHook is used to intercept messages and process or route them before being processed/invoked in the Service. Here all messages allowed to go and effect the Python service will be let through. However, all messsages not found in this filter will go "into" the native service, if the proxy is connected. There they can be handled in the native service.

Overrides:

preProcessHook in class Service

See Also:

Service.preProcessHook(org.myrobotlab.framework.Message)

addMetaData

public static ServiceType addMetaData(ServiceType meta)

getMetaData

public static ServiceType getMetaData()

This static method returns all the details of the class without it having to be constructed. It has description, categories, dependencies, and peer definitions.

Returns:

ServiceType - returns all the data

startService

public void startService()

Specified by:

startService in interface ServiceInterface

Overrides:

startService in class Service

exec

public java.lang.Object exec(java.lang.String method,
                             java.lang.Object[] dat)

Execute method with params dat on the native service this class represents.

exec

public java.lang.Object exec(Message msg)

Execute Message msg on the native service this class represents.

returnData

public void returnData(java.lang.Object obj)

log

public void log(java.lang.String txt)

startNativeService

public void startNativeService()

This is used to start the native service. Currently only Linux is supported

handshake

public void handshake()

This is called by the native service to start the handshake sequence. After the handshake is completed, both this class and the native service should remain in sync

getLogger

public static org.slf4j.Logger getLogger()

main

public static void main(java.lang.String[] args)