org.instrumentmiddleware.cima.transport.impl
Class AbstractTransportProvider

java.lang.Object
  org.instrumentmiddleware.cima.transport.impl.AbstractTransportProvider

All Implemented Interfaces:

java.util.concurrent.Callable<org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel>, ICIMADirectorAware, ITransportProvider

Direct Known Subclasses:

FifoTransport, MemoryTransport

public abstract class AbstractTransportProvider
extends java.lang.Object
implements ITransportProvider

Field Summary

protected ICIMADirector	director
protected static org.apache.log4j.Logger	log
protected org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel	outgoingParcel
protected org.instrumentmiddleware.cima.parcel.EndpointType	remoteEndpoint
protected IPlugin	sendingPlugin

Constructor Summary

AbstractTransportProvider()

Method Summary

org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel	call()
boolean	isAvailable()
org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel	send(IPlugin producer, org.instrumentmiddleware.cima.parcel.EndpointType endpoint, org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel parcel)
void	setCIMADirector(ICIMADirector director)
void	setOutgoingParcel(org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel parcel)
void	setRemoteEndpoint(org.instrumentmiddleware.cima.parcel.EndpointType endpoint)
void	setSendingPlugin(IPlugin plugin)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.instrumentmiddleware.cima.transport.ITransportProvider

getLocalEndpointUrl, getType, send

Field Detail

log

protected static org.apache.log4j.Logger log

remoteEndpoint

protected org.instrumentmiddleware.cima.parcel.EndpointType remoteEndpoint

outgoingParcel

protected org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel outgoingParcel

sendingPlugin

protected IPlugin sendingPlugin

director

protected ICIMADirector director

Constructor Detail

AbstractTransportProvider

public AbstractTransportProvider()

Method Detail

setCIMADirector

public void setCIMADirector(ICIMADirector director)

Specified by:

setCIMADirector in interface ICIMADirectorAware

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface ITransportProvider

send

public org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel send(IPlugin producer,
                                                                       org.instrumentmiddleware.cima.parcel.EndpointType endpoint,
                                                                       org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel parcel)
                                                                throws TransportException

Throws:

TransportException

setRemoteEndpoint

public void setRemoteEndpoint(org.instrumentmiddleware.cima.parcel.EndpointType endpoint)

Specified by:

setRemoteEndpoint in interface ITransportProvider

setOutgoingParcel

public void setOutgoingParcel(org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel parcel)

Specified by:

setOutgoingParcel in interface ITransportProvider

setSendingPlugin

public void setSendingPlugin(IPlugin plugin)

Specified by:

setSendingPlugin in interface ITransportProvider

call

public org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel call()
                                                                throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel>

Throws:

java.lang.Exception