pyrasun.eio.services.bytearray
Class ByteArrayClientService

java.lang.Object
  pyrasun.eio.services.AbstractEmberService
      pyrasun.eio.services.bytearray.ByteArrayClientService

All Implemented Interfaces:

EmberService, EndpointEventListener

public class ByteArrayClientService

extends AbstractEmberService

implements EndpointEventListener

Field Summary

Fields inherited from interface pyrasun.eio.services.EmberService

RUNNING, STOPPED

Constructor Summary

ByteArrayClientService(EIOGlobalContext context, EIOPoolingStrategy strategy)

Method Summary

ByteArrayServerClient	createClient(java.lang.String host, int port, java.lang.String ID, ByteArrayServerClientListener listener)
ReadWriteEndpoint	createEndpoint(EndpointCoordinator coord, java.nio.channels.SocketChannel channel)
void	endpointClosed(Endpoint endpoint, EIOReasonCode reason, java.lang.String msg, java.lang.Throwable t, java.lang.Object context) A callback indicating that the specified endpoint was closed.
ByteArrayServerListener	getListener()
void	newEndpoint(ReadWriteEndpoint endpoint)
void	reportReadError(Endpoint endpoint, EIOReasonCode why, java.lang.String msg, java.lang.Throwable t, java.lang.Object context) Reports that a non-fatal error occured while reading from this endpoint.
void	reportWriteError(Endpoint endpoint, EIOReasonCode why, java.lang.String msg, java.lang.Throwable t, java.lang.Object context) Reports that a non-fatal error occured while writing to this endpoint.
void	setListener(ByteArrayServerListener listener)
void	start() Start the service.
void	stop() Stop the service.

Methods inherited from class pyrasun.eio.services.AbstractEmberService

failureOK, getController, getName, getState, isStoppable, setController

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteArrayClientService

public ByteArrayClientService(EIOGlobalContext context,
                              EIOPoolingStrategy strategy)
                       throws java.io.IOException

Method Detail

setListener

public void setListener(ByteArrayServerListener listener)

getListener

public ByteArrayServerListener getListener()

start

public void start()
           throws EmberServiceException

Start the service.

Specified by:

start in interface EmberService

Specified by:

start in class AbstractEmberService

Throws:

ServiceException - if the service fails to start, or is already running

EmberServiceException

stop

public void stop()
          throws EmberServiceException

Stop the service.

Specified by:

stop in interface EmberService

Specified by:

stop in class AbstractEmberService

Throws:

ServiceException - if the service fails to stop, or is already stopped

EmberServiceException

createClient

public ByteArrayServerClient createClient(java.lang.String host,
                                          int port,
                                          java.lang.String ID,
                                          ByteArrayServerClientListener listener)
                                   throws java.io.IOException

Throws:

java.io.IOException

createEndpoint

public ReadWriteEndpoint createEndpoint(EndpointCoordinator coord,
                                        java.nio.channels.SocketChannel channel)

newEndpoint

public void newEndpoint(ReadWriteEndpoint endpoint)

endpointClosed

public void endpointClosed(Endpoint endpoint,
                           EIOReasonCode reason,
                           java.lang.String msg,
                           java.lang.Throwable t,
                           java.lang.Object context)

Description copied from interface: EndpointEventListener

A callback indicating that the specified endpoint was closed.

Specified by:

endpointClosed in interface EndpointEventListener

Parameters:

endpoint - The endpoint that was closed

reason - Indicator as to why the endpoint was closed

msg - Semi-friendly text explaining in more detail why it was closed. May be null!

t - Exception that caused the close. May be null if an exception was not the cause

context - An object that indicates the context in which the close happened. Usually null, but app code may override with its own meaning

reportReadError

public void reportReadError(Endpoint endpoint,
                            EIOReasonCode why,
                            java.lang.String msg,
                            java.lang.Throwable t,
                            java.lang.Object context)

Description copied from interface: EndpointEventListener

Reports that a non-fatal error occured while reading from this endpoint.

Specified by:

reportReadError in interface EndpointEventListener

reportWriteError

public void reportWriteError(Endpoint endpoint,
                             EIOReasonCode why,
                             java.lang.String msg,
                             java.lang.Throwable t,
                             java.lang.Object context)

Description copied from interface: EndpointEventListener

Reports that a non-fatal error occured while writing to this endpoint.

Specified by:

reportWriteError in interface EndpointEventListener