Package org.metricshub.ipmi.core.transport

Class UdpMessenger

java.lang.Object

java.lang.Thread

org.metricshub.ipmi.core.transport.UdpMessenger

All Implemented Interfaces:

Runnable, Messenger

public class UdpMessenger
extends Thread
implements Messenger

Handles the UDP connection.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
UdpMessenger(int port)	Initiates UdpMessenger, binds it to the specified port and starts listening.
UdpMessenger(int port, InetAddress address)	Initiates UdpMessenger, binds it to the specified port and IP address and starts listening.

Method Summary

Modifier and Type	Method	Description
void	closeConnection()	Closes the socket and releases port.
int	getPort()
void	register(UdpListener listener)	Registers listener in the UdpMessenger so it will be notified via UdpListener.notifyMessage(UdpMessage) when new message arrives.
void	run()
void	send(UdpMessage message)	Sends UdpMessage.
void	unregister(UdpListener listener)	Unregisters listener from UdpMessenger so it no longer will be notified.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

UdpMessenger

public UdpMessenger(int port)
             throws SocketException,
UnknownHostException

Initiates UdpMessenger, binds it to the specified port and starts listening. Wildcard IP address will be used.

Parameters:

port - - port to bind socket to.

Throws:

SocketException - if the socket could not be opened, or the socket could not bind to the specified local port.

UnknownHostException

UdpMessenger

public UdpMessenger(int port,
 InetAddress address)
             throws SocketException

Initiates UdpMessenger, binds it to the specified port and IP address and starts listening.

Parameters:

port - - port to bind socket to.

address - - IP address to bind socket to.

Throws:

SocketException - if the socket could not be opened, or the socket could not bind to the specified local port.

Method Details

getPort

public int getPort()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

closeConnection

public void closeConnection()

Closes the socket and releases port.

Specified by:

closeConnection in interface Messenger

register

public void register(UdpListener listener)

Registers listener in the UdpMessenger so it will be notified via UdpListener.notifyMessage(UdpMessage) when new message arrives.

Specified by:

register in interface Messenger

Parameters:

listener - - UdpListener to register.

unregister

public void unregister(UdpListener listener)

Unregisters listener from UdpMessenger so it no longer will be notified.

Specified by:

unregister in interface Messenger

Parameters:

listener - - UdpListener to unregister

send

public void send(UdpMessage message)
          throws IOException

Sends UdpMessage.

Specified by:

send in interface Messenger

Parameters:

message - - UdpMessage to send.

Throws:

IOException - when sending of the message fails