AQ Message from java to Oracle Database Example

The script below highlights the example of the (raw) AQ Message creation
March 3, 2015
javaAQ

Setting the message Header

 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();


Setting the message Body and AQAgent

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 ------------


Commit AQ

 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

Daniel is a Technical Manager with over 10 years of consulting expertise in the Identity and Access Management space.
Daniel has built from scratch this blog as well as technicalconfessions.com
Follow Daniel on twitter @nervouswiggles

Comments

Other Posts

AWS-PHP integration - Email not sent. SMTP Error: Could not authenticate.

phpsmtpaws

February 6, 2020
Created by: Daniel Redfern
AS I was migrating my environment into an S3 environment, I wanted to leverage off the SES services that AWS provide, more specifically, to leverage the off the SMTP functionality by sending an email via PHP
Read More...

SOLUTION: no headers files (.h) found in softwareserial - Arduino

Arduino

February 24, 2019
Created by: Daniel Redfern
The WeMos D1 is a ESP8266 WiFi based board is an extension to the current out-of-the-box library that comes with the Arduino installation. Because of this, you need to import in the libraries as well as acknowledging the specific board. This process is highly confusion with a number of different individuals talking about a number of different ways to integrate.
Read More...

NameID element must be present as part of the Subject in the Response message

ShibbolethSAML

August 7, 2018
Created by: Daniel Redfern
NameID element must be present as part of the Subject in the Response message, please enable it in the IDP configuration.
Read More...

HOW TO provision AD group membership from OpenIDM

OpenIDMICFAD-connector

June 15, 2018
Created by: Daniel Redfern
For what I see, there's not too many supportive documentations out there that will demonstrate how provision AD group membership with the ICF connector using OpenIDM. The use of the special ldapGroups attribute is not explained anywhere in the Integrators guides to to the date of this blog. This quick blog identifies the tasks required to provision AD group membership from OpenIDM to AD using the LDAP ICF connector. However this doesn't really explain what ldapGroups actually does and there's no real worked example of how to go from an Assignment to ldapGroups to an assigned group in AD. I wrote up a wiki article for my own reference: AD group memberships automatically to users This is just my view, others may disagree, but I think the implementation experience could be improved with some more documentation and a more detailed example here.
Read More...

ForgeRock OpenIDM - InvalidCredentialException: Remote framework key is invalid

ICFIDMOpenIDMOpenICF

November 8, 2017
Created by: Daniel Redfern
In the past, the similar error occurred though for the Oracle Identity Management solution. invalidcredentialexception remote framework key is invalid Because they all share the ICF connector framework, the error/solution would be the same.
Read More...

org.forgerock.script.exception.ScriptCompilationException: missing ; before statement

IDMsync.confforgerockopenidm

November 8, 2017
Created by: Daniel Redfern
org.forgerock.script.exception.ScriptCompilationException: missing ; before statement
Read More...

ForgeRock IDM - org.forgerock.script.exception.ScriptCompilationException: missing ; before statemen

OpenIDMsync.confForgeRock

September 17, 2017
Created by: Daniel Redfern
ForgeRock IDM - org.forgerock.script.exception.ScriptCompilationException: missing ; before statement
Read More...

Caused by: org.forgerock.json.resource.BadRequestException: Target does not support attribute groups

OpenIDMForgeRockICFConnector

September 17, 2017
Created by: Daniel Redfern
When performing the attempt of a reconciliation from ForgeRock IDM to Active Directory, I would get the following error
Read More...

ForgeRock OpenIDM - InvalidCredentialException: Remote framework key is invalid

OpenIDMForgeRockICFConnectorAD

September 17, 2017
Created by: Daniel Redfern
In the past, the similar error occurred though for the Oracle Identity Management solution. invalidcredentialexception remote framework key is invalid Because they all share the ICF connector framework, the error/solution would be the same.
Read More...

ERROR Caused by com.google.api.client.auth.oauth2.TokenResponseException 400 Bad Request - invalid_g

OpenIDMIDMGoogleGoogle-AppsICFreconciliation

September 12, 2017
Created by: Daniel Redfern
During the reconcilation from OpenIDM to the ICF google apps connector, the following error response would occur. ERROR Caused by com.google.api.client.auth.oauth2.TokenResponseException 400 Bad Request - invalid_grant
Read More...