eu.xtreemos.service.test
Class Test

java.lang.Object
  extended by eu.xtreemos.system.eventmachine.stage.AbstractStage
      extended by eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
          extended by eu.xtreemos.system.eventmachine.stage.Abstract2wayStage
              extended by eu.xtreemos.service.test.Test
All Implemented Interfaces:
eu.xtreemos.system.eventmachine.queue.IEventHandler, eu.xtreemos.system.eventmachine.stage.IStage

public class Test
extends eu.xtreemos.system.eventmachine.stage.Abstract2wayStage

Author:
gregor.pipan@xlab.si Date Oct 16, 2007

Nested Class Summary
 class Test.CallbackInvocation
           
 class Test.ThisProcessListener
           
 
Field Summary
(package private) static org.apache.log4j.Logger logger
           
(package private)  ISomeProcess someProcess
           
 
Fields inherited from class eu.xtreemos.system.eventmachine.stage.Abstract2wayStage
context, counter, curContext, sink
 
Fields inherited from class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
queue
 
Fields inherited from class eu.xtreemos.system.eventmachine.stage.AbstractStage
handlerChain, handlerGroup, handlerThreads, name, running, serviceListeners
 
Constructor Summary
Test()
           
 
Method Summary
 void activateLateInvocation()
           
 java.lang.Integer blockThread(java.lang.String param)
           
 java.lang.Integer blockThreadCallback(java.lang.Integer v)
           
 java.lang.Integer delegateExecution(CommunicationAddress targetAddress)
           
 void dumpText(java.lang.String text)
           
 java.lang.Integer externalProcess(java.lang.Integer in)
           
 java.lang.Integer externalProcessFailure(java.lang.Exception ex)
           
 java.lang.Integer externalProcessSuccess(java.lang.Integer val)
           
 java.util.ArrayList<CommunicationAddress> getDaemons()
           
 java.lang.Object getDCB(java.lang.Object ret1)
           
 java.lang.String getHandledEventType()
           
 void handleEvent(java.lang.Object event)
           
 java.lang.Integer indirectExternalProcess(java.lang.Integer in)
           
 void init()
           
 java.lang.Integer secondBlockThread(java.lang.Integer p)
           
 java.util.ArrayList<java.lang.String> strangeMethod(java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.Integer>> param1)
          a test comment
 java.lang.Object testLateInvocation(java.lang.Object parameter)
           
 java.util.ArrayList testPackets(java.lang.Integer prefix, java.lang.Integer len)
           
 java.util.ArrayList testPacketsCallback(java.util.ArrayList result)
           
 
Methods inherited from class eu.xtreemos.system.eventmachine.stage.Abstract2wayStage
getContext, removeContext, SendException, SendException, SendException, SendReply, SendReply, SendReply, setSink
 
Methods inherited from class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
dequeue, getSource
 
Methods inherited from class eu.xtreemos.system.eventmachine.stage.AbstractStage
addHandler, addHandler, addServiceListener, getName, getShortName, getThreadCount, notifyServiceInitialised, notifyServiceStarted, notifyServiceStopped, processEvent, removeHandler, removeServiceListener, setThreadCount, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

static final org.apache.log4j.Logger logger

someProcess

ISomeProcess someProcess
Constructor Detail

Test

public Test()
Method Detail

getDaemons

public java.util.ArrayList<CommunicationAddress> getDaemons()

getDCB

public java.lang.Object getDCB(java.lang.Object ret1)

strangeMethod

public java.util.ArrayList<java.lang.String> strangeMethod(java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.Integer>> param1)
a test comment

Parameters:
param1 -
Returns:

testLateInvocation

public java.lang.Object testLateInvocation(java.lang.Object parameter)

activateLateInvocation

public void activateLateInvocation()

handleEvent

public void handleEvent(java.lang.Object event)
                 throws java.lang.Exception
Specified by:
handleEvent in interface eu.xtreemos.system.eventmachine.queue.IEventHandler
Specified by:
handleEvent in class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage
Throws:
java.lang.Exception

getHandledEventType

public java.lang.String getHandledEventType()
Specified by:
getHandledEventType in class eu.xtreemos.system.eventmachine.stage.AbstractReceivingStage

init

public void init()
Specified by:
init in interface eu.xtreemos.system.eventmachine.stage.IStage
Overrides:
init in class eu.xtreemos.system.eventmachine.stage.AbstractStage

delegateExecution

public java.lang.Integer delegateExecution(CommunicationAddress targetAddress)

blockThread

public java.lang.Integer blockThread(java.lang.String param)

secondBlockThread

public java.lang.Integer secondBlockThread(java.lang.Integer p)

blockThreadCallback

public java.lang.Integer blockThreadCallback(java.lang.Integer v)

testPackets

public java.util.ArrayList testPackets(java.lang.Integer prefix,
                                       java.lang.Integer len)
                                throws java.lang.Exception
Throws:
java.lang.Exception

testPacketsCallback

public java.util.ArrayList testPacketsCallback(java.util.ArrayList result)

dumpText

public void dumpText(java.lang.String text)

externalProcess

public java.lang.Integer externalProcess(java.lang.Integer in)
                                  throws java.lang.Exception
Throws:
java.lang.Exception

indirectExternalProcess

public java.lang.Integer indirectExternalProcess(java.lang.Integer in)
                                          throws java.lang.Exception
Throws:
java.lang.Exception

externalProcessSuccess

public java.lang.Integer externalProcessSuccess(java.lang.Integer val)

externalProcessFailure

public java.lang.Integer externalProcessFailure(java.lang.Exception ex)
                                         throws java.lang.Exception
Throws:
java.lang.Exception