org.myrobotlab.service

Class TestCatcher

java.lang.Object

org.myrobotlab.framework.MessageService

org.myrobotlab.framework.Service

org.myrobotlab.service.TestCatcher

All Implemented Interfaces:

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

public class TestCatcher
extends Service
implements SerialDataListener

test catcher is a class to be used to exercise and verify publish, subscribe and other forms of message sending

Author:

GroG

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	log
static ServiceType	meta
java.util.concurrent.BlockingQueue<Message>	msgs data to hold the incoming messages

Fields inherited from class org.myrobotlab.framework.Service

cfgDir, dnaPool, MESSAGE_RECORDING_FORMAT_BINARY, MESSAGE_RECORDING_FORMAT_XML

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addData(java.lang.String method, java.lang.Object... parms)
void	checkMsg(long timeout, java.lang.String method, java.lang.Object... checkParms)
void	checkMsg(java.lang.String method)
void	checkMsg(java.lang.String method, java.lang.Object... checkParms)
void	clear()
java.lang.Object	getData(long timeout)
static ServiceType	getMetaData()
Message	getMsg(long timeout)
int	getMsgCount()
java.util.concurrent.BlockingQueue<Message>	getMsgs()
boolean	isLocal() awesome override to simulate remote services - e.g.
static void	main(java.lang.String[] args)
java.lang.Integer	onByte(java.lang.Integer b) some pub/sub interfaces do not use the Message queue to post their data - but use a callback thread from the other service as an optimization onByte is one of those methods
void	onConnect(java.lang.String portName)
void	onDisconnect(java.lang.String portName)
Status	onError(Status error)
boolean	preProcessHook(Message msg)
double	testDouble(double d)
java.util.ArrayList<?>	waitForData(int count)
java.util.ArrayList<?>	waitForData(int count, int timeout)
java.util.ArrayList<?>	waitForData(int count, int timeout, int pollInterval)
java.util.concurrent.BlockingQueue<Message>	waitForMsgs(int count)
java.util.concurrent.BlockingQueue<Message>	waitForMsgs(int count, int timeout)

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, 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, startService, 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

Methods inherited from interface org.myrobotlab.service.interfaces.QueueReporter

publishStats, updateStats

Methods inherited from interface org.myrobotlab.framework.interfaces.NameProvider

getName

Field Detail

log

public static final org.slf4j.Logger log

msgs

public transient java.util.concurrent.BlockingQueue<Message> msgs

data to hold the incoming messages

meta

public static ServiceType meta

Constructor Detail

TestCatcher

public TestCatcher(java.lang.String n)

Method Detail

isLocal

public boolean isLocal()

awesome override to simulate remote services - e.g. in Serial.addByteListener

Specified by:

isLocal in interface Attachable

Overrides:

isLocal in class Service

onError

public Status onError(Status error)

onByte

public java.lang.Integer onByte(java.lang.Integer b)

some pub/sub interfaces do not use the Message queue to post their data - but use a callback thread from the other service as an optimization onByte is one of those methods

Specified by:

onByte in interface SerialDataListener

preProcessHook

public boolean preProcessHook(Message msg)

Overrides:

preProcessHook in class Service

clear

public void clear()

getMsgs

public java.util.concurrent.BlockingQueue<Message> getMsgs()

getMsg

public Message getMsg(long timeout)
               throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getData

public java.lang.Object getData(long timeout)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

waitForMsgs

public java.util.concurrent.BlockingQueue<Message> waitForMsgs(int count)
                                                        throws java.lang.InterruptedException,
                                                               java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

waitForMsgs

public java.util.concurrent.BlockingQueue<Message> waitForMsgs(int count,
                                                               int timeout)
                                                        throws java.lang.InterruptedException,
                                                               java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

waitForData

public java.util.ArrayList<?> waitForData(int count)
                                   throws java.lang.InterruptedException,
                                          java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

waitForData

public java.util.ArrayList<?> waitForData(int count,
                                          int timeout)
                                   throws java.lang.InterruptedException,
                                          java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

waitForData

public java.util.ArrayList<?> waitForData(int count,
                                          int timeout,
                                          int pollInterval)
                                   throws java.lang.InterruptedException,
                                          java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

getMsgCount

public int getMsgCount()

onConnect

public void onConnect(java.lang.String portName)

Specified by:

onConnect in interface PortListener

onDisconnect

public void onDisconnect(java.lang.String portName)

Specified by:

onDisconnect in interface PortListener

checkMsg

public void checkMsg(java.lang.String method)
              throws java.lang.InterruptedException,
                     java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

checkMsg

public void checkMsg(java.lang.String method,
                     java.lang.Object... checkParms)
              throws java.lang.InterruptedException,
                     java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

checkMsg

public void checkMsg(long timeout,
                     java.lang.String method,
                     java.lang.Object... checkParms)
              throws java.lang.InterruptedException,
                     java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

addData

public void addData(java.lang.String method,
                    java.lang.Object... parms)

testDouble

public double testDouble(double d)

main

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

getMetaData

public static ServiceType getMetaData()