org.jboss.jms.client
Class JBossConnectionConsumer

java.lang.Object
  org.jboss.jms.client.JBossConnectionConsumer

All Implemented Interfaces:

java.lang.Runnable

public class JBossConnectionConsumer

extends java.lang.Object

implements java.lang.Runnable

This class implements javax.jms.ConnectionConsumer

Version:

$Revision: 2684 $ $Id: JBossConnectionConsumer.java 2684 2007-05-15 07:31:30Z timfox $

Author:

Tim Fox, Ovidiu Feodorov Partially based on JBossMQ version by:, Hiram Chirino (Cojonudo14@hotmail.com), Adrian Brock

Constructor Summary

JBossConnectionConsumer(ConnectionDelegate conn, JBossDestination dest, java.lang.String subName, java.lang.String messageSelector, ServerSessionPool sessPool, int maxMessages)

Method Summary

void	close()
protected void	doClose()
ServerSessionPool	getServerSessionPool()
void	run()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

JBossConnectionConsumer

public JBossConnectionConsumer(ConnectionDelegate conn,
                               JBossDestination dest,
                               java.lang.String subName,
                               java.lang.String messageSelector,
                               ServerSessionPool sessPool,
                               int maxMessages)
                        throws JMSException

Method Detail

getServerSessionPool

public ServerSessionPool getServerSessionPool()
                                       throws JMSException

Throws:

JMSException

close

public void close()
           throws JMSException

Throws:

JMSException

run

public void run()

Specified by:

run in interface java.lang.Runnable

doClose

protected void doClose()
                throws JMSException

Throws:

JMSException

toString

public java.lang.String toString()