|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.boundedvm.TransientQueueBoundedMessageContainer
A MessageContainer for transient queues
Constructor Summary | |
TransientQueueBoundedMessageContainer(MemoryBoundedQueueManager queueManager,
ActiveMQDestination destination)
Construct this beast |
Method Summary | |
TransientQueueSubscription |
addConsumer(Filter filter,
ConsumerInfo info,
BrokerClient client)
Add a consumer to dispatch messages to |
MessageIdentity |
addMessage(ActiveMQMessage msg)
Add an ActiveMQMessage to the message container |
protected void |
clear()
|
void |
close()
close down this container |
boolean |
containsMessage(MessageIdentity messageIdentity)
Returns whether or not this container contains the given message identity which provides an optimisation over getMessage() where the message does not need to be loaded. |
void |
delete(MessageIdentity messageIdentity,
MessageAck ack)
Delete a message - if no |
void |
enqueue(ActiveMQMessage message)
enqueue a message for dispatching |
void |
enqueueFirst(ActiveMQMessage message)
enqueue a message for dispatching |
ActiveMQDestination |
getDestination()
|
String |
getDestinationName()
|
ActiveMQMessage |
getMessage(MessageIdentity messageIdentity)
Return the ActiveMQMessage that matches the Id |
protected boolean |
hasActiveSubscribers()
|
boolean |
isInactive()
|
void |
registerMessageInterest(MessageIdentity messageIdentity)
Register that a consumer will be interested in this message |
void |
removeConsumer(ConsumerInfo info)
Remove a consumer |
protected void |
removeExpiredMessages()
|
void |
run()
do some dispatching |
void |
start()
start working |
void |
stop()
stop working |
void |
unregisterMessageInterest(MessageIdentity messageIdentity,
MessageAck ack)
A message consumer calls this when it's no longer interested in a message so that we know when we can delete (or archive) it |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TransientQueueBoundedMessageContainer(MemoryBoundedQueueManager queueManager, ActiveMQDestination destination)
queueManager
- destination
- Method Detail |
public boolean isInactive()
public TransientQueueSubscription addConsumer(Filter filter, ConsumerInfo info, BrokerClient client) throws JMSException
filter
- info
- client
-
JMSException
public void removeConsumer(ConsumerInfo info) throws JMSException
info
-
JMSException
public void start()
start
in interface Service
public void enqueue(ActiveMQMessage message)
message
- public void enqueueFirst(ActiveMQMessage message)
message
- public void stop()
stop
in interface Service
public void close() throws JMSException
JMSException
public void run()
run
in interface Runnable
public ActiveMQDestination getDestination()
public String getDestinationName()
getDestinationName
in interface MessageContainer
public MessageIdentity addMessage(ActiveMQMessage msg) throws JMSException
MessageContainer
addMessage
in interface MessageContainer
msg
-
JMSException
public void delete(MessageIdentity messageIdentity, MessageAck ack) throws JMSException
MessageContainer
delete
in interface MessageContainer
messageIdentity
- ack
-
JMSException
public ActiveMQMessage getMessage(MessageIdentity messageIdentity) throws JMSException
MessageContainer
getMessage
in interface MessageContainer
messageIdentity
-
JMSException
public void registerMessageInterest(MessageIdentity messageIdentity) throws JMSException
MessageContainer
registerMessageInterest
in interface MessageContainer
messageIdentity
-
JMSException
public void unregisterMessageInterest(MessageIdentity messageIdentity, MessageAck ack) throws JMSException
MessageContainer
unregisterMessageInterest
in interface MessageContainer
messageIdentity
- ack
-
JMSException
public boolean containsMessage(MessageIdentity messageIdentity) throws JMSException
MessageContainer
containsMessage
in interface MessageContainer
messageIdentity
-
JMSException
protected boolean hasActiveSubscribers()
protected void clear()
protected void removeExpiredMessages()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |