com.ibm.as400.access
Class BaseDataQueue

java.lang.Object
  com.ibm.as400.access.BaseDataQueue

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

DataQueue, KeyedDataQueue

public abstract class BaseDataQueue
extends Object
implements Serializable

The BaseDataQueue class represents an IBM i data queue object.

See Also:

Serialized Form

Constructor and Description

BaseDataQueue()
Constructs a BaseDataQueue object.

BaseDataQueue(AS400 system, String path)
Constructs a BaseDataQueue object.

Method Summary

Modifier and Type	Method and Description
void	addDataQueueListener(DataQueueListener listener) Adds a listener to be notified when a data queue event occurs.
void	addObjectListener(ObjectListener listener) Adds a listener to be notified when an object event occurs.
void	addPropertyChangeListener(PropertyChangeListener listener) Adds a listener to be notified when the value of any bound property changes.
void	addVetoableChangeListener(VetoableChangeListener listener) Adds a listener to be notified when the value of any constrained property changes.
void	clear() Removes all entries from the data queue.
void	delete() Deletes the data queue.
boolean	exists() Checks to see if the data queue exists.
int	getCcsid() Returns the CCSID used for the data in this data queue.
String	getDescription() Returns the text description of the data queue.
boolean	getForceToAuxiliaryStorage() Returns a value that indicates if entries are forced to auxiliary storage.
int	getMaxEntryLength() Returns the maximum entry length of the data queue.
String	getName() Returns the name of the data queue.
String	getPath() Returns the full integrated file system path name of the data queue.
boolean	getSaveSenderInformation() Returns whether sender information is stored with each data queue entry.
AS400	getSystem() Returns the system object representing the system on which the data queue exists.
boolean	isFIFO() Returns a value that indicates if entries are read in FIFO order.
void	refreshAttributes() Refreshes the attributes of the data queue.
void	removeDataQueueListener(DataQueueListener listener) Removes a data queue listener.
void	removeObjectListener(ObjectListener listener) Removes a object listener.
void	removePropertyChangeListener(PropertyChangeListener listener) Removes a property change listener.
void	removeVetoableChangeListener(VetoableChangeListener listener) Removes a vetoable change listener.
void	setCcsid(int ccsid) Sets the CCSID to use for the data in this data queue.
void	setPath(String path) Sets the fully qualified integrated file system path name of the data queue.
void	setSystem(AS400 system) Sets the system object representing the system on which the data queue exists.
String	toString() Returns the String representation of this data queue object.

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseDataQueue

public BaseDataQueue()

Constructs a BaseDataQueue object. The system and path properties must be set before using any method requiring a connection to the system.

BaseDataQueue

public BaseDataQueue(AS400 system,
                     String path)

Constructs a BaseDataQueue object. It uses the specified system and path.

Parameters:

system - The system object representing the system on which the data queue exists.

path - The fully qualified integrated file system path name of the data queue.

Method Detail

addDataQueueListener

public void addDataQueueListener(DataQueueListener listener)

Adds a listener to be notified when a data queue event occurs.

Parameters:

listener - The listener object.

addObjectListener

public void addObjectListener(ObjectListener listener)

Adds a listener to be notified when an object event occurs.

Parameters:

listener - The listener object.

addPropertyChangeListener

public void addPropertyChangeListener(PropertyChangeListener listener)

Adds a listener to be notified when the value of any bound property changes.

Parameters:

listener - The listener object.

addVetoableChangeListener

public void addVetoableChangeListener(VetoableChangeListener listener)

Adds a listener to be notified when the value of any constrained property changes.

Parameters:

listener - The listener object.

clear

public void clear()
           throws AS400SecurityException,
                  ErrorCompletingRequestException,
                  IOException,
                  IllegalObjectTypeException,
                  InterruptedException,
                  ObjectDoesNotExistException

Removes all entries from the data queue.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

delete

public void delete()
            throws AS400SecurityException,
                   ErrorCompletingRequestException,
                   IOException,
                   IllegalObjectTypeException,
                   InterruptedException,
                   ObjectDoesNotExistException

Deletes the data queue.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

exists

public boolean exists()
               throws AS400SecurityException,
                      ErrorCompletingRequestException,
                      IOException,
                      IllegalObjectTypeException,
                      InterruptedException

Checks to see if the data queue exists.

Returns:

true if the data queue exists; false otherwise.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

getCcsid

public int getCcsid()

Returns the CCSID used for the data in this data queue.

Returns:

The CCSID used for the data in this data queue. If the CCSID has not been set, zero (0) is returned.

getDescription

public String getDescription()
                      throws AS400SecurityException,
                             ErrorCompletingRequestException,
                             IOException,
                             IllegalObjectTypeException,
                             InterruptedException,
                             ObjectDoesNotExistException

Returns the text description of the data queue.

Returns:

The text description of the data queue.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

getForceToAuxiliaryStorage

public boolean getForceToAuxiliaryStorage()
                                   throws AS400SecurityException,
                                          ErrorCompletingRequestException,
                                          IOException,
                                          IllegalObjectTypeException,
                                          InterruptedException,
                                          ObjectDoesNotExistException

Returns a value that indicates if entries are forced to auxiliary storage. If true, entries are immediately written to permanent storage. If false, written entries may be kept in memory and could be lost in the case of a power outage.

Returns:

true if entries are immediately written to permanent storage; false otherwise.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

getMaxEntryLength

public int getMaxEntryLength()
                      throws AS400SecurityException,
                             ErrorCompletingRequestException,
                             IOException,
                             IllegalObjectTypeException,
                             InterruptedException,
                             ObjectDoesNotExistException

Returns the maximum entry length of the data queue.

Returns:

The maximum entry length of the data queue.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

getName

public String getName()

Returns the name of the data queue.

Returns:

The data queue name, or an empty string ("") if not set.

getPath

public String getPath()

Returns the full integrated file system path name of the data queue.

Returns:

The fully-qualified data queue name, or an empty string ("") if not set.

getSaveSenderInformation

public boolean getSaveSenderInformation()
                                 throws AS400SecurityException,
                                        ErrorCompletingRequestException,
                                        IOException,
                                        IllegalObjectTypeException,
                                        InterruptedException,
                                        ObjectDoesNotExistException

Returns whether sender information is stored with each data queue entry.

Returns:

true if sender information is saved; false otherwise.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

getSystem

public AS400 getSystem()

Returns the system object representing the system on which the data queue exists.

Returns:

The system object representing the system on which the data queue exists. If the system has not been set, null is returned.

isFIFO

public boolean isFIFO()
               throws AS400SecurityException,
                      ErrorCompletingRequestException,
                      IOException,
                      IllegalObjectTypeException,
                      InterruptedException,
                      ObjectDoesNotExistException

Returns a value that indicates if entries are read in FIFO order. Returns true if entries are read off the data queue in FIFO order. Returns false if entries are read off the data queue in LIFO order.

Returns:

true if entries are read off the data queue in FIFO order; false otherwise.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

refreshAttributes

public void refreshAttributes()
                       throws AS400SecurityException,
                              ErrorCompletingRequestException,
                              IOException,
                              IllegalObjectTypeException,
                              InterruptedException,
                              ObjectDoesNotExistException

Refreshes the attributes of the data queue.

Throws:

AS400SecurityException - If a security or authority error occurs.

ErrorCompletingRequestException - If an error occurs before the request is completed.

IOException - If an error occurs while communicating with the system.

IllegalObjectTypeException - If the object on the system is not the required type.

InterruptedException - If this thread is interrupted.

ObjectDoesNotExistException - If the object does not exist on the system.

removeDataQueueListener

public void removeDataQueueListener(DataQueueListener listener)

Removes a data queue listener.

Parameters:

listener - The listener object.

removeObjectListener

public void removeObjectListener(ObjectListener listener)

Removes a object listener.

Parameters:

listener - The listener object.

removePropertyChangeListener

public void removePropertyChangeListener(PropertyChangeListener listener)

Removes a property change listener.

Parameters:

listener - The listener object.

removeVetoableChangeListener

public void removeVetoableChangeListener(VetoableChangeListener listener)

Removes a vetoable change listener.

Parameters:

listener - The listener object.

setCcsid

public void setCcsid(int ccsid)
              throws PropertyVetoException

Sets the CCSID to use for the data in this data queue.

Parameters:

ccsid - The CCSID to use for the data in this data queue.

Throws:

PropertyVetoException - If the change is vetoed.

setPath

public void setPath(String path)
             throws PropertyVetoException

Sets the fully qualified integrated file system path name of the data queue.

Parameters:

path - The fully qualified integrated file system path name of the data queue.

Throws:

PropertyVetoException - If the change is vetoed.

setSystem

public void setSystem(AS400 system)
               throws PropertyVetoException

Sets the system object representing the system on which the data queue exists.

Parameters:

system - The system object representing the system on which the data queue exists.

Throws:

PropertyVetoException - If the change is vetoed.

toString

public String toString()

Returns the String representation of this data queue object.

Overrides:

toString in class Object

Returns:

The String representation of this data queue object.