org.instrumentmiddleware.cima.transport.impl
Class FifoTransport

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

All Implemented Interfaces:

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

public class FifoTransport
extends AbstractTransportProvider

Field Summary

Fields inherited from class org.instrumentmiddleware.cima.transport.impl.AbstractTransportProvider

director, log, outgoingParcel, remoteEndpoint, sendingPlugin

Constructor Summary

FifoTransport(java.lang.String source, java.lang.String dest)

Method Summary

java.lang.String	getLocalEndpointUrl()
org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel	getResponse(int sequenceId)
org.instrumentmiddleware.cima.parcel.EndpointTypeEnum.Enum	getType()
org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel	send()
void	setLocalEndpointUrl(java.lang.String url)
void	setParcelSizeLimit(int limit)

Methods inherited from class org.instrumentmiddleware.cima.transport.impl.AbstractTransportProvider

call, isAvailable, send, setCIMADirector, setOutgoingParcel, setRemoteEndpoint, setSendingPlugin

Methods inherited from class java.lang.Object

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

Constructor Detail

FifoTransport

public FifoTransport(java.lang.String source,
                     java.lang.String dest)

Method Detail

setParcelSizeLimit

public void setParcelSizeLimit(int limit)

setLocalEndpointUrl

public void setLocalEndpointUrl(java.lang.String url)

getLocalEndpointUrl

public java.lang.String getLocalEndpointUrl()

getType

public org.instrumentmiddleware.cima.parcel.EndpointTypeEnum.Enum getType()

getResponse

public org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel getResponse(int sequenceId)

send

public org.instrumentmiddleware.cima.parcel.ParcelDocument.Parcel send()
                                                                throws TransportException

Throws:

TransportException