de.hybris.platform.mediaconversion.os.process.impl

Class DefaultRemoteDrain

java.lang.Object

de.hybris.platform.mediaconversion.os.process.impl.DefaultRemoteDrain

All Implemented Interfaces:

RemoteDrain, java.rmi.Remote

public class DefaultRemoteDrain
extends java.lang.Object
implements RemoteDrain

Default implementation of the RemoteDrain. This spring bean registers itself to the RMI Registry to accept all incoming 'drain requests'. It then adapts and delegates the callback to the underlying ProcessContextRegistry and the ProcessContext associated with the given pid.

Field Summary

Fields inherited from interface de.hybris.platform.mediaconversion.os.process.rmi.RemoteDrain

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
DefaultRemoteDrain()

Method Summary

Modifier and Type	Method and Description
void	destroy() Unregisters this service from the rmi registry.
void	drain(int pid, DrainType type, java.lang.String message) Adapts and delegates the given message to a registered ProcessContext identified by the given pid.
ProcessContextRegistry	getProcessContextRegistry()
RMIRegistryService	getRmiRegistryService()
void	init() Registers this service to the wired rmi Registry.
void	setProcessContextRegistry(ProcessContextRegistry processContextRegistry)
void	setRmiRegistryService(RMIRegistryService rmiRegistryService)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRemoteDrain

public DefaultRemoteDrain()

Method Detail

drain

public void drain(int pid,
                  DrainType type,
                  java.lang.String message)
           throws java.rmi.RemoteException

Adapts and delegates the given message to a registered ProcessContext identified by the given pid. Callback method to handle a line of std err/out output of an process.

Specified by:

drain in interface RemoteDrain

Parameters:

pid - the unique id of a process.

type - the type of output we are talking about.

message - the actual payload: one line of output.

Throws:

java.rmi.RemoteException - on any technical communication error.

See Also:

RemoteDrain.drain(int, DrainType, String)

init

public void init()

Registers this service to the wired rmi Registry.

destroy

public void destroy()

Unregisters this service from the rmi registry.

getRmiRegistryService

public RMIRegistryService getRmiRegistryService()

setRmiRegistryService

public void setRmiRegistryService(RMIRegistryService rmiRegistryService)

getProcessContextRegistry

public ProcessContextRegistry getProcessContextRegistry()

setProcessContextRegistry

public void setProcessContextRegistry(ProcessContextRegistry processContextRegistry)