midrange.com code scratchpad
Name:
MessageFile enhancement
Scriptlanguage:
Java
Tabwidth:
4
Date:
09/14/2008 04:55:47 pm
IP:
Logged
Description:
I've modified the MessageFile object to allow the first & next messages to be retrieved from a message file.

To retrieve the first message, invoke the getMessage with a message id of MessageFile.FIRST. To retrieve the next message, invoke the getMessage method with a message id of MessageFile.NEXT.

If NEXT is specified, and there are no more messages to retrieve, a null message object is returned.
Code:
  1. ///////////////////////////////////////////////////////////////////////////////
  2. //
  3. // JTOpen (IBM Toolbox for Java - OSS version)
  4. //
  5. // Filename:  MessageFile.java
  6. //
  7. // The source code contained herein is licensed under the IBM Public License
  8. // Version 1.0, which has been approved by the Open Source Initiative.
  9. // Copyright (C) 1997-2005 International Business Machines Corporation and
  10. // others.  All rights reserved.
  11. //
  12. ///////////////////////////////////////////////////////////////////////////////
  14. package com.ibm.as400.access;
  15.  
  16. import java.beans.PropertyChangeListener;
  17. import java.beans.PropertyChangeSupport;
  18. import java.beans.PropertyVetoException;
  19. import java.beans.VetoableChangeListener;
  20. import java.beans.VetoableChangeSupport;
  21. import java.io.IOException;
  22. import java.io.Serializable;
  23.  
  24. /**
  25.  Represents a message file object on the system.  This class allows a user to get a message from a message file, returning an AS400Message object which contains the message.  The calling program can optionally supply substitution text for the message.
  26.  <p>MessageFile will optionally format the message's associated help text.  Three options are available for help text formatting:
  27.  <ol>
  28.  <li>No formatting - the help text is returned as a string of characters.  This is the default.
  29.  <li>Include formatting characters - the help text contains formatting characters.  The formatting characters are:
  30.  <ul>
  31.  <br>&N -- Force a new line.
  32.  <br>&P -- Force a new line and indent the new line six characters.
  33.  <br>&B -- Force a new line and indent the new line four characters.
  34.  </ul>
  35.  <li>Substitute formatting characters - the MessageFile class replaces system formatting characters with newline and space characters.
  36.  </ol>
  37.  The difference between options 2 and 3 are with line wrapping.  If the formatting characters remain the application can handle line wrapping and indentation.  If the MessageFile class inserts newline and space characters, Java components will handle line wrapping.
  38.  <p>For example, to retrieve and print a message:
  39.  <pre>
  40.  AS400 system = new AS400("mysystem.mycompany.com");
  41.  MessageFile messageFile = new MessageFile(system);
  42.  messageFile.setPath("/QSYS.LIB/QCPFMSG.MSGF");
  43.  AS400Message message = messageFile.getMessage("CPD0170");
  44.  System.out.println(message.getText());
  45.  </pre>
  46.  <p>You can also sequentially retrieve messages from a message file by using the FIRST & NEXT message id values.
  47.  <pre>
  48.  AS400Message msg = messageFile.getMessage(MessageFile.FIRST);
  49.  
  50.  while (msg != null) {
  51.     System.out.println(msg.getID() + " = " + msg.getText());
  52.     msg = messageFile.getMessage(MessageFile.NEXT);
  53.  }
  54. </pre>
  55.  @see  AS400Message
  56.  @see  CommandCall
  57.  @see  ProgramCall
  58.  @see  QSYSObjectPathName
  59.  **/
  60. public class MessageFile implements Serializable
  61. {
  62.     static final long serialVersionUID = 4L;
  63.  
  64.     /**
  65.      Constant indicating help text should not be formatted.
  66.      **/
  67.     public static final int NO_FORMATTING = 0;
  68.  
  69.     /**
  70.      Constant indicating formatting characters are left in the help text.
  71.      **/
  72.     public static final int RETURN_FORMATTING_CHARACTERS = 1;
  73.  
  74.     /**
  75.      Constant indicating MessageFile should replace formatting characters with newline and space characters.
  76.      **/
  77.     public static final int SUBSTITUTE_FORMATTING_CHARACTERS = 2;
  78.  
  79.     /**
  80.      Constant indicating "the CCSID of the job".
  81.      **/
  82.     public static final int CCSID_OF_JOB = 0;
  83.  
  84.     // The type of help text formatting.
  85.     private int helpTextFormatting_ = NO_FORMATTING;
  86.  
  87.     // The system where the message file is located.
  88.     private AS400 system_ = null;
  89.     // The full IFS path name of the message file.
  90.     private String path_ = "";
  91.     // The library that contains the message file.
  92.     private String library_ = null;
  93.     // The name of the message file.
  94.     private String name_ = null;
  95.  
  96.     // Track if a connection to the system has been made.
  97.     private transient boolean connected_ = false;
  98.  
  99.     // List of property change event bean listeners.
  100.     private transient PropertyChangeSupport propertyChangeListeners_ = null;  // Set on first add.
  101.     // List of vetoable change event bean listeners.
  102.     private transient VetoableChangeSupport vetoableChangeListeners_ = null;  // Set on first add.
  104.     private String lastMessageId = null;
  105.  
  106.     /**
  107.      * Constant indicating we are going to retrieve the next message
  108.      * (using the previous message as a starting point).
  109.      */
  110.     public static final String NEXT = "*NEXT";
  111.     
  112.     /**
  113.      * Constant indicating we are going to retrieve the first message
  114.      * in the message file.
  115.      */
  116.     public static final String FIRST = "*FIRST";
  117.     
  118.     private static final byte[] OPTION_MSGID = 
  119.         new byte[] { 0x5C, (byte)0xD4, (byte)0xE2, (byte)0xC7, (byte)0xC9, (byte)0xC4, (byte)0x40, (byte)0x40, (byte)0x40, (byte)0x40 };
  120.     private static final byte[] OPTION_NEXT = 
  121.         new byte[] { 0x5C, (byte)0xD5, (byte)0xC5, (byte)0xE7, (byte)0xE3, (byte)0x40, (byte)0x40, (byte)0x40, (byte)0x40, (byte)0x40 };
  122.     private static final byte[] OPTION_FIRST = 
  123.         new byte[] { 0x5C, (byte)0xC6, (byte)0xC9, (byte)0xD9, (byte)0xE2, (byte)0xE3, (byte)0x40, (byte)0x40, (byte)0x40, (byte)0x40 };
  124.     
  125.     /**
  126.      Constructs a MessageFile object.  The system and message file name must be provided later.
  127.      **/
  128.     public MessageFile()
  129.     {
  130.         super();
  131.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Constructing MessageFile object.");
  132.     }
  133.  
  134.     /**
  135.      Constructs a MessageFile object.  It uses the specified system.  The message file name must be provided later.
  136.      @param  system  The system object representing the system on which the message file exists.
  137.      **/
  138.     public MessageFile(AS400 system)
  139.     {
  140.         super();
  141.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Constructing MessageFile object, system: " + system);
  142.         if (system == null)
  143.         {
  144.             Trace.log(Trace.ERROR, "Parameter 'system' is null.");
  145.             throw new NullPointerException("system");
  146.         }
  147.         system_ = system;
  148.     }
  149.  
  150.     /**
  151.      Constructs a MessageFile object.  It uses the specified system and message file name.
  152.      @param  system  The system object representing the system on which the message file exists.
  153.      @param  path  The integrated file system path name for the message file.  That is, the message file name as a fully qualified path name in the library file system.  The library and message file name must each be 10 characters or less.  The extension for message files is .msgf.  For example, /QSYS.LIB/MYLIB.LIB/MYFILE.MSGF.
  154.      **/
  155.     public MessageFile(AS400 system, String path)
  156.     {
  157.         super();
  158.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Constructing MessageFile object, system: " + system + " path: " + path);
  159.  
  160.         // Check parameters.
  161.         if (system == null)
  162.         {
  163.             Trace.log(Trace.ERROR, "Parameter 'system' is null.");
  164.             throw new NullPointerException("system");
  165.         }
  166.         if (path == null)
  167.         {
  168.             Trace.log(Trace.ERROR, "Parameter 'path' is null.");
  169.             throw new NullPointerException("path");
  170.         }
  171.         QSYSObjectPathName ifs = new QSYSObjectPathName(path, "MSGF");
  172.  
  173.         // Set instance variables.
  174.         library_ = ifs.getLibraryName();
  175.         name_ = ifs.getObjectName();
  176.         path_ = path;
  177.         system_ = system;
  178.     }
  179.  
  180.     /**
  181.      Adds a PropertyChangeListener.  The specified PropertyChangeListener's <b>propertyChange()</b> method will be called each time the value of any bound property is changed.
  182.      @param  listener  The listener.
  183.      @see  #removePropertyChangeListener
  184.      **/
  185.     public void addPropertyChangeListener(PropertyChangeListener listener)
  186.     {
  187.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Adding property change listener.");
  188.         if (listener == null)
  189.         {
  190.             Trace.log(Trace.ERROR, "Parameter 'listener' is null.");
  191.             throw new NullPointerException("listener");
  192.         }
  193.         synchronized (this)
  194.         {
  195.             // If first add.
  196.             if (propertyChangeListeners_ == null)
  197.             {
  198.                 propertyChangeListeners_ = new PropertyChangeSupport(this);
  199.             }
  200.             propertyChangeListeners_.addPropertyChangeListener(listener);
  201.         }
  202.     }
  203.  
  204.     /**
  205.      Adds a VetoableChangeListener.  The specified VetoableChangeListener's <b>vetoableChange()</b> method will be called each time the value of any constrained property is changed.
  206.      @param  listener  The listener.
  207.      @see  #removeVetoableChangeListener
  208.      **/
  209.     public void addVetoableChangeListener(VetoableChangeListener listener)
  210.     {
  211.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Adding vetoable change listener.");
  212.         if (listener == null)
  213.         {
  214.             Trace.log(Trace.ERROR, "Parameter 'listener' is null.");
  215.             throw new NullPointerException("listener");
  216.         }
  217.         synchronized (this)
  218.         {
  219.             // If first add.
  220.             if (vetoableChangeListeners_ == null)
  221.             {
  222.                 vetoableChangeListeners_ = new VetoableChangeSupport(this);
  223.             }
  224.             vetoableChangeListeners_.addVetoableChangeListener(listener);
  225.         }
  226.     }
  227.  
  228.     /**
  229.      Substitutes formatting characters with appropriate new line and indent characters.  The formatting characters are:
  230.      <ul>
  231.      <br>&N -- Force a new line.
  232.      <br>&P -- Force a new line and indent the new line six characters.
  233.      <br>&B -- Force a new line and indent the new line four characters.
  234.      </ul>
  235.      @param  sourceText  The source text.
  236.      @return  The formatted text.
  237.      **/
  238.     public static String substituteFormattingCharacters(String sourceText)
  239.     {
  240.         // To preserve behavior, assume not BiDi.
  241.         return substituteFormattingCharacters(sourceText, false);
  242.     }
  243.  
  244.     private static String substituteFormattingCharacters(String sourceText, boolean bidi)
  245.     {
  246.         String targetText = sourceText;
  247.         targetText = replaceText(targetText, "&N", "\n");
  248.         targetText = replaceText(targetText, "&P", "\n      ");
  249.         targetText = replaceText(targetText, "&B", "\n    ");
  250.  
  251.         if (bidi)
  252.         {
  253.             targetText = replaceText(targetText, "N&", "\n");
  254.             targetText = replaceText(targetText, "P&", "\n      ");
  255.             targetText = replaceText(targetText, "B&", "\n    ");
  256.         }
  257.         return targetText;
  258.     }
  259.  
  260.     /**
  261.      Returns the status of help text formatting.  Possible values are:
  262.      <ul>
  263.      <li>NO_FORMATTING - The help text is returned as a string of characters.  This is the default.
  264.      <li>RETURN_FORMATTING_CHARACTERS - The help text contains formatting characters.  The formatting characters are:
  265.      <ul>
  266.      <br>&N -- Force a new line.
  267.      <br>&P -- Force a new line and indent the new line six characters.
  268.      <br>&B -- Force a new line and indent the new line four characters.
  269.      </ul>
  270.      <li>SUBSTITUTE_FORMATTING_CHARACTERS - The MessageFile class replaces formatting characters with newline and space characters.
  271.      </ul>
  272.      @return  The status of help text formatting.
  273.      **/
  274.     public int getHelpTextFormatting()
  275.     {
  276.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Getting help text formatting:", helpTextFormatting_);
  277.         return helpTextFormatting_;
  278.     }
  279.  
  280.     /**
  281.      Returns the integrated file system path name of the message file.
  282.      @return  The fully-qualified message file name, or an empty string ("") if not set.
  283.      **/
  284.     public String getPath()
  285.     {
  286.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Getting path: " + path_);
  287.         return path_;
  288.     }
  289.  
  290.     /**
  291.      Returns an AS400Message object containing the object.  The system and message file name must be set before calling this method.
  292.      @param  ID  The message identifier, FIRST, or NEXT.
  293.      @return  An AS400Message object containing the message.
  294.      @exception  AS400SecurityException  If a security or authority error occurs.
  295.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  296.      @exception  InterruptedException  If this thread is interrupted.
  297.      @exception  IOException  If an error occurs while communicating with the system.
  298.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  299.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  300.      **/
  301.     public AS400Message getMessage(String ID) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  302.     {
  303.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID);
  304.         return getMessage(ID, (byte[])null);
  305.     }
  306.  
  307.     /**
  308.      Returns an AS400Message object containing the object.  The system and message file name must be set before calling this method.
  309.      @param  ID  The message identifier, FIRST, or NEXT.
  310.      @param  type  The bidi message string type, as defined by the CDRA (Character Data Representataion Architecture).  See <a href="BidiStringType.html"> BidiStringType</a> for more information and valid values.
  311.      @return  An AS400Message object containing the message.
  312.      @exception  AS400SecurityException  If a security or authority error occurs.
  313.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  314.      @exception  InterruptedException  If this thread is interrupted.
  315.      @exception  IOException  If an error occurs while communicating with the system.
  316.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  317.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  318.      **/
  319.     public AS400Message getMessage(String ID, int type) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  320.     {
  321.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID + ", type:", type);
  322.         return getMessage(ID, (byte[])null, type);
  323.     }
  324.  
  325.     /**
  326.      Returns an AS400Message object containing the message.  The system and message file name must be set before calling this method.  Up to 1024 bytes of substitution text can be supplied to this method.  The calling program is responsible for correctly formatting the string containing the substitution text for the specified message.
  327.      <p>For example, using CL command DSPMSGD, we see the format of the substitution text for message CPD0170 is char 4, char 10, char 10.  Passing string <pre>"12  abcd      xyz"</pre> as the substitution text on this call means "12" will be substituted for &1, "abcd" will be substituted for &2, and "xyz" will be substituted for &3.
  328.      @param  ID  The message identifier, FIRST, or NEXT.
  329.      @param  substitutionText  The substitution text.
  330.      @return  An AS400Message object containing the message.
  331.      @exception  AS400SecurityException  If a security or authority error occurs.
  332.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  333.      @exception  InterruptedException  If this thread is interrupted.
  334.      @exception  IOException  If an error occurs while communicating with the system.
  335.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  336.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  337.      **/
  338.     public AS400Message getMessage(String ID, String substitutionText) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  339.     {
  340.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID + ", substitutionText: " + substitutionText);
  341.         if (system_ == null)
  342.         {
  343.             Trace.log(Trace.ERROR, "Cannot connect to server before setting system.");
  344.             throw new ExtendedIllegalStateException("system", ExtendedIllegalStateException.PROPERTY_NOT_SET);
  345.         }
  346.  
  347.         if (AS400BidiTransform.isBidiCcsid(system_.getCcsid()))
  348.         {
  349.             return getMessage(ID, substitutionText, AS400BidiTransform.getStringType(system_.getCcsid()));
  350.         }
  351.         return getMessage(ID, substitutionText, BidiStringType.DEFAULT);
  352.     }
  353.  
  354.     /**
  355.      Returns an AS400Message object containing the message.  The system and message file name must be set before calling this method.  Up to 1024 bytes of substitution text can be supplied to this method.  The calling program is responsible for correctly formatting the string containing the substitution text for the specified message.
  356.      <p>For example, using CL command DSPMSGD, we see the format of the substitution text for message CPD0170 is char 4, char 10, char 10.  Passing string <pre>"12  abcd      xyz"</pre> as the substitution text on this call means "12" will be substituted for &1, "abcd" will be substituted for &2, and "xyz" will be substituted for &3.
  357.      @param  ID  The message identifier, FIRST, or NEXT.
  358.      @param  substitutionText  The substitution text.
  359.      @param  type  The bidi message string type, as defined by the CDRA (Character Data Representataion Architecture).  See <a href="BidiStringType.html"> BidiStringType</a> for more information and valid values.
  360.      @return  An AS400Message object containing the message.
  361.      @exception  AS400SecurityException  If a security or authority error occurs.
  362.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  363.      @exception  InterruptedException  If this thread is interrupted.
  364.      @exception  IOException  If an error occurs while communicating with the system.
  365.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  366.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  367.      **/
  368.     public AS400Message getMessage(String ID, String substitutionText, int type) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  369.     {
  370.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID + ", substitutionText: " + substitutionText + ", type:", type);
  371.         if (system_ == null)
  372.         {
  373.             Trace.log(Trace.ERROR, "Cannot connect to server before setting system.");
  374.             throw new ExtendedIllegalStateException("system", ExtendedIllegalStateException.PROPERTY_NOT_SET);
  375.         }
  376.  
  377.         return getMessage(ID, substitutionText != null ? new Converter(system_.getCcsid(), system_).stringToByteArray(substitutionText, type) : null, type);
  378.     }
  379.  
  380.     /**
  381.      Returns an AS400Message object containing the message.  The system and message file name must be set before calling this method.  Up to 1024 bytes of substitution text can be supplied to this method.  <b>The byte array is not changed or converted before being sent to the system</b>.
  382.      @param  ID  The message identifier, FIRST, or NEXT.
  383.      @param  substitutionText  The substitution text.  The bytes are assumed to be in the CCSID of the job.
  384.      @return  An AS400Message object containing the message.
  385.      @exception  AS400SecurityException  If a security or authority error occurs.
  386.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  387.      @exception  InterruptedException  If this thread is interrupted.
  388.      @exception  IOException  If an error occurs while communicating with the system.
  389.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  390.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  391.      **/
  392.     public AS400Message getMessage(String ID, byte[] substitutionText) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  393.     {
  394.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID + ", substitutionText:", substitutionText);
  395.         if (system_ == null)
  396.         {
  397.             Trace.log(Trace.ERROR, "Cannot connect to server before setting system.");
  398.             throw new ExtendedIllegalStateException("system", ExtendedIllegalStateException.PROPERTY_NOT_SET);
  399.         }
  400.  
  401.         if (AS400BidiTransform.isBidiCcsid(system_.getCcsid()))
  402.         {
  403.             return getMessage(ID, substitutionText, AS400BidiTransform.getStringType(system_.getCcsid()));
  404.         }
  405.         return getMessage(ID, substitutionText, BidiStringType.DEFAULT);
  406.     }
  407.  
  408.     /**
  409.      Returns an AS400Message object containing the message.  The system and message file name must be set before calling this method.  Up to 1024 bytes of substitution text can be supplied to this method.  <b>The byte array is not changed or converted before being sent to the system</b>.
  410.      @param  ID  The message identifier, FIRST, or NEXT.
  411.      @param  substitutionText  The substitution text.  The bytes are assumed to be in the CCSID of the job.
  412.      @param  type  The bidi message string type, as defined by the CDRA (Character Data Representataion Architecture).  See <a href="BidiStringType.html"> BidiStringType</a> for more information and valid values.
  413.      @return  An AS400Message object containing the message.
  414.      @exception  AS400SecurityException  If a security or authority error occurs.
  415.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  416.      @exception  InterruptedException  If this thread is interrupted.
  417.      @exception  IOException  If an error occurs while communicating with the system.
  418.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  419.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  420.      **/
  421.     public AS400Message getMessage(String ID, byte[] substitutionText, int type) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  422.     {
  423.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID + ", type:" + type + ", substitutionText:", substitutionText);
  424.         return getMessage(ID, substitutionText, type, CCSID_OF_JOB, CCSID_OF_JOB);
  425.     }
  426.  
  427.  
  428.     /**
  429.      Returns an AS400Message object containing the message.  The system and message file name must be set before calling this method.  Up to 1024 bytes of substitution text can be supplied to this method.  <b>The byte array is not changed or converted before being sent to the system</b>.
  430.      @param  ID  The message identifier, FIRST, or NEXT.
  431.      @param  substitutionText  The substitution text.
  432.      @param  type  The bidi message string type, as defined by the CDRA (Character Data Representataion Architecture).  The default value is {@link BidiStringType#DEFAULT BidiStringType.DEFAULT}. See <a href="BidiStringType.html"> BidiStringType</a> for more information and valid values.
  433.      @param  ccsidOfSubstitutionText  The CCSID of the substitution text.  The default value is {@link #CCSID_OF_JOB CCSID_OF_JOB}.
  434.      @param  ccsidToConvertTo  The CCSID in which the system should return the message text. The Toolbox then converts from that CCSID to Unicode when constructing the AS400Message.  The default value is {@link #CCSID_OF_JOB CCSID_OF_JOB}.
  435.      @return  An AS400Message object containing the message.
  436.      @exception  AS400SecurityException  If a security or authority error occurs.
  437.      @exception  ErrorCompletingRequestException  If an error occurs before the request is completed.
  438.      @exception  InterruptedException  If this thread is interrupted.
  439.      @exception  IOException  If an error occurs while communicating with the system.
  440.      @exception  ObjectDoesNotExistException  If the object does not exist on the system.
  441.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  442.      **/
  443.     public AS400Message getMessage(String ID, byte[] substitutionText, int type, int ccsidOfSubstitutionText, int ccsidToConvertTo) throws AS400SecurityException, ErrorCompletingRequestException, InterruptedException, IOException, ObjectDoesNotExistException, PropertyVetoException
  444.     {
  445.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Retrieving message from message file, ID: " + ID + ", type:" + type+ ", ccsidOfSubstitutionText:" + ccsidOfSubstitutionText + ", substitutionText:", substitutionText);
  446.         if (ID == null)
  447.         {
  448.             Trace.log(Trace.ERROR, "Parameter 'ID' is null.");
  449.             throw new NullPointerException("ID");
  450.         }
  451.         if (ID.length() > 7)
  452.         {
  453.             Trace.log(Trace.ERROR, "Length of parameter 'ID' is not valid: '" + ID + "'");
  454.             throw new ExtendedIllegalArgumentException("ID (" + ID + ")", ExtendedIllegalArgumentException.LENGTH_NOT_VALID);
  455.         }
  456.  
  457.         if (system_ == null)
  458.         {
  459.             Trace.log(Trace.ERROR, "Cannot connect to server before setting system.");
  460.             throw new ExtendedIllegalStateException("system", ExtendedIllegalStateException.PROPERTY_NOT_SET);
  461.         }
  462.         if (path_.length() == 0)
  463.         {
  464.             Trace.log(Trace.ERROR, "Cannot connect to server before setting path.");
  465.             throw new ExtendedIllegalStateException("path", ExtendedIllegalStateException.PROPERTY_NOT_SET);
  466.         }
  467.  
  468.         // Prevent changing the system or path after retrieving a message.
  469.         connected_ = true;
  470.  
  471.         Converter conv = new Converter(system_.getCcsid(), system_);
  472.  
  473.         byte[] nameBytes = new byte[] { 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40 };  // 20 EBCDIC blanks
  474.         conv.stringToByteArray(name_, nameBytes, 0, 10, type);
  475.         conv.stringToByteArray(library_, nameBytes, 10, 10, type);
  476.  
  477.         byte[] optionBytes = OPTION_MSGID;
  478.         if (ID.equals(FIRST)) {
  479.             optionBytes = OPTION_FIRST;
  480.             ID = "";
  481.         } else if (ID.equals(NEXT)) {
  482.             optionBytes = OPTION_NEXT;
  483.             ID = lastMessageId;
  484.         }
  485.         
  486.         byte[] idBytes = new byte[] { 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40 };  // 7 EBCDIC blanks
  487.         conv.stringToByteArray(ID, idBytes, 0, 7);
  488.  
  489.         if (substitutionText == null) substitutionText = new byte[0];
  490.  
  491.         byte[] starNoBytes = new byte[] { 0x5C, (byte)0xD5, (byte)0xD6, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40 };  // "*NO       ", in EBCDIC
  492.         byte[] starYesBytes = new byte[] { 0x5C, (byte)0xE8, (byte)0xC5, (byte)0xE2, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40 };  // "*YES      ", in EBCDIC
  494.         byte[] replace = (substitutionText.length == 0) ? starNoBytes : starYesBytes;
  495.         byte[] format = (helpTextFormatting_ == 0) ? starNoBytes : starYesBytes;
  496.  
  497.         // Setup program parameters.
  498.         ProgramParameter[] parameters = new ProgramParameter[]
  499.         {
  500.             // Message information, output, char(*).
  501.             new ProgramParameter(5120),
  502.             // Length of message information, input, binary(4). (0x1400 == 5120)
  503.             new ProgramParameter(new byte[] { 0x00, 0x00, 0x14, 0x00 } ),
  504.             // Format name, input, char(8), "RTVM0300" (EBCDIC).
  505.             new ProgramParameter(new byte[] { (byte)0xD9, (byte)0xE3, (byte)0xE5, (byte)0xD4, (byte)0xF0, (byte)0xF3, (byte)0xF0, (byte)0xF0 } ),
  506.             // Message identifier, input, char(7).
  507.             new ProgramParameter(idBytes),
  508.             // Qualified message file name, input, char(20).
  509.             new ProgramParameter(nameBytes),
  510.             // Replacement data, input, char(*).
  511.             new ProgramParameter(substitutionText),
  512.             // Length of replacement data, input, binary(4).
  513.             new ProgramParameter(BinaryConverter.intToByteArray(substitutionText.length)),
  514.             // Replace substitution values, input, char(10).
  515.             new ProgramParameter(replace),
  516.             // Return format control characters, input, char(10).
  517.             new ProgramParameter(format),
  518.             // Error code, I/0, char(*).
  519.             new ProgramParameter(new byte[8]),
  520.             // Retrieve option, input, char(10)
  521.             new ProgramParameter(optionBytes),
  522.            // CCSID to convert to, input, binary(4).  0 == "ccsid of job".
  523.             new ProgramParameter(BinaryConverter.intToByteArray(ccsidToConvertTo)),
  524.             // CCSID of replacement data, input, binary(4).  0 == "ccsid of job".
  525.             new ProgramParameter(BinaryConverter.intToByteArray(ccsidOfSubstitutionText))
  526.         };
  527.  
  528.         // Design note: The 3 "optional parameters" existed in V5R1, and probably even earlier.  But to be safe, we'll only send them if we need to.
  529.         // In order to implement the *FIRST & *NEXT options, the three optional
  530.         // parameters are now always included.
  531.         
  532.         // Call the program.
  533.         ProgramCall pc = new ProgramCall(system_, "/QSYS.LIB/QMHRTVM.PGM", parameters);
  534.         pc.setThreadSafe(true);
  535.         if (!pc.run())
  536.         {
  537.             throw new AS400Exception(pc.getMessageList()[0]);
  538.         }
  539.  
  540.         // Prepare to convert returned character bytes to Unicode.
  541.         int ccsidOfTextBytes;  // CCSID of returned character fields
  542.         if (ccsidToConvertTo == CCSID_OF_JOB) {
  543.           ccsidOfTextBytes = system_.getCcsid();
  544.         }
  545.         else {
  546.           ccsidOfTextBytes = ccsidToConvertTo;
  547.           conv = new Converter(ccsidOfTextBytes, system_);
  548.         }
  549.  
  550.         byte[] messageInformation = parameters[0].getOutputData();
  551.         ID = conv.byteArrayToString(messageInformation, 26, 7, type).trim();
  552.         
  553.         AS400Message msg = null;
  554.         
  555.         // if we got a message (assuming ID isn't blank), create & populate the
  556.         // message object.  If we didn't get a message, leave the message null.
  557.         if (ID.length() > 0) {
  558.             msg = new AS400Message();
  559.             msg.setID(ID);
  560.             msg.setSeverity(BinaryConverter.byteArrayToInt(messageInformation, 8));
  561.             int defaultReplyOffset = BinaryConverter.byteArrayToInt(messageInformation, 52);
  562.             int defaultReplyLength = BinaryConverter.byteArrayToInt(messageInformation, 56);
  563.             int messageOffset = BinaryConverter.byteArrayToInt(messageInformation, 64);
  564.             int messageLength = BinaryConverter.byteArrayToInt(messageInformation, 68);
  565.             int helpOffset = BinaryConverter.byteArrayToInt(messageInformation, 76);
  566.             int helpLength = BinaryConverter.byteArrayToInt(messageInformation, 80);
  567.  
  568.             msg.setDefaultReply(conv.byteArrayToString(messageInformation, defaultReplyOffset, defaultReplyLength, type));
  569.             msg.setText(conv.byteArrayToString(messageInformation, messageOffset, messageLength, type));
  570.             String helpText = conv.byteArrayToString(messageInformation, helpOffset, helpLength, type);
  571.             if (helpTextFormatting_ == SUBSTITUTE_FORMATTING_CHARACTERS)
  572.             {
  573.                 helpText = substituteFormattingCharacters(helpText, AS400BidiTransform.isBidiCcsid(ccsidOfTextBytes));
  574.             }
  575.             msg.setHelp(helpText);
  576.             lastMessageId = ID;
  577.  
  578.         } 
  579.  
  580.         return msg;
  581.     }
  582.  
  583.     /**
  584.      Returns the system object representing the system on which the message file exists.
  585.      @return  The system object representing the system on which the message file exists.  If the system has not been set, null is returned.
  586.      **/
  587.     public AS400 getSystem()
  588.     {
  589.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Getting system: " + system_);
  590.         return system_;
  591.     }
  592.  
  593.     /**
  594.      Removes the PropertyChangeListener.  If the PropertyChangeListener is not on the list, nothing is done.
  595.      @param  listener  The listener object.
  596.      **/
  597.     public void removePropertyChangeListener(PropertyChangeListener listener)
  598.     {
  599.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Removing property change listener.");
  600.         if (listener == null)
  601.         {
  602.             Trace.log(Trace.ERROR, "Parameter 'listener' is null.");
  603.             throw new NullPointerException("listener");
  604.         }
  605.         // If we have listeners.
  606.         if (propertyChangeListeners_ != null)
  607.         {
  608.             propertyChangeListeners_.removePropertyChangeListener(listener);
  609.         }
  610.     }
  611.  
  612.     /**
  613.      Removes the VetoableChangeListener.  If the VetoableChangeListener is not on the list, nothing is done.
  614.      @param  listener  The listener object.
  615.      **/
  616.     public void removeVetoableChangeListener(VetoableChangeListener listener)
  617.     {
  618.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Removing vetoable change listener.");
  619.         if (listener == null)
  620.         {
  621.             Trace.log(Trace.ERROR, "Parameter 'listener' is null.");
  622.             throw new NullPointerException("listener");
  623.         }
  624.         // If we have listeners.
  625.         if (vetoableChangeListeners_ != null)
  626.         {
  627.             vetoableChangeListeners_.removeVetoableChangeListener(listener);
  628.         }
  629.     }
  630.  
  631.     // Replace one phrase for another inside a string.
  632.     private static String replaceText(String s, String oldPhrase, String newPhrase)
  633.     {
  634.         int index = s.indexOf(oldPhrase);
  635.  
  636.         while (index >= 0)
  637.         {
  638.             if (index == 0)
  639.             {
  640.                 s = newPhrase + s.substring(3);
  641.             }
  642.             else
  643.             {
  644.                 // Copy from beginning of String to location of oldPhrase.
  645.                 StringBuffer b = new StringBuffer(s.substring(0, index));
  646.                 b.append(newPhrase);
  647.                 // Start at the 2nd position after where oldPhrase occurred.
  648.                 b.append(s.substring(index + 2));
  649.                 s = b.toString();
  650.             }
  651.  
  652.             index = s.indexOf(oldPhrase);
  653.         }
  654.  
  655.         return s;
  656.     }
  657.  
  658.     /**
  659.      Sets the help text formatting value.  Possible values are:
  660.      <ul>
  661.      <li>NO_FORMATTING - the help text is returned as a string of characters.  This is the default.
  662.      <li>RETURN_FORMATTING_CHARACTERS - the help text contains formatting characters.  The formatting characters are:
  663.      <ul>
  664.      <br>&N -- Force a new line.
  665.      <br>&P -- Force a new line and indent the new line six characters.
  666.      <br>&B -- Force a new line and indent the new line four characters.
  667.      </ul>
  668.      <li>SUBSTITUTE_FORMATTING_CHARACTERS - the MessageFile class replaces formatting characters with new line and space characters.
  669.      </ul>
  670.      @param  helpTextFormatting  The help text formatting value.
  671.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  672.      **/
  673.     public void setHelpTextFormatting(int helpTextFormatting) throws PropertyVetoException
  674.     {
  675.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Setting help text formatting:", helpTextFormatting);
  676.         if (helpTextFormatting < NO_FORMATTING || helpTextFormatting > SUBSTITUTE_FORMATTING_CHARACTERS)
  677.         {
  678.             Trace.log(Trace.ERROR, "Value of parameter 'helpTextFormatting' is not valid: " + helpTextFormatting);
  679.             throw new ExtendedIllegalArgumentException("helpTextFormatting (" + helpTextFormatting + ")", ExtendedIllegalArgumentException.PARAMETER_VALUE_NOT_VALID);
  680.         }
  681.  
  682.         if (propertyChangeListeners_ == null && vetoableChangeListeners_ == null)
  683.         {
  684.             helpTextFormatting_ = helpTextFormatting;
  685.         }
  686.         else
  687.         {
  688.             Integer oldValue = new Integer(helpTextFormatting_);
  689.             Integer newValue = new Integer(helpTextFormatting);
  690.  
  691.             if (vetoableChangeListeners_ != null)
  692.             {
  693.                 vetoableChangeListeners_.fireVetoableChange("helpTextFormatting", oldValue, newValue);
  694.             }
  695.             helpTextFormatting_ = helpTextFormatting;
  696.             if (propertyChangeListeners_ != null)
  697.             {
  698.                 propertyChangeListeners_.firePropertyChange("helpTextFormatting", oldValue, newValue);
  699.             }
  700.         }
  701.     }
  702.  
  703.     /**
  704.      Sets the message file name.  The name cannot be changed after retrieving a message from the system.
  705.      @param  path  The integrated file system path name for the message file.  That is, the message file name as a fully qualified path name in the library file system.  The library and message file name must each be 10 characters or less.  The extension for message files is .msgf.  For example, /QSYS.LIB/MYLIB.LIB/MYFILE.MSGF.
  706.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  707.      **/
  708.     public void setPath(String path) throws PropertyVetoException
  709.     {
  710.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Setting path: " + path);
  711.         if (path == null)
  712.         {
  713.             Trace.log(Trace.ERROR, "Parameter 'path' is null.");
  714.             throw new NullPointerException("path");
  715.         }
  716.         // Cannot change the path once we retrieve the first message.
  717.         if (connected_)
  718.         {
  719.             Trace.log(Trace.ERROR, "Cannot set property 'path' after connect.");
  720.             throw new ExtendedIllegalStateException("path", ExtendedIllegalStateException.PROPERTY_NOT_CHANGED);
  721.         }
  722.         QSYSObjectPathName ifs = new QSYSObjectPathName(path, "MSGF");
  723.  
  724.         if (propertyChangeListeners_ == null && vetoableChangeListeners_ == null)
  725.         {
  726.             library_ = ifs.getLibraryName();
  727.             name_ = ifs.getObjectName();
  728.             path_ = path;
  729.         }
  730.         else
  731.         {
  732.             String oldValue = path_;
  733.             String newValue = path;
  734.  
  735.             if (vetoableChangeListeners_ != null)
  736.             {
  737.                 vetoableChangeListeners_.fireVetoableChange("path", oldValue, newValue);
  738.             }
  739.             library_ = ifs.getLibraryName();
  740.             name_ = ifs.getObjectName();
  741.             path_ = path;
  742.             if (propertyChangeListeners_ != null)
  743.             {
  744.                 propertyChangeListeners_.firePropertyChange("path", oldValue, newValue);
  745.             }
  746.         }
  747.     }
  748.  
  749.     /**
  750.      Sets the system object representing the system on which the message file exists.  The system cannot be changed after retrieving a message from the system.
  751.      @param  system  The system object representing the system on which the message file exists.
  752.      @exception  PropertyVetoException  If any of the registered listeners vetos the property change.
  753.      **/
  754.     public void setSystem(AS400 system) throws PropertyVetoException
  755.     {
  756.         if (Trace.traceOn_) Trace.log(Trace.DIAGNOSTIC, "Setting system: " + system);
  757.         if (system == null)
  758.         {
  759.             Trace.log(Trace.ERROR, "Parameter 'system' is null.");
  760.             throw new NullPointerException("system");
  761.         }
  762.         // Cannot change the system once we retrieve the first message.
  763.         if (connected_)
  764.         {
  765.             Trace.log(Trace.ERROR, "Cannot set property 'system' after connect.");
  766.             throw new ExtendedIllegalStateException("system", ExtendedIllegalStateException.PROPERTY_NOT_CHANGED);
  767.         }
  768.  
  769.         if (propertyChangeListeners_ == null && vetoableChangeListeners_ == null)
  770.         {
  771.             system_ = system;
  772.         }
  773.         else
  774.         {
  775.             AS400 oldValue = system_;
  776.             AS400 newValue = system;
  777.  
  778.             if (vetoableChangeListeners_ != null)
  779.             {
  780.                 vetoableChangeListeners_.fireVetoableChange("system", oldValue, newValue);
  781.             }
  782.             system_ = system;
  783.             if (propertyChangeListeners_ != null)
  784.             {
  785.                 propertyChangeListeners_.firePropertyChange("system", oldValue, newValue);
  786.             }
  787.         }
  788.     }
  789. }
  790.  
© 2004-2019 by midrange.com generated in 0.755s valid xhtml & css