org.ws4d.java.communication.monitor
Class MonitorStreamFactory

java.lang.Object
  org.ws4d.java.communication.monitor.MonitorStreamFactory

Direct Known Subclasses:

DefaultMonitoredStreamFactory

public abstract class MonitorStreamFactory
extends java.lang.Object

Factory which allows to create an OutputStream to catch incoming and outgoing data which allows the creation of Message objects.

Field Summary

static HashMap	inMon
static HashMap	outMon

Constructor Summary

MonitorStreamFactory()

Method Summary

abstract StreamMonitor	createInputMonitor()
abstract StreamMonitor	createOutputMonitor()
void	discard(ProtocolData pd, MonitoringContext context, int discardReason) Allows the assignment of a incoming discarded Message to a previously given OutputStream.
StreamMonitor	getInputMonitor(ProtocolData pd) Creates a StreamMonitor for incoming messages.
MonitoringContext	getMonitoringContextIn(ProtocolData pd)
MonitoringContext	getMonitoringContextOut(ProtocolData pd)
MonitoringContext	getNewMonitoringContextIn(ProtocolData pd)
MonitoringContext	getNewMonitoringContextOut(ProtocolData pd)
StreamMonitor	getOutputMonitor(ProtocolData pd) Creates a StreamMonitor for outgoing messages.
void	linkIn(ProtocolData pd, StreamMonitor mon) Method which allows the link between the current Thread and a StreamMonitor for an OutputStream.
void	linkOut(ProtocolData pd, StreamMonitor mon) Method which allows the link between the current Thread and a StreamMonitor for an InputStream.
void	received(ProtocolData pd, MonitoringContext context, Message message) Allows the assignment of a incoming Message to a previously given OutputStream.
void	receivedFault(ProtocolData pd, MonitoringContext context, java.lang.Exception e) Allows to inform the incoming monitor about a fault.
void	receivedResource(ProtocolData pd, MonitoringContext context, Resource r)
void	requestResource(ProtocolData pd, MonitoringContext context, URI location)
void	resetMonitoringContextIn(ProtocolData pd)
void	resetMonitoringContextOut(ProtocolData pd)
void	send(ProtocolData pd, MonitoringContext context, Message message) Allows the assignment of a outgoing Message to a previously given OutputStream.
void	sendFault(ProtocolData pd, MonitoringContext context, java.lang.Exception e) Allows to inform the outgoing monitor about a fault.
void	sendResource(ProtocolData pd, MonitoringContext context, Resource r)

Methods inherited from class java.lang.Object

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

Field Detail

inMon

public static HashMap inMon

outMon

public static HashMap outMon

Constructor Detail

MonitorStreamFactory

public MonitorStreamFactory()

Method Detail

createInputMonitor

public abstract StreamMonitor createInputMonitor()

createOutputMonitor

public abstract StreamMonitor createOutputMonitor()

getInputMonitor

public final StreamMonitor getInputMonitor(ProtocolData pd)

Creates a StreamMonitor for incoming messages.

Returns:

the StreamMonitor for incoming messages.

getOutputMonitor

public final StreamMonitor getOutputMonitor(ProtocolData pd)

Creates a StreamMonitor for outgoing messages.

Returns:

the StreamMonitor for outgoing messages.

resetMonitoringContextIn

public final void resetMonitoringContextIn(ProtocolData pd)

resetMonitoringContextOut

public final void resetMonitoringContextOut(ProtocolData pd)

getNewMonitoringContextIn

public final MonitoringContext getNewMonitoringContextIn(ProtocolData pd)

getNewMonitoringContextOut

public final MonitoringContext getNewMonitoringContextOut(ProtocolData pd)

getMonitoringContextIn

public final MonitoringContext getMonitoringContextIn(ProtocolData pd)

getMonitoringContextOut

public final MonitoringContext getMonitoringContextOut(ProtocolData pd)

linkIn

public final void linkIn(ProtocolData pd,
                         StreamMonitor mon)

Method which allows the link between the current Thread and a StreamMonitor for an OutputStream.

Parameters:

pd - the protocol data which will be used to identify the monitor.

mon - the stream monitor

linkOut

public final void linkOut(ProtocolData pd,
                          StreamMonitor mon)

Method which allows the link between the current Thread and a StreamMonitor for an InputStream.

Parameters:

pd - the protocol data which will be used to identify the monitor.

mon - the stream monitor

received

public final void received(ProtocolData pd,
                           MonitoringContext context,
                           Message message)

Allows the assignment of a incoming Message to a previously given OutputStream.

Parameters:

pd - the protocol data which will be used to identify the monitor.

message - the message.

discard

public final void discard(ProtocolData pd,
                          MonitoringContext context,
                          int discardReason)

Allows the assignment of a incoming discarded Message to a previously given OutputStream.

Parameters:

pd - the protocol data which will be used to identify the monitor.

header - the message header.

send

public final void send(ProtocolData pd,
                       MonitoringContext context,
                       Message message)

Allows the assignment of a outgoing Message to a previously given OutputStream.

Parameters:

pd - the protocol data which will be used to identify the monitor.

message - the message.

receivedFault

public final void receivedFault(ProtocolData pd,
                                MonitoringContext context,
                                java.lang.Exception e)

Allows to inform the incoming monitor about a fault.

Parameters:

pd - the protocol data which will be used to identify the monitor.

sendFault

public final void sendFault(ProtocolData pd,
                            MonitoringContext context,
                            java.lang.Exception e)

Allows to inform the outgoing monitor about a fault.

Parameters:

pd - the protocol data which will be used to identify the monitor.

sendResource

public final void sendResource(ProtocolData pd,
                               MonitoringContext context,
                               Resource r)

requestResource

public final void requestResource(ProtocolData pd,
                                  MonitoringContext context,
                                  URI location)

receivedResource

public final void receivedResource(ProtocolData pd,
                                   MonitoringContext context,
                                   Resource r)