org.apache.activemq.artemis.core.server

Interface ServerConsumer

All Superinterfaces:

Consumer

All Known Implementing Classes:

ServerConsumerImpl

public interface ServerConsumer
extends Consumer

A ServerConsumer

Method Summary

Modifier and Type	Method and Description
void	acknowledge(Transaction tx, long messageID)
void	backToDelivering(MessageReference reference) Some protocols may choose to send the message back to delivering instead of redeliver.
List<MessageReference>	cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx)
void	close(boolean failed)
void	fireSlowConsumer()
void	forceDelivery(long sequence)
Object	getConnectionID()
long	getCreationTime()
List<MessageReference>	getDeliveringReferencesBasedOnProtocol(boolean remove, Object protocolDataStart, Object protocolDataEnd)
long	getID()
Object	getProtocolContext() An object set by the Protocol implementation.
Object	getProtocolData() this is to be used with anything specific on a protocol head.
Queue	getQueue()
String	getSessionID()
SlowConsumerDetectionListener	getSlowConsumerDetecion()
void	individualAcknowledge(Transaction tx, long messageID)
void	individualCancel(long messageID, boolean failed)
boolean	isBrowseOnly()
void	promptDelivery()
void	receiveCredits(int credits)
void	removeItself() This method is just to remove itself from Queues.
MessageReference	removeReferenceByID(long messageID)
void	setlowConsumerDetection(SlowConsumerDetectionListener listener)
void	setProtocolContext(Object protocolContext)
void	setProtocolData(Object protocolData) this is to be used with anything specific on a protocol head.
void	setStarted(boolean started)
void	setTransferring(boolean transferring)

Methods inherited from interface org.apache.activemq.artemis.core.server.Consumer

debug, disconnect, getDeliveringMessages, getFilter, handle, proceedDeliver, toManagementString

Method Detail

setlowConsumerDetection

void setlowConsumerDetection(SlowConsumerDetectionListener listener)

getSlowConsumerDetecion

SlowConsumerDetectionListener getSlowConsumerDetecion()

fireSlowConsumer

void fireSlowConsumer()

getProtocolData

Object getProtocolData()

this is to be used with anything specific on a protocol head.

setProtocolData

void setProtocolData(Object protocolData)

this is to be used with anything specific on a protocol head.

setProtocolContext

void setProtocolContext(Object protocolContext)

Parameters:

protocolContext -

See Also:

getProtocolContext()

getProtocolContext

Object getProtocolContext()

An object set by the Protocol implementation. it could be anything pre-determined by the implementation

getID

long getID()

getConnectionID

Object getConnectionID()

close

void close(boolean failed)
    throws Exception

Throws:

Exception

removeItself

void removeItself()
           throws Exception

This method is just to remove itself from Queues. If for any reason during a close an exception occurred, the exception treatment will call removeItself what should take the consumer out of any queues.

Throws:

Exception

cancelRefs

List<MessageReference> cancelRefs(boolean failed,
                                  boolean lastConsumedAsDelivered,
                                  Transaction tx)
                           throws Exception

Throws:

Exception

setStarted

void setStarted(boolean started)

receiveCredits

void receiveCredits(int credits)

getQueue

Queue getQueue()

removeReferenceByID

MessageReference removeReferenceByID(long messageID)
                              throws Exception

Throws:

Exception

backToDelivering

void backToDelivering(MessageReference reference)

Some protocols may choose to send the message back to delivering instead of redeliver. For example openwire will redeliver through the client, so messages will go back to delivering list after rollback.

getDeliveringReferencesBasedOnProtocol

List<MessageReference> getDeliveringReferencesBasedOnProtocol(boolean remove,
                                                              Object protocolDataStart,
                                                              Object protocolDataEnd)

acknowledge

void acknowledge(Transaction tx,
                 long messageID)
          throws Exception

Throws:

Exception

individualAcknowledge

void individualAcknowledge(Transaction tx,
                           long messageID)
                    throws Exception

Throws:

Exception

individualCancel

void individualCancel(long messageID,
                      boolean failed)
               throws Exception

Throws:

Exception

forceDelivery

void forceDelivery(long sequence)

setTransferring

void setTransferring(boolean transferring)

isBrowseOnly

boolean isBrowseOnly()

getCreationTime

long getCreationTime()

getSessionID

String getSessionID()

promptDelivery

void promptDelivery()