org.jboss.messaging.jms.client
Class JBossConnectionConsumer

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

All Implemented Interfaces:

java.lang.Runnable, javax.jms.ConnectionConsumer

public class JBossConnectionConsumer
extends java.lang.Object
implements javax.jms.ConnectionConsumer, java.lang.Runnable

This class implements javax.jms.ConnectionConsumer

Version:

$Revision: 3799 $ $Id: JBossConnectionConsumer.java 3799 2008-02-26 10:20:51Z timfox $

Author:

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

Constructor Summary

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

Method Summary

void	close()
protected void	doClose()
javax.jms.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(ClientConnection conn,
                               JBossDestination dest,
                               java.lang.String subName,
                               java.lang.String messageSelector,
                               javax.jms.ServerSessionPool sessPool,
                               int maxMessages)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

getServerSessionPool

public javax.jms.ServerSessionPool getServerSessionPool()
                                                 throws javax.jms.JMSException

Specified by:

getServerSessionPool in interface javax.jms.ConnectionConsumer

Throws:

javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.ConnectionConsumer

Throws:

javax.jms.JMSException

run

public void run()

Specified by:

run in interface java.lang.Runnable

doClose

protected void doClose()
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object