guarana.toolkit.task.communicators.dummy
Class InDummyCommunicator
java.lang.Object
guarana.util.observer.smart.SmartObservable
guarana.framework.task.Task
guarana.toolkit.task.communicators.Communicator
guarana.toolkit.task.communicators.dummy.InDummyCommunicator
- All Implemented Interfaces:
- ISource, IStubIn, guarana.util.observer.smart.ISmartObserver, Remote
public class InDummyCommunicator
- extends Communicator
- implements IStubIn
An InCommunicator for test purposes only.
- Since:
- Guaranį SDK 1.3.0
- Author:
- Rafael Z. Frantz
- See Also:
InCommunicator
Constructor Summary |
InDummyCommunicator(String name,
String host,
int port)
Constructs a new Passive Communicator to receive messages and exports this communicator to the RMI Registry. |
Method Summary |
void |
execute()
This method executes the business logic of this task. |
void |
pushRead(Message<?> message)
This method can be invoked to push a message into an EntryPort via an In-Communicator task. |
Methods inherited from class guarana.util.observer.smart.SmartObservable |
addSmartObserver, containsSmartObserver, containsSmartObserver, countSmartObservers, deleteSmartObserver, deleteSmartObservers, hasChanged, notifySmartObservers, notifySmartObservers |
InDummyCommunicator
public InDummyCommunicator(String name,
String host,
int port)
- Constructs a new Passive Communicator to receive messages and exports this communicator to the RMI Registry.
- Parameters:
name
- The name of the communicator.host
- The host name on which the registry is running.port
- The port on which the registry accepts requests.
execute
public void execute()
throws TaskExecutionException
- This method executes the business logic of this task. It is automatically invoked by workers.
- Overrides:
execute
in class Task
- Throws:
TaskExecutionException
- to report any exception that has occurred during the execution of this method.- See Also:
TaskExecutionException
pushRead
public void pushRead(Message<?> message)
throws RemoteException
- This method can be invoked to push a message into an
EntryPort
via an In-Communicator task.
- Specified by:
pushRead
in interface IStubIn
- Parameters:
message
- The inbound message.
- Throws:
RemoteException
- if any remote exception is raised during this method execution.- See Also:
communicator.proxy.IStubIn
Guaranį DSL Home