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 TSNamingContextInterface
protected String
protected String
protected String
protected String
protected jakarta.jms.TextMessage
protected Properties
protected jakarta.jms.QueueConnection
protected jakarta.jms.QueueConnectionFactory
protected jakarta.jms.QueueSender
protected jakarta.jms.Queue
protected jakarta.jms.QueueSession
protected jakarta.jms.TopicConnection
protected jakarta.jms.TopicConnectionFactory
protected long
protected jakarta.jms.TopicPublisher
protected String
protected jakarta.jms.TopicSession
Fields inherited from class com.sun.ts.lib.harness.EETest
err, iLogDelaySeconds, log, sTestCase
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
checkOnResponse
(String TestCase) void
cleanup()
void
Close default connections if openprotected void
createTestMessage
(String TestCase, int num) void
Use this method at cleanup time to remove any messages that have remained on the queue.protected boolean
recvMessageInternal
(jakarta.jms.QueueSession session, String TestCase) void
setup
(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
-