org.jboss.messaging.jms.client
Class JBossConnectionConsumer

java.lang.Object
  extended by 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


Copyright © 2006 JBoss Inc. All Rights Reserved.