org.jboss.messaging.core.server.impl
Class ServerConsumerImpl

java.lang.Object
  extended by org.jboss.messaging.core.server.impl.ServerConsumerImpl
All Implemented Interfaces:
Consumer, ServerConsumer

public class ServerConsumerImpl
extends java.lang.Object
implements ServerConsumer

Concrete implementation of a ClientConsumer.

Version:
$Revision: 3783 $ $Id: ServerConsumerImpl.java 3783 2008-02-25 12:15:14Z timfox $
Author:
Tim Fox, Jeff Mesnil Partially derived from JBM 1.x version by:, Ovidiu Feodorov, Tim Fox

Method Summary
 void close()
           
 long getClientTargetID()
           
 long getID()
           
 HandleStatus handle(MessageReference ref)
           
 void receiveCredits(int credits)
           
 void setStarted(boolean started)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Method Detail

getID

public long getID()
Specified by:
getID in interface ServerConsumer

getClientTargetID

public long getClientTargetID()
Specified by:
getClientTargetID in interface ServerConsumer

handle

public HandleStatus handle(MessageReference ref)
                    throws java.lang.Exception
Specified by:
handle in interface Consumer
Throws:
java.lang.Exception

close

public void close()
           throws java.lang.Exception
Specified by:
close in interface ServerConsumer
Throws:
java.lang.Exception

setStarted

public void setStarted(boolean started)
Specified by:
setStarted in interface ServerConsumer

receiveCredits

public void receiveCredits(int credits)
                    throws java.lang.Exception
Specified by:
receiveCredits in interface ServerConsumer
Throws:
java.lang.Exception

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object


Copyright © 2006 JBoss Inc. All Rights Reserved.