org.xmlBlaster.engine
Class TopicAccessor.Consumer

java.lang.Object
  org.xmlBlaster.engine.TopicAccessor.Consumer

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

TopicAccessor

private class TopicAccessor.Consumer
extends java.lang.Object
implements java.lang.Runnable

Called by msgUnitWrapper.toDestroyed(): this.glob.getTopicAccessor().entryDestroyed_scheduleForExecution(this); Is currently switched off (not used)

Author:

mr@marcelruff.info

Field Summary

private java.util.concurrent.BlockingQueue

queue

Constructor Summary

TopicAccessor.Consumer(java.util.concurrent.BlockingQueue q)

Method Summary

(package private) void	consume(java.lang.Object x)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

queue

private final java.util.concurrent.BlockingQueue queue

Constructor Detail

TopicAccessor.Consumer

TopicAccessor.Consumer(java.util.concurrent.BlockingQueue q)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

consume

void consume(java.lang.Object x)