|
||||||||||
PREV CLASS (src) NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.channel.plugins.handler.AbstractChannelHandler (src)
org.jboss.messaging.channel.plugins.handler.SharedChannelHandler
A channel handler that has multiple consumers
Field Summary |
Fields inherited from class org.jboss.messaging.channel.plugins.handler.AbstractChannelHandler (src) |
messages |
Constructor Summary | |
SharedChannelHandler(MessageSet (src) messages)
Create a new SharedChannelHandler. |
Method Summary | |
protected void |
addConsumer(Consumer (src) consumer,
long wait)
Add a consumer |
protected Consumer (src) |
findConsumer(MessageReference (src) reference)
Find a consumer for a message |
protected void |
removeConsumer(Consumer (src) consumer)
Remove a consumer |
Methods inherited from class org.jboss.messaging.channel.plugins.handler.AbstractChannelHandler (src) |
accepts, addMessage, onMessage, removeMessage, stopWaitMessage, waitMessage |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SharedChannelHandler(MessageSet (src) messages)
messages
- the message setMethod Detail |
protected void addConsumer(Consumer (src) consumer, long wait)
AbstractChannelHandler (src)
addConsumer
in class AbstractChannelHandler (src)
consumer
- the consumer to wait for a messagewait
- the length of time to waitprotected Consumer (src) findConsumer(MessageReference (src) reference)
AbstractChannelHandler (src)
findConsumer
in class AbstractChannelHandler (src)
reference
- the message
protected void removeConsumer(Consumer (src) consumer)
AbstractChannelHandler (src)
removeConsumer
in class AbstractChannelHandler (src)
consumer
- the consumer to remove
|
||||||||||
PREV CLASS (src) NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |