kaos.core.service.transport.flexfeed
Class FlexfeedCommClient

java.lang.Object
  kaos.core.service.transport.flexfeed.FlexfeedCommClient

All Implemented Interfaces:

CommClient

public class FlexfeedCommClient
extends java.lang.Object
implements CommClient

Field Summary

protected Mocket	_mocket
protected java.io.ObjectOutputStream	_oos

Constructor Summary

FlexfeedCommClient()
used for testing

Method Summary

void	close() Closes any open connections.
void	init(java.lang.String host, int port) Tries to connect to the specified host on the specified port and open an object output stream to it.
static void	main(java.lang.String[] args)
boolean	peerUnreachableWarning(long timeSinceLastContact)
void	SendObject(java.io.Serializable obj) Sends the specified Serializable object across the ObjectOutputStream.

Methods inherited from class java.lang.Object

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

Field Detail

_mocket

protected Mocket _mocket

_oos

protected java.io.ObjectOutputStream _oos

Constructor Detail

FlexfeedCommClient

public FlexfeedCommClient()

used for testing

Method Detail

init

public void init(java.lang.String host,
                 int port)
          throws TransportFailure

Tries to connect to the specified host on the specified port and open an object output stream to it.

Specified by:

init in interface CommClient

Parameters:

String - host

int - port

Throws:

TransportFailure

close

public void close()

Closes any open connections.

Specified by:

close in interface CommClient

SendObject

public void SendObject(java.io.Serializable obj)
                throws TransportFailure

Sends the specified Serializable object across the ObjectOutputStream.

Specified by:

SendObject in interface CommClient

Parameters:

serializable - object to send

Throws:

TransportFailure

peerUnreachableWarning

public boolean peerUnreachableWarning(long timeSinceLastContact)

main

public static void main(java.lang.String[] args)