HOW TO: Enqueue a JMS_TEXT_MESSAGE from java to Oracle database Queue

In this example, I've quickly highlighted the JMS (Java Message Service) components with a simple POJO (Plain Old Java Object) for an asynchronous oracle database queue as well as constructing a JMS_TEXT_MESSAGE to the queue.
February 1, 2017
AQJMSQueueSQL

If you haven't already, jump to the blog HOW TO: Create a Oracle AQ Topic JMS message for java delivery, which will be able to assist you in setting up the database, if you haven't already.

Java Message Service (JMS) is the messaging standard to provide the exchanging of messages. Essentially, JMS are a set interfaces that provides a JMS client the ability to facilitate for the enterprise messaging. This also includes the extension to support the operations and features for Advanced Queuing (AQ)

The JMS Text message is sent to an AQ queue. There are other types of JMS messages ('bytes_messages', 'map_message', 'stream_message' etc) though this blog focuses on the text message, which is called SYS.AQ$_JMS_TEXT_MESSAGE.

The code below goes through a similar example though here's a basic JMS TEXT MESSAGE.

SYS.AQ$_JMS_TEXT_MESSAGE(
SYS.AQ$_JMS_HEADER(NULL,NULL,NULL,NULL,NULL,NULL,NULL),
17,
'text',
NULL
)


Breaking down the SYS.AQ$_JMS_TEXT_MESSAGE

Essentially, the SYS.AQ$_JMS_TEXT_MESSAGE as 4 components, which are highlighted below. the type of JMS_TEXT_MESSAGE components are as follows:

  • HEADER - Header properties in the SYS.AQ$_JMS_HEADER datatype. (Explained in more detail below)
  • TEXT_LEN - It's the size of the message, which it is set automatically. The example above is 29
  • TEXT_VC - The message payload in VARCHAR2 format, if the payload is equal to or less than 4000 bytes. Because the example above is TEXT_LEN is less than 4000 (hence 29), this is populated and not the TEXT_LOB. If it's greater than 4000, this remains null and the TEXT_LOB is populated.
  • TEXT_LOB - The message payload in CLOB (hence the 'LOB' name) format. This is populated if the TEXT_VS is greater than 4000, otherwise it's null


The SYS.AQ$_JMS_HEADER

The HEADER value, which is known as the SYS.AQ$_JMS_HEADER datatype, contains the following attributes.

  • REPLYTO - A Destination supplied by a client when a message is sent
  • TYPE - The type of the message
  • USERID - The identity of the user sending the message
  • APPID - The identity of the application sending the message
  • GROUPID - The identity of the message group of which this message is a part; set by the client
  • GROUPSEQ - The sequence number of the message within the group
  • PROPERTIES - Additional message properties in the SYS.AQ$_JMS_USERPROPARRAY datatype
So you have the header information, the size of the message, then either a VC or a LOB (basically a varchar or a BLOB). To populate the TEXT_LOB, you need to ensure the message exceeds 4000 characters. The example below shows an example on how an xml file is populated within the buffer reader and eventually as a message

Example Below:

package com.aptec.iam.idl.client.produceMessage;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.sql.SQLException;
import java.util.Properties;

import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.TopicConnection;
import javax.naming.InitialContext;

import oracle.jms.AQjmsFactory;
import oracle.jms.AQjmsSession;

public class OracleAQClient {

	static final String xmlFile = "/Users/danielredfern/Documents/workspace/AQProducerAndConsumer/src/com/aptec/iam/idl/client/xmlExamples/identification.xml";
	
	
public static QueueConnection getConnection() {

	
	Properties p = new Properties();
	p.setProperty("java.naming.factory.initial", "weblogic.jndi.WLInitialContextFactory");
	p.setProperty("java.naming.provider.url", "t3://172.16.101.253:7001");
	p.setProperty("java.naming.security.principal", "weblogic");
	p.setProperty("java.naming.security.credentials", "Password1");
	
	InitialContext ctx = null;
	
	try{
		
		ctx = new InitialContext(p);
	}catch(Exception e){
		e.printStackTrace();
	}
	
    String hostname = "172.16.101.253";
    String oracle_sid = "orcl";
    int portno = 1521;
    String userName = "ORACLEAQJMSUSER";
    String password = "ORACLEAQJMSUSER";
    String driver = "thin";
    QueueConnectionFactory QFac = null;
    QueueConnection QCon = null;
    try {
        // get connection factory , not going through JNDI here
        QFac = AQjmsFactory.getQueueConnectionFactory(hostname, oracle_sid, portno, driver);
        // create connection
        QCon = QFac.createQueueConnection(userName, password);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return QCo

The identification.xml file contains characters that exceeds 4000 characters, so the VC becomes a BLOB. This is demonstrated when I query queue table, by using the following command:

select msgid, enq_time, enq_uid, q.user_data from queuetable1 q where q_name = 'AQ_MESSAGE_QUEUE_TABLE'

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

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

IDM ERROR - JDBC repository configured but datasource default was not found

ForgeRockIDMJDBC

May 23, 2017
Created by: Daniel Redfern
IDM ERROR - JDBC repository configured but datasource default was not found
Read More...

OpenIDM Issue - javax.crypto.BadPaddingException: Given final block not properly padded

OpenIDMIDMForgeRockcryptography

May 23, 2017
Created by: Daniel Redfern
org.forgerock.json.JsonException: org.forgerock.json.crypto.JsonCryptoException: javax.crypto.BadPaddingException: Given final block not properly padded
Read More...

Validating CAS service tickets - Client available

CASAuthentication

May 23, 2017
Created by: Daniel Redfern
During the CAS integration for a protected web application, there was always the question on how to see the CAS response once someone has authenticated.
Read More...

HOW TO: Enqueue a JMS_TEXT_MESSAGE from java to Oracle database Queue

AQJMSQueueSQL

February 1, 2017
Created by: Daniel Redfern
In this example, I've quickly highlighted the JMS (Java Message Service) components with a simple POJO (Plain Old Java Object) for an asynchronous oracle database queue as well as constructing a JMS_TEXT_MESSAGE to the queue.
Read More...

Shibboleth SP Issue: opensaml::saml2md::MetadataException

ShibbolethIDPShibboleth-SPSAML2metadata

December 13, 2016
Created by: Daniel Redfern
When integrating the Shibboleth IDP and the Shibboleth SP, I would receive the following saml2 metadata issue

opensaml::saml2md::MetadataException
The system encountered an error at
To report this problem, please contact the site administrator atroot@localhost.
Please include the following message in any email:
opensaml::saml2md::MetadataException at (http://HOSTNAME/secure/)
Unable to locate metadata for identity provider (https://HOSTNAME/idp/shibboleth)

Read More...

Shibboleth CAS Integration: HTTP Status 500 - Error processing ShibCas authentication request

ShibbolethIDPCASAuthentication

December 13, 2016
Created by: Daniel Redfern
You need to integrate Shibboleth IDP 3 with CAS This means that Shibboleth uses CAS as the authentication module to authenticate users. This is a Shibboleth IDP external authentication plugin that delegates to CAS
Read More...

OpenDJ Issue - The search base entry 'dc=example,dc=com' does not exist

OpenDJldapsearchForgeRock

November 2, 2016
Created by: Daniel Redfern
This bugged me for a while though when I installed a default openDJ instance in my local computer for POC purposes, I would get an ldapsearch error response stating that The search base entry 'dc=example,dc=com' does not exist All I was doing was a simple ldapsearch so what was the problem.
Read More...