Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.jboss.test.jbossmq
Class MQBase.TopicWorker

java.lang.Object
  extended byorg.jboss.test.jbossmq.MQBase.JMSWorker (src) 
      extended byorg.jboss.test.jbossmq.MQBase.TopicWorker
All Implemented Interfaces:
ExceptionListener (src) , MessageListener (src) , java.lang.Runnable
Direct Known Subclasses:
MassiveTest.FailingSubWorker (src)
Enclosing class:
MQBase (src)
public class MQBase.TopicWorker
extends MQBase.JMSWorker (src)

Field Summary
 
Fields inherited from class org.jboss.test.jbossmq.MQBase.JMSWorker (src)
clientID, connection, consumer, creator, destination, filter, messageHandled, number, password, producer, qosConfig, runEx, session, stopRequested, transacted, type, userName
 
Constructor Summary
MQBase.TopicWorker()
          If using this, use mutators to add attrs.
MQBase.TopicWorker(int type, int transacted, MQBase.MessageCreator (src)  creator, int number)
           
MQBase.TopicWorker(int type, int transacted, MQBase.MessageFilter (src)  filter)
           
 
Method Summary
 void connect()
           
 void get()
           
 void publish()
           
 void publish(int nr)
           
 void setDurable(java.lang.String handle)
           
 void setDurable(java.lang.String userId, java.lang.String pwd, java.lang.String handle)
           
 void subscribe()
          Subsribes, collects, checking any set filters.
 void subscribe(boolean failsafe)
          Subsribes, collects, checking any set filters.
 java.lang.String toString()
           
 void unsubscribe()
           
 
Methods inherited from class org.jboss.test.jbossmq.MQBase.JMSWorker (src)
close, getException, getMessageHandled, onException, onMessage, reset, run, setClientID, setPublisherAttrs, setQosConfig, setStoped, setSubscriberAttrs, setUser
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MQBase.TopicWorker

public MQBase.TopicWorker()
If using this, use mutators to add attrs.

MQBase.TopicWorker

public MQBase.TopicWorker(int type,
                          int transacted,
                          MQBase.MessageFilter (src)  filter)

MQBase.TopicWorker

public MQBase.TopicWorker(int type,
                          int transacted,
                          MQBase.MessageCreator (src)  creator,
                          int number)
Method Detail

publish

public void publish()
             throws JMSException (src)
Specified by:
publish in class MQBase.JMSWorker (src)
Throws:
JMSException (src)

publish

public void publish(int nr)
             throws JMSException (src)
Specified by:
publish in class MQBase.JMSWorker (src)
Throws:
JMSException (src)

subscribe

public void subscribe()
               throws JMSException (src)
Description copied from class: MQBase.JMSWorker (src)
Subsribes, collects, checking any set filters. A messageComsumer must be created before calling this.

Overrides:
subscribe in class MQBase.JMSWorker (src)
Throws:
JMSException (src)

subscribe

public void subscribe(boolean failsafe)
               throws JMSException (src)
Description copied from class: MQBase.JMSWorker (src)
Subsribes, collects, checking any set filters. A messageComsumer must be created before calling this. If arg set to true, do a failsafe sub

Overrides:
subscribe in class MQBase.JMSWorker (src)
Throws:
JMSException (src)

get

public void get()
         throws JMSException (src)
Overrides:
get in class MQBase.JMSWorker (src)
Throws:
JMSException (src)

connect

public void connect()
             throws JMSException (src)
Specified by:
connect in class MQBase.JMSWorker (src)
Throws:
JMSException (src)

setDurable

public void setDurable(java.lang.String userId,
                       java.lang.String pwd,
                       java.lang.String handle)

setDurable

public void setDurable(java.lang.String handle)

unsubscribe

public void unsubscribe()
                 throws JMSException (src)
Throws:
JMSException (src)

toString

public java.lang.String toString()
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD