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

org.jboss.test.jbossmq
Class MQBase.QueueWorker

java.lang.Object
  extended byorg.jboss.test.jbossmq.MQBase.JMSWorker (src) 
      extended byorg.jboss.test.jbossmq.MQBase.QueueWorker
All Implemented Interfaces:
ExceptionListener (src) , MessageListener (src) , java.lang.Runnable
Enclosing class:
MQBase (src)
public class MQBase.QueueWorker
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.QueueWorker()
          If using this, use mutators to add attrs.
MQBase.QueueWorker(int type, int transacted, MQBase.MessageCreator (src)  creator, int number)
           
MQBase.QueueWorker(int type, int transacted, MQBase.MessageFilter (src)  filter)
           
 
Method Summary
 java.util.Enumeration browse()
           
 void connect()
           
 void get()
           
 void publish()
           
 void publish(int nr)
           
 void subscribe()
          Subsribes, collects, checking any set filters.
 void subscribe(boolean failsafe)
          Subsribes, collects, checking any set filters.
 
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, toString, wait, wait, wait
 

Constructor Detail

MQBase.QueueWorker

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

MQBase.QueueWorker

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

MQBase.QueueWorker

public MQBase.QueueWorker(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)

browse

public java.util.Enumeration browse()
                             throws JMSException (src)
Throws:
JMSException (src)
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD