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 edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue

queue

Constructor Summary

(package private)

TopicAccessor.Consumer(edu.emory.mathcs.backport.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 edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue queue

Constructor Detail

TopicAccessor.Consumer

TopicAccessor.Consumer(edu.emory.mathcs.backport.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)