wt.wrmf.transport
Class StandardGenericTransportService

java.lang.Object
  wt.services.StandardManager
      wt.wrmf.transport.StandardGenericTransportService

All Implemented Interfaces:

GenericTransportService, Manager, NetFactor, Serializable

public class StandardGenericTransportService

extends StandardManager

implements GenericTransportService, Serializable

Use the newStandardGenericTransportService static factory method(s), not the StandardGenericTransportService constructor, to construct instances of this class. Instances must be constructed using the static factory(s), in order to ensure proper initialization of the instance.

Supported API: false

Extendable: false

See Also:

Serialized Form

Nested Class Summary

private class

StandardGenericTransportService.TransportThread

Field Summary

private static String	CLASSNAME
private boolean	initialized
private Hashtable	pipes
private static String	RESOURCE
private static int	TOTAL_TRANSPORT_THREAD
private static ThreadAdapter	transportAdapter
private static boolean	VERBOSE

Fields inherited from class wt.services.StandardManager

Fields inherited from interface wt.services.Manager

MANAGER_SERVICE, STARTUP_AUTOMATIC, STARTUP_MANUAL, STATUS_EMERGENCY_SHUTDOWN, STATUS_EMERGENCY_SHUTTING_DOWN, STATUS_SHUTDOWN, STATUS_SHUTDOWN_ERRORS, STATUS_SHUTDOWN_FAILURE, STATUS_SHUTTING_DOWN, STATUS_STARTED, STATUS_STARTED_ERRORS, STATUS_STARTING_UP, STATUS_STARTUP_FAILURE

Constructor Summary

StandardGenericTransportService()

Method Summary

protected void	dispatchVetoableEvent(String eventType, ShippingItem obj)
private void	finalizeUnconsumedBytes(InputStream is)
String	getConceptualClassname() Deprecated.
static StandardGenericTransportService	newStandardGenericTransportService() Default factory for the class.
protected void	performStartupProcess() Supported API: false
private void	PP(String msg)
private InputStream	pull0(ActionPullItem pullItem)
InputStream	pullInitialize(ActionPullItem pullItem) May throw invocation related exeptions due to the fact that some transports may work synchroneusly.
void	registerEvents(ManagerService ms) Register events with the passed ManagerService.
InputStream	send(InputStream is, SiteAddress to, TransportType by, ShippingItem shippingItem, long length) May throw invocation related exeptions due to the fact that some transports may work synchroneusly.
private InputStream	send0(InputStream is, SiteAddress to, TransportType by, ShippingItem item, long length)

Methods inherited from class wt.services.StandardManager

emergencyShutdown, emergencyShutdownComplete, emergencyShuttingDown, getClassInfo, getManagerService, getManagerStatus, getName, getStartupType, init, initialize, initialize, isStarted, newStandardManager, newStandardManager, performEmergencyShutdownProcess, performShutdownProcess, setManagerService, shutdown, shutdownFailure, shutdownSuccess, shuttingDown, started, startedErrors, startingUp, startup, startupFailure, toString

Methods inherited from class java.lang.Object

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

Field Detail

RESOURCE

private static final String RESOURCE

See Also:

Constant Field Values

CLASSNAME

private static final String CLASSNAME

pipes

private Hashtable pipes

initialized

private boolean initialized

VERBOSE

private static boolean VERBOSE

TOTAL_TRANSPORT_THREAD

private static int TOTAL_TRANSPORT_THREAD

transportAdapter

private static ThreadAdapter transportAdapter

Constructor Detail

StandardGenericTransportService

public StandardGenericTransportService()

Method Detail

getConceptualClassname

public String getConceptualClassname()

Deprecated.

Returns the conceptual (modeled) name for the class.

Supported API: false

Specified by:

getConceptualClassname in interface NetFactor

Overrides:

getConceptualClassname in class StandardManager

Returns:

String

performStartupProcess

protected void performStartupProcess()
                              throws ManagerException

Supported API: false

Overrides:

performStartupProcess in class StandardManager

Throws:

ManagerException

newStandardGenericTransportService

public static StandardGenericTransportService newStandardGenericTransportService()
                                                                          throws WTException

Default factory for the class.

Supported API: false

Returns:

StandardGenericTransportService

Throws:

WTException

send

public InputStream send(InputStream is,
                        SiteAddress to,
                        TransportType by,
                        ShippingItem shippingItem,
                        long length)
                 throws WTTransportException

May throw invocation related exeptions due to the fact that some transports may work synchroneusly. All exceptions are wrapped into the WTTransportException

Supported API: false

Specified by:

send in interface GenericTransportService

Parameters:

is -

to -

by -

shippingItem -

length -

Returns:

InputStream

Throws:

WTTransportException

pullInitialize

public InputStream pullInitialize(ActionPullItem pullItem)
                           throws WTTransportException

May throw invocation related exeptions due to the fact that some transports may work synchroneusly. All exceptions are wrapped into the WTTransportException

Supported API: false

Specified by:

pullInitialize in interface GenericTransportService

Parameters:

pullItem -

Returns:

InputStream

Throws:

WTTransportException

finalizeUnconsumedBytes

private void finalizeUnconsumedBytes(InputStream is)
                              throws IOException

Throws:

IOException

send0

private InputStream send0(InputStream is,
                          SiteAddress to,
                          TransportType by,
                          ShippingItem item,
                          long length)
                   throws WTTransportException

Throws:

WTTransportException

pull0

private InputStream pull0(ActionPullItem pullItem)
                   throws WTTransportException

Throws:

WTTransportException

registerEvents

public void registerEvents(ManagerService ms)

Description copied from class: StandardManager

Register events with the passed ManagerService. The default method does nothing, subclasses should provide an overriding implementation.

Supported API: false

Specified by:

registerEvents in interface Manager

Overrides:

registerEvents in class StandardManager

Parameters:

ms - the ManagerService with which to register events.

dispatchVetoableEvent

protected void dispatchVetoableEvent(String eventType,
                                     ShippingItem obj)
                              throws WTException

Throws:

WTException

PP

private void PP(String msg)