org.mule.extension.socket.api.worker

Class UdpWorker

java.lang.Object

org.mule.extension.socket.api.worker.SocketWorker

org.mule.extension.socket.api.worker.UdpWorker

All Implemented Interfaces:

Runnable, org.mule.runtime.api.lifecycle.Disposable

public final class UdpWorker
extends SocketWorker

One worker is created per received package. If the other end of the connection is awaiting for a response, one will be sent but not from the same listener socket the source has. The response will be sent from a new different DatagramSocket bound to a port choose by the system.

Field Summary

Fields inherited from class org.mule.extension.socket.api.worker.SocketWorker

callback, encoding

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
UdpWorker(DatagramSocket socket, DatagramPacket packet, ObjectSerializer objectSerializer, org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback)

Method Summary

Modifier and Type	Method and Description
void	dispose()
void	doRun()
void	onComplete(Object result)
void	onError(Throwable e)

Methods inherited from class org.mule.extension.socket.api.worker.SocketWorker

handle, onError, run, setEncoding

Methods inherited from class java.lang.Object

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

Constructor Detail

UdpWorker

public UdpWorker(DatagramSocket socket,
                 DatagramPacket packet,
                 ObjectSerializer objectSerializer,
                 org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback)

Method Detail

doRun

public void doRun()

Specified by:

doRun in class SocketWorker

onComplete

public void onComplete(Object result)

Specified by:

onComplete in class SocketWorker

onError

public void onError(Throwable e)

Specified by:

onError in class SocketWorker

dispose

public void dispose()