org.mule.extension.socket.internal

Class SocketUtils

java.lang.Object

org.mule.extension.socket.internal.SocketUtils

public final class SocketUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	WORK

Method Summary

Modifier and Type	Method and Description
static void	configureConnection(DatagramSocket socket, UdpSocketProperties socketProperties) Sets the configuration parameters into the socket.
static void	configureConnection(Socket socket, TcpSocketProperties socketProperties) Sets the configuration parameters into the socket
static DatagramPacket	createPacket(byte[] content) Creates a DatagramPacket with the size of the content, addressed to the port and address of the client.
static DatagramPacket	createPacket(int bufferSize)
static org.mule.runtime.extension.api.runtime.operation.Result<InputStream,SocketAttributes>	createResult(InputStream content, SocketAttributes attributes)
static byte[]	getByteArray(Object data, boolean streamingIsAllowed, String encoding, ObjectSerializer objectSerializer)
static byte[]	getUdpAllowedByteArray(Object data, String encoding, ObjectSerializer objectSerializer) UDP doesn't allow streaming and it always sends payload when dealing with a Message
static org.mule.runtime.api.connection.ConnectionValidationResult	validate(AbstractSocketConnection connection)

Methods inherited from class java.lang.Object

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

Field Detail

WORK

public static final String WORK

See Also:

Constant Field Values

Method Detail

getUdpAllowedByteArray

public static byte[] getUdpAllowedByteArray(Object data,
                                            String encoding,
                                            ObjectSerializer objectSerializer)
                                     throws IOException

UDP doesn't allow streaming and it always sends payload when dealing with a Message

Throws:

IOException

getByteArray

public static byte[] getByteArray(Object data,
                                  boolean streamingIsAllowed,
                                  String encoding,
                                  ObjectSerializer objectSerializer)
                           throws IOException

Throws:

IOException

validate

public static org.mule.runtime.api.connection.ConnectionValidationResult validate(AbstractSocketConnection connection)

Parameters:

connection - delegates connectin's validation on SocketConnection.validate()

Returns:

a ConnectionValidationResult with the outcome of the validation

createResult

public static org.mule.runtime.extension.api.runtime.operation.Result<InputStream,SocketAttributes> createResult(InputStream content,
                                                                                                                 SocketAttributes attributes)

createPacket

public static DatagramPacket createPacket(byte[] content)
                                   throws UnresolvableHostException

Creates a DatagramPacket with the size of the content, addressed to the port and address of the client.

Parameters:

content - that is going to be sent inside the packet

Returns:

a packet ready to be sent

Throws:

UnresolvableHostException

createPacket

public static DatagramPacket createPacket(int bufferSize)
                                   throws UnresolvableHostException

Returns:

a packet configured to be used for receiving purposes

Throws:

UnresolvableHostException

configureConnection

public static void configureConnection(DatagramSocket socket,
                                       UdpSocketProperties socketProperties)
                                throws org.mule.runtime.api.connection.ConnectionException

Sets the configuration parameters into the socket.

Parameters:

socket - UDP Socket

socketProperties - Configuration properties

Throws:

org.mule.runtime.api.connection.ConnectionException

configureConnection

public static void configureConnection(Socket socket,
                                       TcpSocketProperties socketProperties)
                                throws org.mule.runtime.api.connection.ConnectionException

Sets the configuration parameters into the socket

Parameters:

socket - TCP Socket

socketProperties - Configuration properties

Throws:

org.mule.runtime.api.connection.ConnectionException