169 questions
0
votes
0
answers
34
views
OracleAQ: JMS_OracleDelay settings
When I use a JMS message producer with OracleAQ to send a message with JMS_OracleDelay
message.setIntProperty("JMS_OracleDelay", 10)
I see the the underlying AQ table add the correct DELAY ...
0
votes
0
answers
82
views
Dequeue from the exception queue and put it back to regular queue
I'm using Oracle AQs and what I'm having is some messages in the exception queue and I would like to move them back to the regular queue. As you may know, exception queues in Oracle and special, some ...
0
votes
0
answers
119
views
Slow message delivery in Java application using Oracle Advanced Queue
I have a Java application that connects to Oracle Advanced Queue (AQ) and listens for various event types. The Java server and the Oracle server are on different machines but within the same data ...
1
vote
1
answer
90
views
JMS application unable to consume from Oracle Sharded Queue
We have a system that successfully send messages across a normal, non-sharded Oracle Advanced Queue (AQ), but when we change to a Sharded Queue, the Java application is unable to consume the messages. ...
0
votes
1
answer
506
views
Spring boot with Oracle AQ and Universal Connection Pool
I am using Oracle AQ with spring boot with as follows:
Gradle dependency:
implementation "com.oracle.database.spring:oracle-spring-boot-starter-aqjms:23.4.0"
JmsConfiguration:
@...
0
votes
1
answer
174
views
Oracle AQ - Multiple JMS Listeners to dequeue a specific custom 'message type'- is this possible?
I have an Oracle 19 Database in which I planned to leverage Oracle AQ for its queueing capabilities.
During a flow, a message will be created. Messages can be either of "type A" or "...
2
votes
0
answers
104
views
Read Oracle AQ message from Java with RAW type
I was trying to read RAW type AQ message from java application. But I'm getting error.
java.lang.NullPointerException: Cannot invoke "String.equalsIgnoreCase(String)" because "<...
2
votes
0
answers
95
views
Oracle AQ and .Net core - How to be notified that a message is available?
Im having a bit of difficulty in creating worker service that will continuously read a AQ…
my expectation is:
Open Connection
Create a Queue Object
Hookup the “myqueue.MessageAvaiable” event
Call “...
1
vote
1
answer
242
views
Sequential processing of logically grouped messages in Oracle AQ by multiple consumers
I have a spring-boot service using Oracle AQ. The service receives http-requests, enqueues request bodies as message into Oracle AQ, then dequeues it and sends to the destination services via http, so ...
0
votes
1
answer
51
views
Publishing outgoing messages with Helidon and Oracle AQ
I have the following class that supposed to send messages to Oracle AQ defined application.yml.
@ApplicationScoped
public class BaseAQClient{
private static final Logger logger = LoggerFactory....
3
votes
0
answers
418
views
Read messages from Oracle AQ with custom ADT payload
I am trying to read messages from an Oracle Queue that has custom ADT payload (not simple text messaging) using a simple spring cloud stream project. I am having difficulties doing this with spring, ...
1
vote
0
answers
170
views
Spring-Jms DefaultMessageListenerContainer ADT payloads Issue
I am working on a Springboot (1.5.14.RELEASE) and I upgraded that to Springboot 3.3.2.
I have an oracleAQ queue and I was using XmlMessageListenerContainer (Because my payloadtype is "SYS".&...
1
vote
1
answer
134
views
Error in executing task: 'javax.jms.Session javax.jms.Connection.createSession(boolean, int)
I followed this blog and tried to configure Oracle AQ with WSO2 Micro Integrator 4.2.0. There I created proxy service and inbound endpoint as explined in the blog. But I'm getting the below error.
...
0
votes
0
answers
85
views
ERROR when trying to configure Oracle AQ with WSO2 Micro Integrator
I'm trying to configure Oracle AQ with WSO2 Micro Integrator 4.2.0. I created oracle Queue and I was able to send and messages there. Howver when I tried to configure it with WSO2 MI and trying to ...
3
votes
1
answer
1k
views
Large numbers of warnings generated by suspected JDBC driver issue using Oracle 19c
Note: Oracle has now released a fix for this issue. See in comments below.
Overview
We are getting warnings in our database logs that seem to be caused by the following statements:
1) BEGIN :1 := ...
0
votes
0
answers
335
views
Oracle Advanced Queuing Service via Node.js -- dequeue a Message Gives Error Message Error: ORA-25215: user_data type and queue type do not match
I get the following message when trying to dequeue a message in a Node.js program. I am using node-oracledb Version 5.5.0. The documentation says that this is an error for enqueueing a message. The ...
0
votes
1
answer
1k
views
SpringBoot 3.x upgrade: AQjmsFactory version compatibility issue with Jakarta namespace
While upgrading to the latest SpringBoot versions from 2.x to 3.x, I have encountered that there is version compatibility issue for Oracle Advance queue "AQjmsFactory" with Jakarta.jms ...
1
vote
1
answer
97
views
Helidon AQ connector does not throw error on database connection reset
I am working on helidon SE service where AQ connector is being used. The service is registered as listener/subscriber to a multi-consumer queue. If database connection is reset due to db restart, AQ ...
0
votes
0
answers
354
views
Asynchronous listening of JMS Message from Oracle AQ - Buffered Queue not working
I've written a sample application for a producer and consumer scenario using an Oracle AQ "buffered" queue. From the producer I am able to send the message to the buffered queue. I have ...
3
votes
2
answers
3k
views
Oracle Advanced Queuing and Jakarta namespace
I am using Oracle AQ in my Java Spring Boot application. I have Oracle JMS implementation AQAPI as dependencies.
Recently I had tried to update the application to Spring Boot 3.x which is build on ...
0
votes
1
answer
1k
views
Oracle AQ. Error ORA-25263: no message in queue when dequeue message
I want to dequeue message with message id from my queue table, but I get error that ORA-25263: no message in queue OPERATION_QUEUE with message ID DBF9DE01CB5C0DA7E0550000FF000001
How I can dequeue ...
0
votes
1
answer
570
views
JMS with Oracle AQ. How to change delay of JMS Message when it's already in the queue?
If is it possible change delay of JMS Message when it's already in the queue?
When I send message via JMS, I set jmsMessage.setIntProperty("JMS_OracleDelay", 120). Then this jmsMessage ...
1
vote
0
answers
176
views
Oracle AQ/JMS - Why is the queue being purged on application shutdown?
I have an application that queues and deques messages from Oracle AQ using the JMS interface. When the application is running items get queued and dequeued and I can see queued items in the queue ...
1
vote
1
answer
354
views
DBMS_AQ.ENQUEUE_ARRAY causes internal ArrayIndexOutOfBoundsException in Oracle JDBC driver
Given:
create TYPE things IS VARRAY(1) OF THING_TYP NOT NULL;
and an Oracle AQ queue table, and a queue FOO_BAR, calling DBMS_AQ.ENQUEUE_ARRAY using a JDBC CallableStatement results in an ...
0
votes
1
answer
264
views
Oracle Advance Queue and Java: Able to send message through code but not able to see in queue table
Tried to send a message to the queue using the Java Code available on the Oracle website.
The code ran successfully but I can't see any record in the db.
static String myJson =
&...
-1
votes
1
answer
2k
views
Oracle Advanced Queue, Java and Maven : unable to find valid certification path to requested target
Not getting in any project and even jdbc dependency:
First time tried project using Oracle Advanced Queue in Maven and got following error
Failed to collect dependencies at com.oracle:aqapi:jar:11.2.0....
0
votes
1
answer
168
views
Jms: Pub/Sub with mutiple consumers
For JMS pub/sub with a topic and two durable subscribers, in most cases when a message is sent to the topic we want the message to be consumed by both subscribers.
But in a particular scenario we may ...
3
votes
0
answers
825
views
How to access an Oracle queue with another user?
I have a schema that owns some queues and an application that connects to that schema and uses the queues. For security reasons I want to create a user schema that can access the queue and I want the ...
0
votes
1
answer
550
views
How to create a queue user in oracle?
I have a QUEUE_OWNER schema that has some queues. When I connect the application to that data source everything works fine and the app can read the from the queues.
I want to create a _USER schema ...
-1
votes
1
answer
144
views
I'm trying send pl/sql command in to oracleAQ
I am trying send pl/sql command to oracle, but i have no idea how I can do that. There is no select or insert only work with oracle AQ. So, Maybe someone have experience with that situation? Any idea'...
1
vote
1
answer
604
views
How do I grant CLOB privileges to a foreign queue user in Oracle Advanced Queuing?
We grant the following priviliges on schema A to user B for inserting into a queue in Oracle 12c:
GRANT CREATE SESSION TO &UNAME_ENQUEUE;
GRANT EXECUTE ON SYS.DBMS_AQ TO &UNAME_ENQUEUE;
GRANT ...
1
vote
0
answers
865
views
Oracle AQ competing consumer
So I am fairly new to Oracle, certainly no Oracle master
However I have used queues a lot before. I have been told that Oracle AQ supports this feature which seems to fly in the face of everything I ...
0
votes
1
answer
864
views
Can't enqueue large text messages onto Oracle AQ via JMS client - ORA-00942: table or view does not exist
I am enqueuing JSON messages onto Oracle AQ on the JVM via the JMS client. This is working fine for small text messages but is failing for larger messages. I believe that this is something to do with ...
0
votes
1
answer
686
views
JMS Text Message on Oracle AQ from Nodejs
I'm trying to enqueue a jms text message on oracle AQ from nodejs.
const enqueue = async () => {
try {
await oracle.createPool();
const connection = await oracle.getConnection();...
0
votes
2
answers
3k
views
jboss eap error org.jboss.jca.adapters.jdbc.jdk8.WrappedConnectionJDK8 cannot be cast to oracle.jdbc.internal.OracleConnection
I'm developing camel route to connect to Oracle AQ on Jboss EAP Fuse.
I managed to do it using the connection factory as follows:
<bean class="org.apache.camel.component.jms.JmsComponent" ...
2
votes
1
answer
1k
views
How to join multiple consumers oracle AQ queue to regular queue? What am I doing wrong?
I tried to develop queueing mechanism for our application. My idea is to prepare standard solution where there is one application (app0) producing events and one or more applications (app1, app2) ...
0
votes
1
answer
1k
views
Oracle AQ c# and dequeueing a message from oracle queue in c#
I am using Oracle 12.01, ODP.NET x64, version 4, and referencing Oracle.DataAccess.dll in .net framework 4.6.
Problem appears when I try to dequeue a message in visual studio. My user has granted ...
0
votes
0
answers
107
views
Generated CONSUMER_NAME on each start
I have spring-jms integrated with multi-consumer Oracle Advanced Queue and each time that the application is started, adds a new consumer with name TSUB_1_[RANDOM] like TSUB_1_9FA550C4DC828DA9E05347F.
...
0
votes
1
answer
512
views
How to stop getting messages deleted without acknowledgement in Oracle AQ?
I have set up a single customer Oracle AQ. I observe messages from this queue in a Java web application with CLIENT_ACKNOWLEDGE mode. But as soon as I receive the messages in the onMessage method, the ...
1
vote
0
answers
2k
views
Dequeue the exception queue in ORACLE AQ
I am new to the Oracle AQ process and have a few questions about the exception queue. Here's my scenario:
Oracle Database 19c Enterprise Edition Release 19.0.0.0.0
Create Table and Queue:
BEGIN
...
0
votes
1
answer
2k
views
Camel consuming message from queue but fails to recreate it
I have a problem where my counterpart is placing messages on a JMS TEXT queue on Oracle (some custom application not using java) and I am to pick it up. The route is very simple:
<!--Receive data ...
0
votes
0
answers
203
views
oracle.AQ.AQOracleSQLException: Invalid column type
I am trying to invoke DBMS_AQ through java but getting following exception while invoking enqueue method.(Spring boot). While enqueing I am using a entity made in java which is similar to the dbms ...
1
vote
1
answer
421
views
How to increase the performance of a Spring Batch that read data from an Oracle AQ?
I have a Spring Batch code that read (dequeue) data from an Oracle AQ.
But to read only 100 rows, it takes 4 minutes!!
What it can be the problem with this reader? ¿How can i improve the ...
0
votes
2
answers
2k
views
How to tell if a JMS queue is started or stopped?
I have a Java service which is getting messages from an Oracle Advanced Queue. I can create the connection and listen and get messages OK. I can see that you can stop and start listening for ...
3
votes
1
answer
4k
views
Query to check if Oracle AQ is started or stopped
I have executed following command to start a user queue.
BEGIN
DBMS_AQADM.START_QUEUE('MY_USER.MY_QUEUE');
END;
Is it possible to check and confirm if this Queue is started or stopped using a ...
0
votes
0
answers
296
views
how to monitor/listen oracle table for any insert/updates using Oracle AQ and java
I need to monitor one table in my Oracle database for any insert/updates using Oracle Advanced Queue and Java.
Note: The table usually gets 10000 inserts/updates per minute in production env.
Can ...
0
votes
1
answer
2k
views
JMS Connection constantly "session is closed" on our oracle queues
We are using spring boot to run our queue polling program.
The queue is being polled about every 2 mins, and every 2 mins the session is closed, then refreshed.
The connection is a shared connection ...
0
votes
1
answer
2k
views
PL/SQL for deqeueu and enqueue in ORACLE
im really new to coding (a few days).I would like to ask you for a help with my problem/idea.
im having .SQL script for re-enqueue of expired messages.
DECLARE
v_en_options DBMS_AQ....
3
votes
1
answer
3k
views
ORA-00932: inconsistent datatypes: expected SYS.AQ$_JMS_TEXT_MESSAGE got SYS.AQ$_JMS_TEXT_MESSAGE
With newer version of Oracle DB (12.2.0.1) we start to receive ORA-00932, for the code which works well with older DB server.
Moreover the driver reports strange detail of exception:
ORA-00932: ...
0
votes
2
answers
3k
views
Oracle : Send latest insert/update to JMS
I have an insert/update trigger for a Oracle table.
Is there a way to send the details of the affected row(all columns) as a message to JMS?
I can write a Java Program, 'loadjava' that and call from ...