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.JMSWorker

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

Field Summary
protected  java.lang.String clientID
           
 Connection (src) connection
           
 MessageConsumer (src) consumer
           
protected  MQBase.MessageCreator (src) creator
           
 Destination (src) destination
           
protected  MQBase.MessageFilter (src) filter
           
protected  int messageHandled
           
protected  int number
           
protected  java.lang.String password
           
 MessageProducer (src) producer
           
protected  MQBase.QosConfig (src) qosConfig
           
protected  java.lang.Exception runEx
           
 Session (src) session
           
protected  boolean stopRequested
           
protected  int transacted
           
protected  int type
           
protected  java.lang.String userName
           
 
Constructor Summary
MQBase.JMSWorker()
          Create one without any settings, use mutators instead.
MQBase.JMSWorker(int type, int transacted, MQBase.MessageCreator (src)  creator, int number)
           
MQBase.JMSWorker(int type, int transacted, MQBase.MessageFilter (src)  filter)
           
 
Method Summary
 void close()
           
abstract  void connect()
           
 void get()
           
 java.lang.Exception getException()
           
 int getMessageHandled()
           
 void onException(JMSException (src)  ex)
          onException handling is only for subscriber.
 void onMessage(Message (src)  msg)
          Passes a message to the listener.
abstract  void publish()
           
abstract  void publish(int nr)
           
 void reset()
           
 void run()
           
 void setClientID(java.lang.String ID)
           
 void setPublisherAttrs(int type, int transacted, MQBase.MessageCreator (src)  creator, int number)
           
 void setQosConfig(MQBase.QosConfig (src)  qosConfig)
           
 void setStoped()
           
 void setSubscriberAttrs(int type, int transacted, MQBase.MessageFilter (src)  filter)
           
 void setUser(java.lang.String userName, java.lang.String password)
           
 void subscribe()
          Subsribes, collects, checking any set filters.
 void subscribe(boolean failsafe)
          Subsribes, collects, checking any set filters.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

stopRequested

protected boolean stopRequested

messageHandled

protected int messageHandled

runEx

protected java.lang.Exception runEx

filter

protected MQBase.MessageFilter (src)  filter

creator

protected MQBase.MessageCreator (src)  creator

number

protected int number

type

protected int type

transacted

protected int transacted

qosConfig

protected MQBase.QosConfig (src)  qosConfig

userName

protected java.lang.String userName

password

protected java.lang.String password

clientID

protected java.lang.String clientID

connection

public Connection (src)  connection

destination

public Destination (src)  destination

session

public Session (src)  session

producer

public MessageProducer (src)  producer

consumer

public MessageConsumer (src)  consumer
Constructor Detail

MQBase.JMSWorker

public MQBase.JMSWorker()
Create one without any settings, use mutators instead. Makes it easier to owerride.

MQBase.JMSWorker

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

MQBase.JMSWorker

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

setSubscriberAttrs

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

setPublisherAttrs

public void setPublisherAttrs(int type,
                              int transacted,
                              MQBase.MessageCreator (src)  creator,
                              int number)

setUser

public void setUser(java.lang.String userName,
                    java.lang.String password)

setClientID

public void setClientID(java.lang.String ID)

publish

public abstract void publish()
                      throws JMSException (src)
Throws:
JMSException (src)

publish

public abstract void publish(int nr)
                      throws JMSException (src)
Throws:
JMSException (src)

subscribe

public void subscribe()
               throws JMSException (src)
Subsribes, collects, checking any set filters. A messageComsumer must be created before calling this.

Throws:
JMSException (src)

subscribe

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

Throws:
JMSException (src)

get

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

connect

public abstract void connect()
                      throws JMSException (src)
Throws:
JMSException (src)

setQosConfig

public void setQosConfig(MQBase.QosConfig (src)  qosConfig)

setStoped

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

getMessageHandled

public int getMessageHandled()

getException

public java.lang.Exception getException()

reset

public void reset()

close

public void close()

onMessage

public void onMessage(Message (src)  msg)
Description copied from interface: MessageListener (src)
Passes a message to the listener.

Specified by:
onMessage in interface MessageListener (src)
Parameters:
msg - the message passed to the listener

onException

public void onException(JMSException (src)  ex)
onException handling is only for subscriber. Will try to to a connect followed by a subscribe

Specified by:
onException in interface ExceptionListener (src)
Parameters:
ex - the JMS exception

run

public void run()
Specified by:
run in interface java.lang.Runnable
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