org.qbroker.receiver

Class PacketReceiver

java.lang.Object

org.qbroker.receiver.Receiver

org.qbroker.receiver.PacketReceiver

All Implemented Interfaces:

MessageReceiver

public class PacketReceiver
extends Receiver

PacketReceiver listens to a UDP socket and receives packets from it. It transforms the packet into a JMS Message and put it to an XQueue as the output. PacketReceiver supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.receiver.Receiver

capacity, displayMask, linkName, maxRetry, mode, operation, partition, pauseTime, propertyName, propertyValue, repeatPeriod, standbyTime, status, timeout, tolerance, uri, waitTime, xaMode

Fields inherited from interface org.qbroker.receiver.MessageReceiver

RCVR_CLOSED, RCVR_DISABLED, RCVR_PAUSE, RCVR_READY, RCVR_RETRYING, RCVR_RUNNING, RCVR_STANDBY, RCVR_STOPPED

Constructor Summary

Constructors

Constructor and Description
PacketReceiver(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
protected void	finalize()
java.net.InetAddress	getAddress()
int	getPort()
void	receive(XQueue xq, int baseTime) puts all the received JMS messages to the XQueue as the output.
void	send(java.net.DatagramPacket packet) for directly sending packet to its destination

Methods inherited from class org.qbroker.receiver.Receiver

getCapacity, getLinkName, getName, getOperation, getPartition, getStatus, getXAMode, isStopped, keepRunning, resetStatus, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

PacketReceiver

public PacketReceiver(java.util.Map props)

Method Detail

receive

public void receive(XQueue xq,
                    int baseTime)

Description copied from interface: MessageReceiver

puts all the received JMS messages to the XQueue as the output. In case of failure, it should keep retry with the sleepTime in milliseconds.

Specified by:

receive in interface MessageReceiver

Specified by:

receive in class Receiver

send

public void send(java.net.DatagramPacket packet)
          throws java.io.IOException

for directly sending packet to its destination

Throws:

java.io.IOException

getAddress

public java.net.InetAddress getAddress()

getPort

public int getPort()

close

public void close()

Description copied from interface: MessageReceiver

closes all opened resources

Specified by:

close in interface MessageReceiver

Specified by:

close in class Receiver

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object