I want to set a gattling test case to keep messages on Oracle AQ. But I do not know how to set up the following:
val jmsConfig = jms .connectionFactoryName (???) .url ("tcp: // localhost: 10002"). Credential "user", "secret"). Contextfacture (???) .listenerCount (1) .usePersistentDeliveryMode
What is the connection factory name and what is the reference factory?
I sent it to oracle.jms.AQjmsInitialContextFactory oracle.jms.AQjmsFactory is not an InitialContextFactory managed to work, so that it does not work.
Be sure to add at least version 11+ of Oracle AQ dependency to AQjmsInitialContextFactory.
You must obtain a qualified privilege for the database user. Insert the messages in the queue (table)
Goting is expected of you request-answer semantics, so get the answer Will wait to do I really wanted to stop waiting for a reply after a certain period, but I have no clue how to do this, so if anyone knows how to know, please tell me: -)
MySimulation.Scala
val jmsConfig = jms .connectionFactoryName ("ConnectionFactory") // Sure !!!! The ConnectionFactory, AQjmsFactory is expected of this naming convention! . ("Jdbc: oracle: thin: @host: 1521: sid"). Credentials ("user", "password"). Contextfactor ("oracle.jms.AQjmsInitialContextFactory") .listenerCount (1) .usPersistentDeliveryMode // TODO Answer How to set a timeout on the jmsscenario = scenario ("JMS DSL Test"). Recurring (1) {exec (jms ("req answer test") .reqreply .ac ("AQ_ADMIN.QUEUE_NAME") .text message ("some messages"). (General check (checkbox text correction)) Def checkout text Correction (M: message) = {// believes that the service only transmits an "uppercase" text M match {case TM: text message => .tm.getText == "Text that is in reply message Should "case_ = & gt; false}} setup (jmsScenario.inject (once user (1)) protocol (jmcconfig));
jndi.propertie S
I had to add jndi.properties to Classpath:
Db_url = jdbc: oracle: thin: @host: 1521: sid
pom.xml
Dependencies (Mewen):
Dependency & gt; & Gt; Oracle & lt; / group & gt; & lt; artifactId & gt; aqapi & lt; / artifactId> & lt; version & gt; 11.2.0.3 & lt; / version & gt; & lt; / Dependence> gt; Dependency & gt; & lt; Group & gt; com.oracle & lt; / group & gt; & Lt; ArtifactId & gt; Ojdbc6 & lt; / ArtifactId> & Lt; Version & gt; 11.2.0.2.0 & lt; / Edition & gt; & Lt; / Dependencies & gt; & Lt; Dependency & gt; & Lt; Group & gt; Javax.transaction & lt; / Group & gt; & Lt; ArtifactId & gt; JTA & lt; / ArtifactId> & Lt; Version & gt; 1.1 & lt; / Edition & gt; & Lt; / Dependencies & gt;
No comments:
Post a Comment