HOW TO: Create a Oracle AQ Topic JMS message for java delivery

The steps to create a AQ Topic for a JMS text message. These are the pre-requisites in preparation to the following blog, HOW TO: Enqueue a JMS_TEXT_MESSAGE from java to Oracle database Queue
March 12, 2015
Oracle-AQJMSQueuesTopicsJMS
E_WARNING Error in file posts.php at line 313: fopen(http://www.technicalconfessions.com/images/postimages/postIcons/pp377.png): failed to open stream: HTTP request failed! HTTP/1.1 404 Not Found E_WARNING Error in file posts.php at line 313: fclose() expects parameter 1 to be resource, boolean given

-- ---------------------------------------
-- Create a user and assign the privileges
-- ---------------------------------------
GRANT connect, resource TO ORACLEAQJMSUSER IDENTIFIED BY ORACLEAQJMSUSER;
GRANT aq_user_role TO ORACLEAQJMSUSER;
GRANT execute ON sys.dbms_aqadm TO ORACLEAQJMSUSER;
GRANT execute ON sys.dbms_aq TO ORACLEAQJMSUSER;
GRANT execute ON sys.dbms_aqin TO ORACLEAQJMSUSER;
GRANT execute ON sys.dbms_aqjms TO ORACLEAQJMSUSER;

-- --------------------
-- Create a queue table
-- --------------------
connect ORACLEAQJMSUSER/ORACLEAQJMSUSER;

BEGIN
dbms_aqadm.create_queue_table (
queue_table => 'AQ_MESSAGE_QUEUE_TABLE',
queue_payload_type => 'sys.aq$_jms_text_message',
multiple_consumers => true
);
END;

-- --------------
-- Create a queue
-- --------------
BEGIN
  DBMS_AQADM.CREATE_QUEUE (
    queue_name  => 'AQ_MESSAGE_QUEUE',
    queue_table => 'AQ_MESSAGE_QUEUE_TABLE'
  );
  DBMS_AQADM.START_QUEUE (
    queue_name => 'AQ_MESSAGE_QUEUE'
  );
END;



/* Drop queue: */  
EXECUTE dbms_aqadm.drop_queue (Queue_name => 'ORACLEAQJMSUSER.AQ_MESSAGE_QUEUE');  
EXECUTE dbms_aqadm.drop_queue (Queue_name => 'ORACLEAQJMSUSER.AQ_MESSAGE_QUEUE_TABLE');   

/*Drop Queue Table */
EXECUTE dbms_aqadm.drop_queue_table (queue_table => 'ORACLEAQJMSUSER.AQ_MESSAGE_QUEUE');  
EXECUTE dbms_aqadm.drop_queue_table (queue_table => 'ORACLEAQJMSUSER.AQ_MESSAGE_QUEUE_TABLE');   



-- -------------------
-- Create a subscriber (aka agent)
-- You only need a subscriber (or a list of recipients) for multiple consumers on the queue (subscribers are not needed for non-multiple consumers)
-- -------------------
/* Anonymous PL/SQL block for adding a subscriber at a designated queue in a 
designated schema at a database link: */ 
DECLARE 
   subscriber          sys.aq$_agent; 
BEGIN 
	/*sys.aq$_agent (, ,*/
   subscriber := sys.aq$_agent ('OIM_SUBSCRIBER', 'null', 0); 
   DBMS_AQADM.ADD_SUBSCRIBER(
     queue_name         => 'ORACLEAQJMSUSER.AQ_MESSAGE_QUEUE', 
      subscriber            =>  subscriber); 
 END; 
 


Create user

https://technicalconfessions.com/images/postimages/postimages/_377_3_Creating user within SQL command.png

Confirm user authentication

https://technicalconfessions.com/images/postimages/postimages/_377_4_ensuring the user can authenticate.png

View queues within SQL developer

https://technicalconfessions.com/images/postimages/postimages/_377_5_checking that the queues and topics are set.png

AQ Queue Details

https://technicalconfessions.com/images/postimages/postimages/_377_6_confirm the queue details.png

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

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

forgerock-openidm-encryptedjwt-error

OpenIDMIDMForgeRockJWTIAM

August 29, 2017
Created by: Daniel Redfern
Received the JWT error
Read More...

Unexpected character ('¾' (code 190)): expected a valid value

ForgeRock-OpenIDMOpenIDMIDMKeystore

June 25, 2017
Created by: Daniel Redfern
Unexpected character occurred when the IP addresses changes and the virtual instance was migrated into a separate network subnet.
Read More...
E_WARNING Error in file posts.php at line 464: fopen(http://www.technicalconfessions.com/images/postimages/postIcons/pp444.png): failed to open stream: HTTP request failed! HTTP/1.1 404 Not Found E_WARNING Error in file posts.php at line 464: fclose() expects parameter 1 to be resource, boolean given

OpenDJ Error - Connect Error Result Code: 91 (Connect Error)

OpenDJLDAPldapsearchForgeRock

June 5, 2017
Created by: Daniel Redfern
When trying to connect, I would then receive the following error "Connect Error Result Code: 91 (Connect Error)"
Read More...

Tomcat NioEndpoint$SocketProcessor.doRun java.lang.NullPointerException error

TomcatJava-8PKICAS

June 5, 2017
Created by: Daniel Redfern
When initiating the Tomcat instance, the cas-stderr log file will log a SEVERE error logging multiple times every few seconds
Read More...