com.draeger.medical.mdpws.communication

Class MDPWSCommunicationManager

java.lang.Object

org.ws4d.java.communication.DPWSCommunicationManager

com.draeger.medical.mdpws.communication.MDPWSCommunicationManager

All Implemented Interfaces:

org.ws4d.java.communication.CommunicationManager, org.ws4d.java.communication.CommunicationManagerInternal

public class MDPWSCommunicationManager
extends org.ws4d.java.communication.DPWSCommunicationManager

Field Summary

Fields inherited from class org.ws4d.java.communication.DPWSCommunicationManager

COMMUNICATION_MANAGER_ID

Fields inherited from interface org.ws4d.java.communication.CommunicationManager

ID_NULL

Constructor Summary

Constructors

Constructor and Description
MDPWSCommunicationManager()

Method Summary

Modifier and Type	Method and Description
protected void	checkAndSendTCPMessage(org.ws4d.java.message.Message message, org.ws4d.java.communication.callback.ResponseCallback callback, org.ws4d.java.types.XAddressInfo targetXAddrInfo, org.ws4d.java.security.CredentialInfo credentialInfo)
protected void	closeStreamSocket(org.ws4d.java.communication.structures.CommunicationBinding binding, org.ws4d.java.service.LocalService service)
java.lang.String	getCommunicationManagerId()
org.ws4d.java.communication.structures.DiscoveryBinding	getDiscoveryBinding(org.ws4d.java.communication.ConnectionInfo data)
org.ws4d.java.structures.DataStructure	getDiscoveryBindings(org.ws4d.java.communication.structures.CommunicationBinding binding)
protected org.ws4d.java.communication.protocol.soap.server.SOAPoverUDPServer	getSOAPoverUDPServerStreaming(org.ws4d.java.communication.connection.ip.IPAddress streamAddress, int port, org.ws4d.java.communication.connection.ip.NetworkInterface iFace)
protected void	openStreamSocket(org.ws4d.java.communication.structures.CommunicationBinding binding, org.ws4d.java.communication.listener.IncomingMessageListener listener)
void	registerService(int[] messageTypes, org.ws4d.java.communication.structures.CommunicationBinding binding, org.ws4d.java.communication.listener.IncomingMessageListener listener, org.ws4d.java.service.LocalService service)
void	start()
void	stop()
void	unregisterService(int[] messageTypes, org.ws4d.java.communication.structures.CommunicationBinding binding, org.ws4d.java.service.LocalService service)

Methods inherited from class org.ws4d.java.communication.DPWSCommunicationManager

adaptDeviceTypes, adaptServiceTypes, checkIfAddressIsAnyLocalThenInterface, containsAllDeviceTypes, containsAllSearchScopes, containsAllServiceTypes, createActionNotSupportedFault, createAuthorizationFault, createDynamicEndpointReference, createEndpointUnavailableFault, createEventingException, createGenericFault, createInvalidAddressingHeaderFault, createInvocationException, createInvocationExceptionSOAPFault, createInvocationFault, createMessageAddressingHeaderRequiredFault, createProtocolInfo, createProtocolInfo, createSubscriptionFault, getAddressFilter, getAllAvailableDiscoveryDomains, getAllAvailableDiscoveryDomainsSize, getAutoBindingFactory, getAvailableOutgoingDiscoveryInfos, getChildren, getCommunicationBinding, getDeviceType, getDeviceTypes, getDiscoveryBinding, getHelper, getHelper, getMessageIDsForGetMetadataMapping, getMetadataValidator, getMulticastAddressAndPortForDiscoveryBinding, getMulticastAddressAndPortForOutgoingDiscoveryInfo, getOutgoingDiscoveryInfo, getOutgoingDiscoveryInfo, getOutgoingDiscoveryInfos, getRandomApplicationDelay, getRegisterForGetMetadata, getResourceAsStream, getSOAPoverUDPServer, getSupportedVersions, init, isMessageComplyingWithSecurityRequirements, isTransportAddress, kill, newDescriptionParser, newDescriptionSerializer, registerDevice, registerDiscovery, registerResource, send, send, send, serializeMessageWithAttachments, serializeMessageWithAttachments, setAddressFilter, supportsAddressingNamespace, supportsDiscoveryNamespace, supportsEventingFilterDialect, supportsEventingNamespace, unregisterDevice, unregisterDiscovery, unregisterResource, validateMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

MDPWSCommunicationManager

public MDPWSCommunicationManager()

Method Detail

getCommunicationManagerId

public java.lang.String getCommunicationManagerId()

Specified by:

getCommunicationManagerId in interface org.ws4d.java.communication.CommunicationManager

Overrides:

getCommunicationManagerId in class org.ws4d.java.communication.DPWSCommunicationManager

start

public void start()
           throws java.io.IOException

Specified by:

start in interface org.ws4d.java.communication.CommunicationManagerInternal

Overrides:

start in class org.ws4d.java.communication.DPWSCommunicationManager

Throws:

java.io.IOException

stop

public void stop()

Specified by:

stop in interface org.ws4d.java.communication.CommunicationManagerInternal

Overrides:

stop in class org.ws4d.java.communication.DPWSCommunicationManager

checkAndSendTCPMessage

protected void checkAndSendTCPMessage(org.ws4d.java.message.Message message,
                                      org.ws4d.java.communication.callback.ResponseCallback callback,
                                      org.ws4d.java.types.XAddressInfo targetXAddrInfo,
                                      org.ws4d.java.security.CredentialInfo credentialInfo)
                               throws org.ws4d.java.util.WS4DIllegalStateException

Overrides:

checkAndSendTCPMessage in class org.ws4d.java.communication.DPWSCommunicationManager

Throws:

org.ws4d.java.util.WS4DIllegalStateException

registerService

public void registerService(int[] messageTypes,
                            org.ws4d.java.communication.structures.CommunicationBinding binding,
                            org.ws4d.java.communication.listener.IncomingMessageListener listener,
                            org.ws4d.java.service.LocalService service)
                     throws java.io.IOException,
                            org.ws4d.java.util.WS4DIllegalStateException

Specified by:

registerService in interface org.ws4d.java.communication.CommunicationManager

Overrides:

registerService in class org.ws4d.java.communication.DPWSCommunicationManager

Throws:

java.io.IOException

org.ws4d.java.util.WS4DIllegalStateException

unregisterService

public void unregisterService(int[] messageTypes,
                              org.ws4d.java.communication.structures.CommunicationBinding binding,
                              org.ws4d.java.service.LocalService service)
                       throws java.io.IOException,
                              org.ws4d.java.util.WS4DIllegalStateException

Specified by:

unregisterService in interface org.ws4d.java.communication.CommunicationManager

Overrides:

unregisterService in class org.ws4d.java.communication.DPWSCommunicationManager

Throws:

java.io.IOException

org.ws4d.java.util.WS4DIllegalStateException

getDiscoveryBindings

public org.ws4d.java.structures.DataStructure getDiscoveryBindings(org.ws4d.java.communication.structures.CommunicationBinding binding)

Specified by:

getDiscoveryBindings in interface org.ws4d.java.communication.CommunicationManager

Overrides:

getDiscoveryBindings in class org.ws4d.java.communication.DPWSCommunicationManager

getDiscoveryBinding

public org.ws4d.java.communication.structures.DiscoveryBinding getDiscoveryBinding(org.ws4d.java.communication.ConnectionInfo data)

Specified by:

getDiscoveryBinding in interface org.ws4d.java.communication.CommunicationManager

Overrides:

getDiscoveryBinding in class org.ws4d.java.communication.DPWSCommunicationManager

closeStreamSocket

protected void closeStreamSocket(org.ws4d.java.communication.structures.CommunicationBinding binding,
                                 org.ws4d.java.service.LocalService service)
                          throws java.io.IOException

Throws:

java.io.IOException

openStreamSocket

protected void openStreamSocket(org.ws4d.java.communication.structures.CommunicationBinding binding,
                                org.ws4d.java.communication.listener.IncomingMessageListener listener)

getSOAPoverUDPServerStreaming

protected org.ws4d.java.communication.protocol.soap.server.SOAPoverUDPServer getSOAPoverUDPServerStreaming(org.ws4d.java.communication.connection.ip.IPAddress streamAddress,
                                                                                                           int port,
                                                                                                           org.ws4d.java.communication.connection.ip.NetworkInterface iFace)