kaos.core.service.transport
Class BufferedMessageSender

java.lang.Object
  kaos.core.service.transport.BufferedMessageSender

public class BufferedMessageSender
extends java.lang.Object

Author:

jlott

Constructor Summary

BufferedMessageSender(MessageSender sender)

Method Summary

void	bindToRemoteLocator(Locator arg0)
MessageTransportService	getMessageTransportService()
Locator	getRemoteLocator()
static boolean	isTransientCommXcp(TransportFailure tf)
void	sendMessage(TransportMessage arg0)

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedMessageSender

public BufferedMessageSender(MessageSender sender)

Method Detail

bindToRemoteLocator

public void bindToRemoteLocator(Locator arg0)
                         throws NotLocatableException,
                                TransportFailure

Throws:

NotLocatableException

TransportFailure

getRemoteLocator

public Locator getRemoteLocator()
                         throws NotBoundException,
                                TransportFailure

Throws:

NotBoundException

TransportFailure

sendMessage

public void sendMessage(TransportMessage arg0)
                 throws NotLocatableException,
                        TransportFailure

Throws:

NotLocatableException

TransportFailure

isTransientCommXcp

public static boolean isTransientCommXcp(TransportFailure tf)

getMessageTransportService

public MessageTransportService getMessageTransportService()
                                                   throws TransportFailure

Throws:

TransportFailure