org.globus.ogsa.impl.base.streaming
Class FileStreamImpl

java.lang.Object
  org.globus.ogsa.impl.core.service.ServicePropertiesImpl
      org.globus.ogsa.impl.ogsi.GridServiceImpl
          org.globus.ogsa.impl.base.streaming.FileStreamImpl

All Implemented Interfaces:

GridServiceBase, GridServiceCallback, ServiceDataValueCallback, ServiceProperties

public class FileStreamImpl

extends GridServiceImpl

Field Summary

protected boolean	appendStdout
protected Tail	outputFollower
protected org.ietf.jgss.GSSCredential	proxy

Fields inherited from class org.globus.ogsa.impl.ogsi.GridServiceImpl

queryEngine, serviceData

Fields inherited from interface org.globus.ogsa.ServiceProperties

ACTIVATE_ON_STARTUP, ACTIVATION, BASE_CLASS_NAME, BOOTSTRAP, CONFIG_PATH, CONTAINS_REFERENCE, CREATION_EXTENSIBILITY, CREATION_EXTENSIBILITY_OUTPUT, CUSTOM_EXTENSIBILITY_DESERIALIZER, CUSTOM_EXTENSIBILITY_SERIALIZER, CUSTOM_MAPPING_REGISTERED, DEACTIVATED_PERSISTENT, DEACTIVATED_STATE, DEACTIVATED_TRANSIENT, DEACTIVATION, DESTROY_LISTENER, DESTRUCTION_SKELETON, DISABLE_FACTORY_REGISTRY, ENDPOINT, ENTRY_INSTANCE_CREATION, FACTORY, FACTORY_CALLBACK, FACTORY_HANDLE, FACTORY_PROVIDER, FACTORY_REGISTRY, GSR_DESCRIPTION, HANDLE, HANDLE_PORT, HANDLE_PROTOCOL, INSTANCE_CLASS, INSTANCE_DEACTIVATION, INSTANCE_GSR_DESCRIPTION, INSTANCE_LIFECYCLE, INSTANCE_PORT_TYPE, INSTANCE_PORT_TYPE_NS, INSTANCE_PREFIX, INSTANCE_REGISTRY, INSTANCE_SCHEMA_PATH, INSTANCE_WSDL, INTERFACE_CLASS_NAME, INVOCATION_ID, LAZY_CREATION, LIFECYCLE, LIFECYCLE_MONITOR, LIFECYCLE_MONITOR_CLASS, NAME, NOTIFICATION_ENGINE, NOTIFICATION_FACTORY, NOTIFICATION_SOURCE, OPERATION_PROVIDERS, PERSISTENT, PERSISTENT_PROPERTIES, PORT, PORT_TYPE, PORT_TYPE_NS, PRIMARY_KEY, PROTOCOL, QUERY_ENGINE, REDIRECT_RESOLVER, REGISTRY, RESOLVER_CACHE, ROUTER_HEADER, ROUTER_VIA, SCHEMA_LOCATION, SCHEMA_PATH, SERVICE_ACTIVATOR, SERVICE_DATA, SERVICE_DEPLOYMENT, SERVICE_GROUP_ENTRY, SERVICE_GROUP_PROVIDER, SERVICE_LOADER, SERVICE_NODE, SERVICE_PATH, SINK_ID, STARTUP_STATE, SWEEP_SERVICE_DATA, TIMEOUT, TIMESTAMP, TRANSIENT, TYPE, USER, WEBSTART_PANEL_NAME, WEBSTART_URL, WSDL

Constructor Summary

FileStreamImpl()

Method Summary

void	addFileStreamStateListener(FileStreamStateListener listener)
void	fireFileStreamStarted()
void	fireFileStreamStopped()
protected java.io.OutputStream	openUrl(java.lang.String file)
void	postCreate(GridContext context) Called when a service has been created and all of its configuration has been set up.
void	preDestroy(GridContext context) Called just before a service gets destroyed.
void	removeFileStreamStateListener(FileStreamStateListener listener)
void	start()
void	stop()

Methods inherited from class org.globus.ogsa.impl.ogsi.GridServiceImpl

activate, addOperationProvider, deactivate, destroy, findServiceData, getInstanceProperty, getOperationProvider, getQueryEngine, getServiceDataSet, getServiceDataValues, getServiceInterface, getTerminationTime, populateInstanceProperties, preCreate, removeOperationProvider, requestTerminationAfter, requestTerminationBefore, setDefaultTermination, setQueryEngine, setServiceData, setServiceDataSet

Methods inherited from class org.globus.ogsa.impl.core.service.ServicePropertiesImpl

flush, flush, getPersistentProperty, getProperty, keySet, setPersistentProperty, setProperty, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.globus.ogsa.ServiceProperties

flush, getPersistentProperty, getProperty, setPersistentProperty, setProperty

Field Detail

outputFollower

protected Tail outputFollower

appendStdout

protected boolean appendStdout

proxy

protected org.ietf.jgss.GSSCredential proxy

Constructor Detail

FileStreamImpl

public FileStreamImpl()

Method Detail

postCreate

public void postCreate(GridContext context)
                throws GridServiceException

Description copied from interface: GridServiceCallback

Called when a service has been created and all of its configuration has been set up.

Specified by:

postCreate in interface GridServiceCallback

Overrides:

postCreate in class GridServiceImpl

Throws:

GridServiceException

openUrl

protected java.io.OutputStream openUrl(java.lang.String file)
                                throws InvalidUrlFault,
                                       FileTransferFault,
                                       CredentialsFault,
                                       InvalidPathFault

Throws:

InvalidUrlFault

FileTransferFault

CredentialsFault

InvalidPathFault

preDestroy

public void preDestroy(GridContext context)
                throws GridServiceException

Description copied from interface: GridServiceCallback

Called just before a service gets destroyed. After this call is made the framework removes all knowledge about the service, so it is a good place to clean up service resources. Note that this call can be triggered both by a client initiated destroy call, as well as a framework initiated softstate timeout.

Specified by:

preDestroy in interface GridServiceCallback

Overrides:

preDestroy in class GridServiceImpl

Throws:

GridServiceException

addFileStreamStateListener

public void addFileStreamStateListener(FileStreamStateListener listener)

removeFileStreamStateListener

public void removeFileStreamStateListener(FileStreamStateListener listener)

fireFileStreamStarted

public void fireFileStreamStarted()

fireFileStreamStopped

public void fireFileStreamStopped()

start

public void start()
           throws InvalidUrlFault,
                  InvalidPathFault,
                  FileTransferFault,
                  CredentialsFault,
                  java.rmi.RemoteException

Throws:

InvalidUrlFault

InvalidPathFault

FileTransferFault

CredentialsFault

java.rmi.RemoteException

stop

public void stop()
          throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException