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

Fields

Modifier and Type	Field and Description
static HashMap	inMon
static HashMap	outMon

Constructor Summary

Constructors

Constructor and Description
MonitorStreamFactory()

Method Summary

Modifier and Type	Method and Description
protected abstract StreamMonitor	createInputMonitor()
protected abstract StreamMonitor	createOutputMonitor()
void	discard(java.lang.Long connectionId, MonitoringContext context, int discardReason) Allows the assignment of a incoming discarded Message to a previously given OutputStream.
static void	dispose(ConnectionInfo ci)
StreamMonitor	getInputMonitor(java.lang.Long connectionId) Creates a StreamMonitor for incoming messages.
MonitoringContext	getMonitoringContextIn(java.lang.Long connectionId)
MonitoringContext	getMonitoringContextOut(java.lang.Long connectionId)
MonitoringContext	getNewMonitoringContextIn(ConnectionInfo ci, boolean setLastTimeEqualToFirstTime)
MonitoringContext	getNewMonitoringContextOut(ConnectionInfo ci, boolean delayMessageIdNumberGeneration)
StreamMonitor	getOutputMonitor(java.lang.Long connectionId) Creates a StreamMonitor for outgoing messages.
void	received(java.lang.Long connectionId, MonitoringContext context, Message message) Allows the assignment of a incoming Message to a previously given OutputStream.
void	receivedFault(java.lang.Long connectionId, MonitoringContext context, java.lang.Exception e) Allows to inform the incoming monitor about a fault.
void	receiveNoContent(java.lang.Long connectionId, MonitoringContext context, java.lang.String reason)
void	receiveResourceRequest(java.lang.Long connectionId, MonitoringContext context, URI location)
void	receiveResourceResponse(java.lang.Long connectionId, MonitoringContext context, Resource r)
void	resetMonitoringContextIn(java.lang.Long connectionId)
void	resetMonitoringContextOut(java.lang.Long connectionId)
void	send(java.lang.Long connectionId, MonitoringContext context, Message message, AttributedURI optionalMessageId) Allows the assignment of a outgoing Message to a previously given OutputStream.
void	sendFault(java.lang.Long connectionId, MonitoringContext context, java.lang.Exception e) Allows to inform the outgoing monitor about a fault.
void	sendNoContent(java.lang.Long connectionId, MonitoringContext context, java.lang.String reason)
void	sendResourceRequest(java.lang.Long connectionId, MonitoringContext context, URI location)
void	sendResourceResponse(java.lang.Long connectionId, MonitoringContext context, Resource r)

Methods inherited from class java.lang.Object

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

Field Detail

inMon

public static final HashMap inMon

outMon

public static final HashMap outMon

Constructor Detail

MonitorStreamFactory

public MonitorStreamFactory()

Method Detail

dispose

public static final void dispose(ConnectionInfo ci)

createInputMonitor

protected abstract StreamMonitor createInputMonitor()

createOutputMonitor

protected abstract StreamMonitor createOutputMonitor()

getInputMonitor

public final StreamMonitor getInputMonitor(java.lang.Long connectionId)

Creates a StreamMonitor for incoming messages.

Returns:

the StreamMonitor for incoming messages.

getOutputMonitor

public final StreamMonitor getOutputMonitor(java.lang.Long connectionId)

Creates a StreamMonitor for outgoing messages.

Returns:

the StreamMonitor for outgoing messages.

resetMonitoringContextIn

public final void resetMonitoringContextIn(java.lang.Long connectionId)

resetMonitoringContextOut

public final void resetMonitoringContextOut(java.lang.Long connectionId)

getNewMonitoringContextIn

public final MonitoringContext getNewMonitoringContextIn(ConnectionInfo ci,
                                                         boolean setLastTimeEqualToFirstTime)

getNewMonitoringContextOut

public final MonitoringContext getNewMonitoringContextOut(ConnectionInfo ci,
                                                          boolean delayMessageIdNumberGeneration)

getMonitoringContextIn

public final MonitoringContext getMonitoringContextIn(java.lang.Long connectionId)

getMonitoringContextOut

public final MonitoringContext getMonitoringContextOut(java.lang.Long connectionId)

received

public final void received(java.lang.Long connectionId,
                           MonitoringContext context,
                           Message message)

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

Parameters:

connectionId - the id which will be used to identify the monitor.

context -

message - the message.

discard

public final void discard(java.lang.Long connectionId,
                          MonitoringContext context,
                          int discardReason)

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

Parameters:

connectionId - the id which will be used to identify the monitor.

context -

discardReason -

send

public final void send(java.lang.Long connectionId,
                       MonitoringContext context,
                       Message message,
                       AttributedURI optionalMessageId)

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

Parameters:

connectionId - the id which will be used to identify the monitor.

context -

message - the message

optionalMessageId -

receivedFault

public final void receivedFault(java.lang.Long connectionId,
                                MonitoringContext context,
                                java.lang.Exception e)

Allows to inform the incoming monitor about a fault.

Parameters:

connectionId - the id which will be used to identify the monitor.

context -

e -

sendFault

public final void sendFault(java.lang.Long connectionId,
                            MonitoringContext context,
                            java.lang.Exception e)

Allows to inform the outgoing monitor about a fault.

Parameters:

connectionId - the id which will be used to identify the monitor.

context -

e -

receiveResourceRequest

public final void receiveResourceRequest(java.lang.Long connectionId,
                                         MonitoringContext context,
                                         URI location)

sendResourceRequest

public final void sendResourceRequest(java.lang.Long connectionId,
                                      MonitoringContext context,
                                      URI location)

receiveResourceResponse

public final void receiveResourceResponse(java.lang.Long connectionId,
                                          MonitoringContext context,
                                          Resource r)

sendResourceResponse

public final void sendResourceResponse(java.lang.Long connectionId,
                                       MonitoringContext context,
                                       Resource r)

receiveNoContent

public void receiveNoContent(java.lang.Long connectionId,
                             MonitoringContext context,
                             java.lang.String reason)

sendNoContent

public void sendNoContent(java.lang.Long connectionId,
                          MonitoringContext context,
                          java.lang.String reason)