org.jboss.messaging.core.server
Interface ServerConsumer
- All Superinterfaces:
- Consumer
- All Known Implementing Classes:
- ServerConsumerImpl
public interface ServerConsumer
- extends Consumer
A ServerConsumer
- Author:
- Tim Fox
getID
long getID()
close
void close()
throws java.lang.Exception
- Throws:
java.lang.Exception
getCountOfPendingDeliveries
int getCountOfPendingDeliveries()
cancelRefs
java.util.List<MessageReference> cancelRefs(boolean lastConsumedAsDelivered,
Transaction tx)
throws java.lang.Exception
- Throws:
java.lang.Exception
setStarted
void setStarted(boolean started)
receiveCredits
void receiveCredits(int credits)
throws java.lang.Exception
- Throws:
java.lang.Exception
getQueue
Queue getQueue()
getExpired
MessageReference getExpired(long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
acknowledge
void acknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
failedOver
void failedOver()
deliverReplicated
void deliverReplicated(long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
lock
void lock()
unlock
void unlock()
Copyright © 2006 JBoss Inc. All Rights Reserved.