com.draeger.medical.mdpws.client.streaming

Class DefaultStreamConsumer

java.lang.Object

com.draeger.medical.mdpws.client.streaming.DefaultStreamConsumer

All Implemented Interfaces:

IStreamConsumer, org.ws4d.java.communication.listener.IncomingMessageListener

public class DefaultStreamConsumer
extends java.lang.Object
implements IStreamConsumer, org.ws4d.java.communication.listener.IncomingMessageListener

Constructor Summary

Constructors

Constructor and Description
DefaultStreamConsumer(ProxyStreamSource sourceInfo)

Method Summary

Modifier and Type	Method and Description
void	addStreamFrameHandler(IStreamFrameHandler handler)
void	close()
void	exclusiveLock()
org.ws4d.java.security.CredentialInfo	getCredentialInfo()
org.ws4d.java.eventing.EventSource	getEvent(java.lang.String action)
protected org.ws4d.java.structures.HashMap	getFrameHandlerMap()
org.ws4d.java.service.OperationDescription	getOperation(java.lang.String action)
ProxyStreamSource	getStreamSource()
void	handle(org.ws4d.java.message.discovery.ByeMessage bye, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.metadata.GetResponseMessage	handle(org.ws4d.java.message.metadata.GetMessage get, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.metadata.GetMetadataResponseMessage	handle(org.ws4d.java.message.metadata.GetMetadataMessage getMetadata, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.eventing.GetStatusResponseMessage	handle(org.ws4d.java.message.eventing.GetStatusMessage getStatus, org.ws4d.java.communication.ConnectionInfo protocolData)
void	handle(org.ws4d.java.message.discovery.HelloMessage hello, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.InvokeMessage	handle(org.ws4d.java.message.InvokeMessage invokeRequest, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.discovery.ProbeMatchesMessage	handle(org.ws4d.java.message.discovery.ProbeMessage probe, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.eventing.RenewResponseMessage	handle(org.ws4d.java.message.eventing.RenewMessage renew, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.discovery.ResolveMatchesMessage	handle(org.ws4d.java.message.discovery.ResolveMessage resolve, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.eventing.SubscribeResponseMessage	handle(org.ws4d.java.message.eventing.SubscribeMessage subscribe, boolean useReferenceParameterMode, org.ws4d.java.communication.ConnectionInfo connectionInfo)
void	handle(org.ws4d.java.message.eventing.SubscriptionEndMessage subscriptionEnd, org.ws4d.java.communication.ConnectionInfo protocolData)
org.ws4d.java.message.eventing.UnsubscribeResponseMessage	handle(org.ws4d.java.message.eventing.UnsubscribeMessage unsubscribe, org.ws4d.java.communication.ConnectionInfo protocolData)
void	handlingInvokeInternal(org.ws4d.java.message.InvokeMessage invokeRequest, org.ws4d.java.communication.ConnectionInfo protocolData)
void	open()
boolean	releaseExclusiveLock()
void	releaseSharedLock()
void	sharedLock()
boolean	tryExclusiveLock()
boolean	trySharedLock()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStreamConsumer

public DefaultStreamConsumer(ProxyStreamSource sourceInfo)

Method Detail

addStreamFrameHandler

public void addStreamFrameHandler(IStreamFrameHandler handler)

Specified by:

addStreamFrameHandler in interface IStreamConsumer

getFrameHandlerMap

protected org.ws4d.java.structures.HashMap getFrameHandlerMap()

getStreamSource

public ProxyStreamSource getStreamSource()

open

public void open()
          throws java.io.IOException

Specified by:

open in interface IStreamConsumer

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface IStreamConsumer

Throws:

java.io.IOException

exclusiveLock

public void exclusiveLock()

releaseExclusiveLock

public boolean releaseExclusiveLock()

releaseSharedLock

public void releaseSharedLock()

sharedLock

public void sharedLock()

tryExclusiveLock

public boolean tryExclusiveLock()

trySharedLock

public boolean trySharedLock()

handle

public void handle(org.ws4d.java.message.discovery.HelloMessage hello,
                   org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public void handle(org.ws4d.java.message.discovery.ByeMessage bye,
                   org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.discovery.ProbeMatchesMessage handle(org.ws4d.java.message.discovery.ProbeMessage probe,
                                                                  org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.discovery.ResolveMatchesMessage handle(org.ws4d.java.message.discovery.ResolveMessage resolve,
                                                                    org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.metadata.GetResponseMessage handle(org.ws4d.java.message.metadata.GetMessage get,
                                                                org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.metadata.GetMetadataResponseMessage handle(org.ws4d.java.message.metadata.GetMetadataMessage getMetadata,
                                                                        org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.eventing.GetStatusResponseMessage handle(org.ws4d.java.message.eventing.GetStatusMessage getStatus,
                                                                      org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.eventing.RenewResponseMessage handle(org.ws4d.java.message.eventing.RenewMessage renew,
                                                                  org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.eventing.UnsubscribeResponseMessage handle(org.ws4d.java.message.eventing.UnsubscribeMessage unsubscribe,
                                                                        org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public void handle(org.ws4d.java.message.eventing.SubscriptionEndMessage subscriptionEnd,
                   org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

getOperation

public org.ws4d.java.service.OperationDescription getOperation(java.lang.String action)

Specified by:

getOperation in interface org.ws4d.java.communication.listener.IncomingMessageListener

handle

public org.ws4d.java.message.InvokeMessage handle(org.ws4d.java.message.InvokeMessage invokeRequest,
                                                  org.ws4d.java.communication.ConnectionInfo protocolData)

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

handlingInvokeInternal

public void handlingInvokeInternal(org.ws4d.java.message.InvokeMessage invokeRequest,
                                   org.ws4d.java.communication.ConnectionInfo protocolData)

handle

public org.ws4d.java.message.eventing.SubscribeResponseMessage handle(org.ws4d.java.message.eventing.SubscribeMessage subscribe,
                                                                      boolean useReferenceParameterMode,
                                                                      org.ws4d.java.communication.ConnectionInfo connectionInfo)
                                                               throws org.ws4d.java.message.SOAPException

Specified by:

handle in interface org.ws4d.java.communication.listener.IncomingMessageListener

Throws:

org.ws4d.java.message.SOAPException

getEvent

public org.ws4d.java.eventing.EventSource getEvent(java.lang.String action)

Specified by:

getEvent in interface org.ws4d.java.communication.listener.IncomingMessageListener

getCredentialInfo

public org.ws4d.java.security.CredentialInfo getCredentialInfo()

Specified by:

getCredentialInfo in interface org.ws4d.java.communication.listener.IncomingMessageListener