Package com.sun.ts.tests.jms.commonee
Class Client
java.lang.Object
com.sun.ts.lib.harness.EETest
com.sun.ts.tests.jms.commonee.Client
- All Implemented Interfaces:
Serializable
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class com.sun.ts.lib.harness.EETest
EETest.Fault, EETest.SetupException -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected TSNamingContextInterfaceprotected Stringprotected Stringprotected Stringprotected Stringprotected jakarta.jms.TextMessageprotected Propertiesprotected jakarta.jms.QueueConnectionprotected jakarta.jms.QueueConnectionFactoryprotected jakarta.jms.QueueSenderprotected jakarta.jms.Queueprotected jakarta.jms.QueueSessionprotected jakarta.jms.TopicConnectionprotected jakarta.jms.TopicConnectionFactoryprotected longprotected jakarta.jms.TopicPublisherprotected Stringprotected jakarta.jms.TopicSessionFields inherited from class com.sun.ts.lib.harness.EETest
err, iLogDelaySeconds, log, sTestCase -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleancheckOnResponse(String TestCase) voidcleanup()voidClose default connections if openprotected voidcreateTestMessage(String TestCase, int num) voidUse this method at cleanup time to remove any messages that have remained on the queue.protected booleanrecvMessageInternal(jakarta.jms.QueueSession session, String TestCase) voidsetup(String[] args, Properties p) Methods inherited from class com.sun.ts.lib.harness.EETest
getPropsReady, getTestPropsFromArgs, initializeProperties, logErr, logErr, logMsg, logTrace, logTrace, run, run, run, run, runAllTestCases, setTestStatus
-
Field Details
-
context
-
props
-
rcvrQueue
protected jakarta.jms.Queue rcvrQueue -
qConnect
protected jakarta.jms.QueueConnection qConnect -
session
protected jakarta.jms.QueueSession session -
qFactory
protected jakarta.jms.QueueConnectionFactory qFactory -
qSender
protected jakarta.jms.QueueSender qSender -
tConnect
protected jakarta.jms.TopicConnection tConnect -
tSession
protected jakarta.jms.TopicSession tSession -
tFactory
protected jakarta.jms.TopicConnectionFactory tFactory -
tPub
protected jakarta.jms.TopicPublisher tPub -
jmsUser
-
jmsPassword
-
hostname
-
traceFlag
-
logPort
-
msg
protected jakarta.jms.TextMessage msg -
timeout
protected long timeout
-
-
Constructor Details
-
Client
public Client()
-
-
Method Details
-
setup
- Throws:
Exception
-
createTestMessage
-
checkOnResponse
-
recvMessageInternal
protected boolean recvMessageInternal(jakarta.jms.QueueSession session, String TestCase) throws jakarta.jms.JMSException - Throws:
jakarta.jms.JMSException
-
cleanup
- Throws:
Exception
-
flushQueue
Use this method at cleanup time to remove any messages that have remained on the queue.- Throws:
Exception
-
closeDefaultConnections
Close default connections if open- Throws:
Exception
-