org.mule.extension.socket.api.source

Class SocketListener

java.lang.Object

org.mule.runtime.extension.api.runtime.source.Source<InputStream,SocketAttributes>

org.mule.extension.socket.api.source.SocketListener

All Implemented Interfaces:

FlowConstructAware

@EmitsResponse
public final class SocketListener
extends org.mule.runtime.extension.api.runtime.source.Source<InputStream,SocketAttributes>
implements FlowConstructAware

Listens for socket connections of the given protocol in the configured host and port.

Whenever a new connection is received, this Source will schedule a a SocketWorker that will handle the communication for that particular connection.

Since:

4.0

Constructor Summary

Constructors

Constructor and Description
SocketListener()

Method Summary

Modifier and Type	Method and Description
void	onError(org.mule.runtime.api.message.Error error, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext context)
void	onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> sourceCallback)
void	onStop()
void	onSuccess(Object responseValue, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext context)
void	setFlowConstruct(FlowConstruct flowConstruct)

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketListener

public SocketListener()

Method Detail

onStart

public void onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> sourceCallback)
             throws org.mule.runtime.api.exception.MuleException

Specified by:

onStart in class org.mule.runtime.extension.api.runtime.source.Source<InputStream,SocketAttributes>

Throws:

org.mule.runtime.api.exception.MuleException

onSuccess

@OnSuccess
public void onSuccess(@Optional(defaultValue="#[payload]") @XmlHints(allowReferences=false)
                                 Object responseValue,
                                 org.mule.runtime.extension.api.runtime.source.SourceCallbackContext context)

onError

@OnError
public void onError(org.mule.runtime.api.message.Error error,
                             org.mule.runtime.extension.api.runtime.source.SourceCallbackContext context)

onStop

public void onStop()

Specified by:

onStop in class org.mule.runtime.extension.api.runtime.source.Source<InputStream,SocketAttributes>

setFlowConstruct

public void setFlowConstruct(FlowConstruct flowConstruct)

Specified by:

setFlowConstruct in interface FlowConstructAware