org.ow2.petals.transport.local
Class LocalTransporterImpl

java.lang.Object
  org.ow2.petals.transport.local.LocalTransporterImpl

All Implemented Interfaces:

Transporter

public class LocalTransporterImpl
extends java.lang.Object
implements Transporter

Author:

Roland NAUDIN - EBM WebSourcing

Field Summary

Fields inherited from interface org.ow2.petals.transport.Transporter

HTTP_FRACTAL_TRANSPORTER, LOCAL_FRACTAL_TRANSPORTER, SSL_FRACTAL_TRANSPORTER, TCP_FRACTAL_TRANSPORTER

Constructor Summary

LocalTransporterImpl()

Method Summary

int	getQueueMaxSize()
java.util.Map<java.lang.String,java.lang.Integer>	getQueueSizes()
void	send(org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper exchangeDecorator, TransportSendContext transportContext) Send the specified exchange to the specified container.
void	sendSync(org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper exchangeDecorator, TransportSendContext transportContext) Send the specified exchange to the specified container and wait until the response is received or the timeout is reached.
protected void	start()
protected void	stop()
void	stopTraffic() Prepare the stopping of the component.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTransporterImpl

public LocalTransporterImpl()

Method Detail

stopTraffic

public void stopTraffic()

Description copied from interface: Transporter

Prepare the stopping of the component. It means that all ongoing message traffic must terminate during the method invocation and all new message traffic is rejected.

Specified by:

stopTraffic in interface Transporter

send

public void send(org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper exchangeDecorator,
                 TransportSendContext transportContext)
          throws TransportException

Description copied from interface: Transporter

Send the specified exchange to the specified container. According to the transport policy, the message is may be not persisted by the Transport layer, so it can be lost in case of problem.

Specified by:

send in interface Transporter

Parameters:

exchangeDecorator - the exchange decorator to send.

Throws:

TransportException - If the exchange is invalid, or can not be serialized. If the distant container can not be found.

sendSync

public void sendSync(org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper exchangeDecorator,
                     TransportSendContext transportContext)
              throws TransportException

Description copied from interface: Transporter

Send the specified exchange to the specified container and wait until the response is received or the timeout is reached. According to the transport policy, the message is may be not persisted by the Transport layer, so it can be lost in case of problem.

Specified by:

sendSync in interface Transporter

Parameters:

exchangeDecorator - the exchange decorator to send.

Throws:

TransportException - If the exchange is invalid, or can not be serialized. If the distant container can not be found.

getQueueMaxSize

public int getQueueMaxSize()
                    throws TransportException

Throws:

TransportException

getQueueSizes

public java.util.Map<java.lang.String,java.lang.Integer> getQueueSizes()
                                                                throws TransportException

Throws:

TransportException

start

protected void start()
              throws java.lang.Exception

Throws:

java.lang.Exception

stop

protected void stop()
             throws java.lang.Exception

Throws:

java.lang.Exception