|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.jms.server.endpoint.ServerConsumerEndpoint
public class ServerConsumerEndpoint
Concrete implementation of ConsumerEndpoint. Lives on the boundary between Messaging Core and the JMS Facade. Handles delivery of messages from the server to the client side consumer.
Method Summary | |
---|---|
boolean |
accept(Message msg)
|
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 |
JBossDestination |
getDestination()
|
ServerSessionEndpoint |
getSessionEndpoint()
|
Delivery |
handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
A receiver can return an active, "done" or null delivery. |
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Method Detail |
---|
public Delivery handle(DeliveryObserver observer, MessageReference ref, Transaction tx)
Receiver
handle
in interface Receiver
observer
- - the component the delivery should be acknowledged to.Delivery
,
DeliveryObserver
public boolean accept(Message msg)
public long closing(long sequence) throws JMSException
Closeable
closing
in interface Closeable
JMSException
public void close() throws JMSException
Closeable
close
in interface Closeable
JMSException
public void changeRate(float newRate) throws JMSException
ConsumerEndpoint
changeRate
in interface ConsumerEndpoint
JMSException
public java.lang.String toString()
toString
in class java.lang.Object
public JBossDestination getDestination()
public ServerSessionEndpoint getSessionEndpoint()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |