No special settings on the DB side. Just a simple queue - but to dispel all doubts I can show you my SQL script creating the queue:
execute DBMS_AQADM.CREATE_QUEUE_TABLE(Queue_table => 'QUELOGENTRYINFO', Queue_payload_type => 'SYS.AQ$_JMS_TEXT_MESSAGE');
execute DBMS_AQADM.CREATE_QUEUE(Queue_name => 'QUELOGENTRY', Queue_table => 'QUELOGENTRYINFO', Max_retries => 5);
execute DBMS_AQADM.START_QUEUE(Queue_name => 'QUELOGENTRY');
I have successfully connected the queue from logstash with the following configuration:
:jndi_name: ConnectionFactory
:jndi_context:
java.naming.factory.initial: oracle.jms.AQjmsInitialContextFactory
java.naming.security.principal: my_user
java.naming.security.credentials: my_password
db_url: 'my_url'
destination => "quelogentry"
My problem can be reduced to the question how to translate these settings to a valid JMS Messaging Modular Input configuration. For now I couldn't find out how I could establish a connection to Oracle AQ.
Hope this gives you a better understanding of my problem.
Best regards,
Andreas
P.S.: May I vote for Java Runtime 1.8 support of the JMS plugin? 😉
... View more