LOGGER.info("----------- Enqueue start ------------");
 //First create the message properties:
 AQMessageProperties msgprop = AQFactory.createAQMessageProperties();
 msgprop.setCorrelation("mycorrelation");
 msgprop.setExceptionQueue("MY_EXCEPTION_QUEUE");
 msgprop.setExpiration(0);
 msgprop.setPriority(1);
 
 // Creates the agent then attaches it to the messages properties (This is the sender)
 oracle.jdbc.aq.AQAgent ag = AQFactory.createAQAgent();
 ag.setName("MY_SENDER_AGENT_NAME");
 ag.setAddress("MY_SENDER_AGENT_ADDRESS");
 msgprop.setSender(ag);
 
 AQMessage mesg = AQFactory.createAQMessage(msgprop);
 
 
 BufferedReader br = new BufferedReader(new FileReader(new File(xmlFile)));
 String line;
 StringBuilder sb = new StringBuilder();

You'll be able to see the REM'd out example of the message, which includes the header and body of the message

 while((line=br.readLine())!= null){
     sb.append(line.trim());
 }
 
 //Setup the message Payload
 byte[] rawPayload = sb.toString().getBytes();
 //byte[] rawPayload = "Example_Payload".getBytes();
 mesg.setPayload(rawPayload);
 //mesg.setPayload(rawPayload);
 
 AQAgent[] recipients = new AQAgent[2];
 recipients[0] = AQFactory.createAQAgent();
 recipients[0].setName("BLUE");
 recipients[1] = AQFactory.createAQAgent();
 recipients[1].setName("RED");
 
 if(recipients != null)
 	msgprop.setRecipientList(recipients);
 
 
 LOGGER.info("Message Enqueue Header Info: "+msgprop.toString());
 //----------- Enqueue start ------------
 //Correlation             : mycorrelation
 //Exception Queue         : MY_EXCEPTION_QUEUE
 //Sender                  : (Name="MY_SENDER_AGENT_NAME" Address="MY_SENDER_AGENT_ADDRESS" Protocol="0") <-- This is the AQ Agent
 //Delay                   : 0
 //Expiration              : 0
 //Priority                : 1
 //Recipient List          : {}
 //----------- Enqueue done ------------

 String str1 = new String(mesg.getPayload());
 LOGGER.info("Payload --> "+str1);
		   
 // We want to retrieve the message id after enqueue:
 AQEnqueueOptions opt = new AQEnqueueOptions();
 opt.setRetrieveMessageId(true);
 
 try{
 	conn.enqueue(queueName,opt,mesg);
 }catch(SQLException s){
 	s.printStackTrace();
 }	

The full example can be located here

About the author