org.ws4d.java.communication.receiver

Class IncomingUDPReceiver

java.lang.Object

org.ws4d.java.communication.receiver.IncomingUDPReceiver

All Implemented Interfaces:

UDPDatagramHandler, MessageReceiver

public class IncomingUDPReceiver
extends java.lang.Object
implements UDPDatagramHandler, MessageReceiver

Constructor Summary

Constructors

Constructor and Description
IncomingUDPReceiver(boolean isMulticastSocket)

Method Summary

Modifier and Type	Method and Description
void	clear()
protected DefaultMessageDiscarder	getDiscarder()
OperationDescription	getEventSource(java.lang.String action)
OperationDescription	getOperation(java.lang.String action)
int	getRequestMessageType()
void	handle(Datagram datagram, IPConnectionInfo connectionInfo)
boolean	isEmpty()
void	receive(ByeMessage bye, ConnectionInfo connectionInfo)
void	receive(FaultMessage fault, ConnectionInfo connectionInfo)
void	receive(GetMessage get, ConnectionInfo connectionInfo)
void	receive(GetMetadataMessage getMetadata, ConnectionInfo connectionInfo)
void	receive(GetMetadataResponseMessage getMetadataResponse, ConnectionInfo connectionInfo)
void	receive(GetResponseMessage getResponse, ConnectionInfo connectionInfo)
void	receive(GetStatusMessage getStatus, ConnectionInfo connectionInfo)
void	receive(GetStatusResponseMessage getStatusResponse, ConnectionInfo connectionInfo)
void	receive(HelloMessage hello, ConnectionInfo connectionInfo)
void	receive(InvokeMessage invoke, ConnectionInfo connectionInfo)
void	receive(ProbeMatchesMessage probeMatches, ConnectionInfo connectionInfo)
void	receive(ProbeMessage probe, ConnectionInfo connectionInfo)
void	receive(RenewMessage renew, ConnectionInfo connectionInfo)
void	receive(RenewResponseMessage renewResponse, ConnectionInfo connectionInfo)
void	receive(ResolveMatchesMessage resolveMatches, ConnectionInfo connectionInfo)
void	receive(ResolveMessage resolve, ConnectionInfo connectionInfo)
void	receive(SubscribeMessage subscribe, ConnectionInfo connectionInfo)
void	receive(SubscribeResponseMessage subscribeResponse, ConnectionInfo connectionInfo)
void	receive(SubscriptionEndMessage subscriptionEnd, ConnectionInfo connectionInfo)
void	receive(UnsubscribeMessage unsubscribe, ConnectionInfo connectionInfo)
void	receive(UnsubscribeResponseMessage unsubscribeResponse, ConnectionInfo connectionInfo)
void	receiveFailed(java.lang.Exception e, ConnectionInfo connectionInfo)
void	receiveNoContent(java.lang.String reason, ConnectionInfo connectionInfo)
void	register(int[] messageTypes, IncomingMessageListener listener)
void	registerByeListener(IncomingMessageListener listener)
void	registerHelloListener(IncomingMessageListener listener)
void	registerProbeResolveListener(IncomingMessageListener listener)
protected void	respond(Message message, IPConnectionInfo connectionInfo)
void	sendFailed(java.lang.Exception e, ConnectionInfo connectionInfo)
void	unregister(int[] messageTypes, IncomingMessageListener listener)
void	unregisterByeListener(IncomingMessageListener listener)
void	unregisterHelloListener(IncomingMessageListener listener)
void	unregisterProbeResolveListener(IncomingMessageListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

IncomingUDPReceiver

public IncomingUDPReceiver(boolean isMulticastSocket)

Method Detail

handle

public void handle(Datagram datagram,
                   IPConnectionInfo connectionInfo)
            throws java.io.IOException

Specified by:

handle in interface UDPDatagramHandler

Throws:

java.io.IOException

respond

protected void respond(Message message,
                       IPConnectionInfo connectionInfo)

receive

public void receive(HelloMessage hello,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(ByeMessage bye,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(ProbeMessage probe,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(ProbeMatchesMessage probeMatches,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(ResolveMessage resolve,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(ResolveMatchesMessage resolveMatches,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(GetMessage get,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(GetResponseMessage getResponse,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(GetMetadataMessage getMetadata,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(GetMetadataResponseMessage getMetadataResponse,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(SubscribeMessage subscribe,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(SubscribeResponseMessage subscribeResponse,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(GetStatusMessage getStatus,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(GetStatusResponseMessage getStatusResponse,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(RenewMessage renew,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(RenewResponseMessage renewResponse,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(UnsubscribeMessage unsubscribe,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(UnsubscribeResponseMessage unsubscribeResponse,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(SubscriptionEndMessage subscriptionEnd,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(InvokeMessage invoke,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receive

public void receive(FaultMessage fault,
                    ConnectionInfo connectionInfo)

Specified by:

receive in interface MessageReceiver

receiveFailed

public void receiveFailed(java.lang.Exception e,
                          ConnectionInfo connectionInfo)

Specified by:

receiveFailed in interface MessageReceiver

sendFailed

public void sendFailed(java.lang.Exception e,
                       ConnectionInfo connectionInfo)

Specified by:

sendFailed in interface MessageReceiver

receiveNoContent

public void receiveNoContent(java.lang.String reason,
                             ConnectionInfo connectionInfo)

Specified by:

receiveNoContent in interface MessageReceiver

getDiscarder

protected DefaultMessageDiscarder getDiscarder()

registerHelloListener

public void registerHelloListener(IncomingMessageListener listener)

registerByeListener

public void registerByeListener(IncomingMessageListener listener)

registerProbeResolveListener

public void registerProbeResolveListener(IncomingMessageListener listener)

unregisterHelloListener

public void unregisterHelloListener(IncomingMessageListener listener)

unregisterByeListener

public void unregisterByeListener(IncomingMessageListener listener)

unregisterProbeResolveListener

public void unregisterProbeResolveListener(IncomingMessageListener listener)

register

public void register(int[] messageTypes,
                     IncomingMessageListener listener)

unregister

public void unregister(int[] messageTypes,
                       IncomingMessageListener listener)

isEmpty

public boolean isEmpty()

clear

public void clear()

getOperation

public OperationDescription getOperation(java.lang.String action)

Specified by:

getOperation in interface MessageReceiver

getEventSource

public OperationDescription getEventSource(java.lang.String action)

Specified by:

getEventSource in interface MessageReceiver

getRequestMessageType

public int getRequestMessageType()

Specified by:

getRequestMessageType in interface MessageReceiver