Configuration Platform SDK 7.6 API Reference

com.genesyslab.platform.commons.protocol
Class AbstractQueueReceiver

java.lang.Object
  extended bycom.genesyslab.platform.commons.protocol.AbstractQueueReceiver
All Implemented Interfaces:
ChannelListener, Listener, Receiver, ReceiverSupport
Direct Known Subclasses:
QueueMessageReceiver, QueueRequestReceiver

public abstract class AbstractQueueReceiver
extends java.lang.Object
implements ReceiverSupport


Field Summary
 
Fields inherited from interface com.genesyslab.platform.commons.protocol.Receiver
DEF_INPUT_SIZE
 
Method Summary
 void clearInput()
          Clears input of the receiver.
 int getInputSize()
          Return the amount of messages this Receiver can hold before start to "forget stale messages"
 int getMaxInputSize()
           
 void onChannelClosed(ChannelClosedEvent event)
           
 void onChannelError(ChannelErrorEvent event)
           
 void onChannelOpened(java.util.EventObject event)
           
 void releaseReceivers()
          Notify receivers (threads waiting on receive() methods) they should stop waiting and return null.
 void setInputSize(int inputSize)
          Set the amount of messages this Receiver can hold before start to "forget stale messages"
 void setMaxInputSize(int maxInputSize)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInputSize

public int getInputSize()
Description copied from interface: Receiver
Return the amount of messages this Receiver can hold before start to "forget stale messages"

Specified by:
getInputSize in interface Receiver
Returns:
maximum count of messages stored in receiver

setInputSize

public void setInputSize(int inputSize)
Description copied from interface: Receiver
Set the amount of messages this Receiver can hold before start to "forget stale messages"

Specified by:
setInputSize in interface Receiver
Parameters:
inputSize - maximum count of messages stored in receiver

getMaxInputSize

public int getMaxInputSize()

setMaxInputSize

public void setMaxInputSize(int maxInputSize)

clearInput

public void clearInput()
Description copied from interface: Receiver
Clears input of the receiver. Please note, that there is no strict guaranties that input will be empty after this method has returned, the messages could be delivered by another thread.

Specified by:
clearInput in interface Receiver

onChannelOpened

public void onChannelOpened(java.util.EventObject event)
Specified by:
onChannelOpened in interface ChannelListener

onChannelClosed

public void onChannelClosed(ChannelClosedEvent event)
Specified by:
onChannelClosed in interface ChannelListener

onChannelError

public void onChannelError(ChannelErrorEvent event)
Specified by:
onChannelError in interface ChannelListener

releaseReceivers

public void releaseReceivers()
Description copied from interface: Receiver
Notify receivers (threads waiting on receive() methods) they should stop waiting and return null.

Specified by:
releaseReceivers in interface Receiver

Configuration Platform SDK 7.6 API Reference

Send comments on this topic.
Copyright © 2006–2008 Genesys Telecommunication Laboratories, Inc. All rights reserved.