com.iizix.comm.test

Class TransactionProcessor

java.lang.Object

com.iizix.comm.test.TransactionProcessor

All Implemented Interfaces:

TransactionCommListener, WebSocketAcceptor

public class TransactionProcessor
extends Object
implements WebSocketAcceptor, TransactionCommListener

The transaction processor for inbound connections from WebSockets.

Author:

Christopher Mindus

Constructor Summary

Constructors

Constructor and Description
TransactionProcessor()

Method Summary

Modifier and Type	Method and Description
Object	isRequestURIAccepted(IWebSocketComm comm, String uri, Map<String,List<String>> headerFields) Called to check if a request URI can be accepted.
void	onCommClosed(TransactionComm comm, int code, String reason) Called when the communication link is closed.
void	onCommClosing(TransactionComm comm) Called when the communication link is closing.
void	onCommConnected(TransactionComm comm) Called when the communication link is connected.
void	onCommData(TransactionComm comm, Transaction trans) Called when the communication link has received data.
void	onCommError(TransactionComm comm, Throwable e) Called when the communication link is closed.
void	onCommHeartBeat(TransactionComm comm, long duration) Called when a heart-beat frame is received.
void	onCommTimeout(TransactionComm comm, boolean isReadTimeout) Called when the communication link has timed out on a read or write operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionProcessor

public TransactionProcessor()

Method Detail

isRequestURIAccepted

public Object isRequestURIAccepted(IWebSocketComm comm,
                                   String uri,
                                   Map<String,List<String>> headerFields)

Called to check if a request URI can be accepted.

Specified by:

isRequestURIAccepted in interface WebSocketAcceptor

Parameters:

comm - The WebSocket communication instance.

uri - The request URI, formatted as e.g. "/something/more.ws?query-params".

headerFields - HTTP header fields.

Returns:

Object an object that is attached to the TransactionComm instance, or null if the URI is not accepted.

onCommConnected

public void onCommConnected(TransactionComm comm)

Called when the communication link is connected.

Specified by:

onCommConnected in interface TransactionCommListener

Parameters:

comm - The transaction communication instance.

onCommData

public void onCommData(TransactionComm comm,
                       Transaction trans)

Called when the communication link has received data.

Specified by:

onCommData in interface TransactionCommListener

Parameters:

comm - The socket communication instance.

trans - The transaction received.

onCommHeartBeat

public void onCommHeartBeat(TransactionComm comm,
                            long duration)

Called when a heart-beat frame is received.

Specified by:

onCommHeartBeat in interface TransactionCommListener

Parameters:

comm - The transaction communication instance.

duration - Duration of the PING-PONG message exchange in milliseconds.

onCommTimeout

public void onCommTimeout(TransactionComm comm,
                          boolean isReadTimeout)

Called when the communication link has timed out on a read or write operation.

Specified by:

onCommTimeout in interface TransactionCommListener

Parameters:

comm - The transaction communication instance.

isReadTimeout - Flag indicating read timeout when true, false indicates write timeout.

onCommError

public void onCommError(TransactionComm comm,
                        Throwable e)

Called when the communication link is closed.

Specified by:

onCommError in interface TransactionCommListener

Parameters:

comm - The socket communication instance.

e - The exception.

onCommClosing

public void onCommClosing(TransactionComm comm)

Called when the communication link is closing.

Specified by:

onCommClosing in interface TransactionCommListener

Parameters:

comm - The socket communication instance.

onCommClosed

public void onCommClosed(TransactionComm comm,
                         int code,
                         String reason)

Called when the communication link is closed.

Specified by:

onCommClosed in interface TransactionCommListener

Parameters:

comm - The socket communication instance.