PollDtaq.java

import com.ibm.as400.access.*;
public class PollDtaq {
	DataQueue readQ;
	AS400 as400;
	ProgramCall program;
	/*
	 * compile: javac -cp .;..\jars\jt400.jar PollDtaq.java
	 */
	public PollDtaq() {
		this.as400 = new AS400("DPITEST", "as400userid", "password");
		this.readQ = new DataQueue(as400, "/QSYS.LIB/GAH285.LIB/TESTINGQ.DTAQ");
		this.program = new ProgramCall(this.as400);
	}
	
	public void writeQ(String data) throws Exception {
		String programName = "/QSYS.LIB/GAH285.LIB/WRITEDTAQ.PGM";
		ProgramParameter[] parameterList = new ProgramParameter[1];
		AS400Text nametext = new AS400Text(100);
		parameterList[0] = new ProgramParameter(nametext.toBytes(data));
		program.setProgram(programName, parameterList);

		if (!program.run()) {
			System.out.println("write to DTAQ failed");
		}
	}
	
	public String getData() throws Exception {
		String data = readQ.read().getString();
		return data;
	}

	public static void main(String[] args) throws Exception {
		PollDtaq pd = new PollDtaq();
		pd.writeQ("Good Morning");
		System.out.println(pd.getData());
	}
}

WRITEDTAQ.CL

pgm   &Data                                                       
                                                                  
             Dcl        &Data       *Char (100)                   
             Dcl        &QueueName  *Char (10)   Value('TESTINGQ')
             Dcl        &QueueLib   *Char (10)   Value('GAH285')  
             DCL        &DataLength *DEC  (5 0)  Value(100)       
                                                                  
             CRTDTAQ DTAQ(GAH285/TESTINGQ) MAXLEN(100)            
             MONMSG CPF0000 EXEC()                                
                                                                  
             Call  QSndDtaQ (&QueueName +                         
                             &QueueLib +                          
                             &DataLength +                        
                             &Data)                               
endpgm