org.objectweb.petals.tools.rmi.server.remote.interfaces
Interface RemoteDeliveryChannel

All Superinterfaces:

java.rmi.Remote

All Known Implementing Classes:

RemoteDeliveryChannelImpl

public interface RemoteDeliveryChannel
extends java.rmi.Remote

The delivery channel interface.

Author:

nsalatge

Method Summary

javax.jbi.messaging.MessageExchange	accept() TODO accept check multi thread Blocking call used to service a MessageExchange instance which has been initiated by another component.
javax.jbi.messaging.MessageExchange	accept(long timeoutMS) TODO accept check multi thread Blocking call used to service a MessageExchange instance which has been initiated by another component, within the given timeout period.
void	close() TODO close pending messages, remove endpoint entries ? Closes the delivery channel, halting all message traffic.
RemoteMessageExchangeFactory	createExchangeFactory() Create a message exchange factory.
RemoteMessageExchangeFactory	createExchangeFactory(javax.xml.namespace.QName interfaceName) Create a message exchange factory for the given interface name.
RemoteMessageExchangeFactory	createExchangeFactory(javax.jbi.servicedesc.ServiceEndpoint endpoint) Create a message exchange factory for the given endpoint.
RemoteMessageExchangeFactory	createExchangeFactoryForService(javax.xml.namespace.QName serviceName) Create a message exchange factory for the given service name.
void	send(javax.jbi.messaging.MessageExchange exchange) TODO send resolve jbi logical endpoint Routes a MessageExchange instance through the Normalized Message Router to the appropriate servicing component.
javax.jbi.messaging.MessageExchange	sendSync(javax.jbi.messaging.MessageExchange exchange) TODO sendSync check multithread The RMI interface of sendSync return a message exchange.
javax.jbi.messaging.MessageExchange	sendSync(javax.jbi.messaging.MessageExchange exchange, long timeoutMS) TODO sendSync check multithread The RMI interface of sendSync return a message exchange.

Method Detail

accept

javax.jbi.messaging.MessageExchange accept()
                                           throws javax.jbi.messaging.MessagingException,
                                                  java.rmi.RemoteException

TODO accept check multi thread Blocking call used to service a MessageExchange instance which has been initiated by another component. This method supports concurrent invocation for multi-threaded environments. This must be interruptable (Thread.interrupt()).

Returns:

message exchange instance; must be non-null

Throws:

javax.jbi.messaging.MessagingException - failed to accept

javax.jbi.messaging.MessagingException - when the blocked thread is interrupted

java.rmi.RemoteException - impossible to realize a remote access

accept

javax.jbi.messaging.MessageExchange accept(long timeoutMS)
                                           throws javax.jbi.messaging.MessagingException,
                                                  java.rmi.RemoteException

TODO accept check multi thread Blocking call used to service a MessageExchange instance which has been initiated by another component, within the given timeout period. This method supports concurrent invocation for multi-threaded environments.

Parameters:

timeoutMS - timeout period, in milliseconds (0 means no timeout); must be greater than or equal to zero

Returns:

message exchange instance, or null if timed out

Throws:

javax.jbi.messaging.MessagingException - failed to accept

javax.jbi.messaging.MessagingException - when the blocked thread is interrupted

java.rmi.RemoteException - impossible to realize a remote access

close

void close()
           throws javax.jbi.messaging.MessagingException,
                  java.rmi.RemoteException

TODO close pending messages, remove endpoint entries ? Closes the delivery channel, halting all message traffic.

Throws:

javax.jbi.messaging.MessagingException - fatal error while closing channel

java.rmi.RemoteException - impossible to realize a remote access

createExchangeFactory

RemoteMessageExchangeFactory createExchangeFactory()
                                                   throws java.rmi.RemoteException

Create a message exchange factory. This factory will create exchange instances with all appropriate properties set to null.

Returns:

a message exchange factory; must be non-null

Throws:

java.rmi.RemoteException - impossible to realize a remote access

createExchangeFactory

RemoteMessageExchangeFactory createExchangeFactory(javax.xml.namespace.QName interfaceName)
                                                   throws java.rmi.RemoteException

Create a message exchange factory for the given interface name.

Parameters:

interfaceName - name of the interface for which all exchanges created by the returned factory will be set for; may be null

Returns:

an exchange factory that will create exchanges for the the given interface; must be non-null

Throws:

java.rmi.RemoteException - impossible to realize a remote access

createExchangeFactory

RemoteMessageExchangeFactory createExchangeFactory(javax.jbi.servicedesc.ServiceEndpoint endpoint)
                                                   throws java.rmi.RemoteException

Create a message exchange factory for the given endpoint.

Parameters:

endpoint - endpoint for which all exchanges created by the returned factory will be set for; may be null

Returns:

an exchange factory that will create exchanges for the given endpoint; must be non-null

Throws:

java.rmi.RemoteException - impossible to realize a remote access

createExchangeFactoryForService

RemoteMessageExchangeFactory createExchangeFactoryForService(javax.xml.namespace.QName serviceName)
                                                             throws java.rmi.RemoteException

Create a message exchange factory for the given service name.

Parameters:

serviceName - name of the service for which all exchanges created by the returned factory will be set for; may be null

Returns:

an exchange factory that will create exchanges for the the given service; must be non-null

Throws:

java.rmi.RemoteException - impossible to realize a remote access

send

void send(javax.jbi.messaging.MessageExchange exchange)
          throws javax.jbi.messaging.MessagingException,
                 java.rmi.RemoteException

TODO send resolve jbi logical endpoint Routes a MessageExchange instance through the Normalized Message Router to the appropriate servicing component. This method supports concurrent invocation for multi-threaded environments.

This is used not only to send the initial message in an exchange, but also for the servicer to "return" the exchange with the appropriate response (response, fault, or ExchangeStatus). In more complex message exchange patterns, a single MessageExchange can be sent back-and-forth via send() several times, but always terminating with the MessageExchange instance being sent with a terminal ExchangeStatus.

Parameters:

exchange - message exchange to send; must be non-null

Throws:

javax.jbi.messaging.MessagingException - unable to send exchange

java.rmi.RemoteException - impossible to realize a remote access

sendSync

javax.jbi.messaging.MessageExchange sendSync(javax.jbi.messaging.MessageExchange exchange)
                                             throws javax.jbi.messaging.MessagingException,
                                                    java.rmi.RemoteException

TODO sendSync check multithread The RMI interface of sendSync return a message exchange. it is different of jbi interface because the message exchange in input parameter is not a remote object, so, it cannot be setted in the method. Routes a MessageExchange instance through the Normalized Message Router to the appropriate servicing component, and blocks until the exchange is returned (that is, the other participant sends the message exchange back). This method supports concurrent invocation for multi-threaded environments.

If the thread making this call is interrupted, the message exchange is treated in the same fashion as a timed-out sendSync call; see sendSync(MessageExchange, long).

Note that the "returned" message exchange (the instance returned by the other participant in the exchange) is the same instance referred to by the parameter exchange.

Parameters:

exchange - message exchange to send; must be non-null

Returns:

the message exchange if the exchange has been returned, or null

Throws:

javax.jbi.messaging.MessagingException - unable to send exchange, or no response is expected from the send() operation (i.e., the MessageExchange is being used to convey an ExchangeStatus)

javax.jbi.messaging.MessagingException - when the blocked thread is interrupted

java.rmi.RemoteException - impossible to realize a remote access

sendSync

javax.jbi.messaging.MessageExchange sendSync(javax.jbi.messaging.MessageExchange exchange,
                                             long timeoutMS)
                                             throws javax.jbi.messaging.MessagingException,
                                                    java.rmi.RemoteException

TODO sendSync check multithread The RMI interface of sendSync return a message exchange. it is different of jbi interface because the message exchange in input parameter is not a remote object, so, it cannot be setted in the method. Routes a MessageExchange instance through the Normalized Message Router to the appropriate servicing component, and blocks until the exchange is returned (that is, the other participant sends the message exchange back), or the specified timeout interval elapses. This method supports concurrent invocation for multi-threaded environments.

If the thread making this call is interrupted while this method is blocked, the message exchange is treated as if the time out occurred.

If this method returns false (indicating that timeout occurred), the message exchange must be marked by the implementation as being in the ExchangeStatus.ERROR state. Attempts by the service provider to send a MessageExchange in such an ERROR state must result in the send (or sendSync) method called ending abruptly with an appropriate MessagingException.

Note that the "returned" message exchange (the instance returned by the other participant in the exchange) is the same instance referred to by the parameter exchange.

Parameters:

exchange - message exchange to send; must be non-null

timeoutMS - timeout period, in milliseconds (0 means no timeout); must be greater than or equal to zero

Returns:

the message exchange if the exchange has been returned, or null if the method timed out while waiting

Throws:

javax.jbi.messaging.MessagingException - unable to send exchange, or no response is expected from the send() operation (i.e., the MessageExchange is being used to convey an ExchangeStatus)

javax.jbi.messaging.MessagingException - when the blocked thread is interrupted

java.rmi.RemoteException - impossible to realize a remote access