org.jboss.jms.server.endpoint.advised
Class ConsumerAdvised

java.lang.Object
  org.jboss.jms.server.endpoint.advised.AdvisedSupport
      org.jboss.jms.server.endpoint.advised.ConsumerAdvised

All Implemented Interfaces:

Closeable, ConsumerEndpoint

public class ConsumerAdvised
extends AdvisedSupport
implements ConsumerEndpoint

The server-side advised instance corresponding to a Consumer. It is bound to the AOP Dispatcher's map.

Version:

$Revision: 3174 $ $Id: ConsumerAdvised.java 3174 2007-10-05 15:14:57Z timfox $

Author:

Tim Fox, Ovidiu Feodorov

Field Summary

protected ConsumerEndpoint

endpoint

Constructor Summary

ConsumerAdvised(ConsumerEndpoint endpoint)

Method Summary

void	changeRate(float newRate) Sent to the server to specify a new maximum rate at which to send messages at
void	close() Close the instance
long	closing(long sequence) Tell the instance to prepare to close
boolean	equals(java.lang.Object obj)
java.lang.Object	getEndpoint()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

endpoint

protected ConsumerEndpoint endpoint

Constructor Detail

ConsumerAdvised

public ConsumerAdvised(ConsumerEndpoint endpoint)

Method Detail

close

public void close()
           throws JMSException

Description copied from interface: Closeable

Close the instance

Specified by:

close in interface Closeable

Throws:

JMSException

closing

public long closing(long sequence)
             throws JMSException

Description copied from interface: Closeable

Tell the instance to prepare to close

Specified by:

closing in interface Closeable

Throws:

JMSException

changeRate

public void changeRate(float newRate)
                throws JMSException

Description copied from interface: ConsumerEndpoint

Sent to the server to specify a new maximum rate at which to send messages at

Specified by:

changeRate in interface ConsumerEndpoint

Throws:

JMSException

getEndpoint

public java.lang.Object getEndpoint()

Specified by:

getEndpoint in class AdvisedSupport

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object