Class Client

java.lang.Object
com.sun.ts.lib.harness.EETest
com.sun.ts.tests.jms.commonee.Client
All Implemented Interfaces:
Serializable

public class Client extends EETest
See Also:
  • Field Details

    • context

      protected TSNamingContextInterface context
    • props

      protected Properties 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

      protected String jmsUser
    • jmsPassword

      protected String jmsPassword
    • hostname

      protected String hostname
    • traceFlag

      protected String traceFlag
    • logPort

      protected String logPort
    • msg

      protected jakarta.jms.TextMessage msg
    • timeout

      protected long timeout
  • Constructor Details

    • Client

      public Client()
  • Method Details

    • setup

      public void setup(String[] args, Properties p) throws Exception
      Throws:
      Exception
    • createTestMessage

      protected void createTestMessage(String TestCase, int num)
    • checkOnResponse

      public boolean checkOnResponse(String TestCase)
    • recvMessageInternal

      protected boolean recvMessageInternal(jakarta.jms.QueueSession session, String TestCase) throws jakarta.jms.JMSException
      Throws:
      jakarta.jms.JMSException
    • cleanup

      public void cleanup() throws Exception
      Throws:
      Exception
    • flushQueue

      public void flushQueue() throws Exception
      Use this method at cleanup time to remove any messages that have remained on the queue.
      Throws:
      Exception
    • closeDefaultConnections

      public void closeDefaultConnections() throws Exception
      Close default connections if open
      Throws:
      Exception