com.latencybusters.jms
Class LBMMessageConsumer

java.lang.Object
  com.latencybusters.jms.LBMMessageConsumer

All Implemented Interfaces:

javax.jms.MessageConsumer

Direct Known Subclasses:

LBMQueueReciever, UMEMessageConsumer

public class LBMMessageConsumer
extends java.lang.Object
implements javax.jms.MessageConsumer

Field Summary

protected int	acknowledgeMode
protected java.lang.String	cfName
protected com.latencybusters.lbm.LBMEventQueue	evq
protected javax.jms.MessageListener	listener
protected java.lang.String	messageSelector
protected com.latencybusters.lbm.LBMContext	myContext
protected int	rcvCreationDelay
protected boolean	transacted

Constructor Summary

LBMMessageConsumer()

LBMMessageConsumer(com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, LBMDestination destination, boolean isActive, int acknowledgeMode, LBMSession session, boolean transacted, java.lang.String cfName, java.lang.String messageSelector)
This is an internal Method.

Method Summary

void	acked(LBMMessage m)
void	addTransaction(LBMMessage msg)
void	addUnAckedMessage(LBMMessage m)
void	close()
void	commit()
com.latencybusters.lbm.LBMConfigOption[]	dumpAttributeList()
int	getDefaultMessageProp()
javax.jms.MessageListener	getMessageListener()
java.lang.String	getMessageSelector() This method has not been implemented.
java.lang.String	getName()
protected LBMSession	getSession()
protected void	init()
boolean	isActive()
boolean	isOpen()
boolean	isTransacted()
protected void	logReceiverConfigOptions(com.latencybusters.lbm.LBMConfigOption[] options)
protected void	printAttr(com.latencybusters.lbm.LBMReceiverAttributes sattr)
javax.jms.Message	receive()
javax.jms.Message	receive(long timeout)
javax.jms.Message	receiveNoWait()
protected void	removeCallback()
void	rollback()
void	setMessageListener(javax.jms.MessageListener listener)
void	setTransacted(boolean transacted)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

listener

protected javax.jms.MessageListener listener

myContext

protected com.latencybusters.lbm.LBMContext myContext

evq

protected com.latencybusters.lbm.LBMEventQueue evq

acknowledgeMode

protected int acknowledgeMode

transacted

protected boolean transacted

cfName

protected java.lang.String cfName

rcvCreationDelay

protected int rcvCreationDelay

messageSelector

protected java.lang.String messageSelector

Constructor Detail

LBMMessageConsumer

public LBMMessageConsumer()

LBMMessageConsumer

public LBMMessageConsumer(com.latencybusters.lbm.LBMContext myContext,
                          com.latencybusters.lbm.LBMEventQueue evq,
                          java.util.ArrayList<NameValue> props,
                          LBMDestination destination,
                          boolean isActive,
                          int acknowledgeMode,
                          LBMSession session,
                          boolean transacted,
                          java.lang.String cfName,
                          java.lang.String messageSelector)
                   throws javax.jms.JMSException

This is an internal Method.

Throws:

javax.jms.JMSException

Method Detail

init

protected void init()
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

commit

public void commit()

rollback

public void rollback()
              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isActive

public boolean isActive()

isOpen

public boolean isOpen()

start

public void start()
           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

stop

public void stop()

addUnAckedMessage

public void addUnAckedMessage(LBMMessage m)

acked

public void acked(LBMMessage m)

removeCallback

protected void removeCallback()

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()

Specified by:

getMessageListener in interface javax.jms.MessageConsumer

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException

This method has not been implemented.

Specified by:

getMessageSelector in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

receive

public javax.jms.Message receive(long timeout)
                          throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException

Specified by:

receiveNoWait in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)

Specified by:

setMessageListener in interface javax.jms.MessageConsumer

getName

public java.lang.String getName()

getSession

protected LBMSession getSession()

printAttr

protected void printAttr(com.latencybusters.lbm.LBMReceiverAttributes sattr)

logReceiverConfigOptions

protected void logReceiverConfigOptions(com.latencybusters.lbm.LBMConfigOption[] options)

dumpAttributeList

public com.latencybusters.lbm.LBMConfigOption[] dumpAttributeList()

isTransacted

public boolean isTransacted()

Returns:

the transacted

setTransacted

public void setTransacted(boolean transacted)

Parameters:

transacted - the transacted to set

addTransaction

public void addTransaction(LBMMessage msg)

getDefaultMessageProp

public int getDefaultMessageProp()