org.opendaylight.openflowplugin.openflow.md.queue

Class TicketFinisherImpl

java.lang.Object

org.opendaylight.openflowplugin.openflow.md.queue.TicketFinisherImpl

All Implemented Interfaces:

Runnable, TicketFinisher<org.opendaylight.yangtools.yang.binding.DataObject>

public class TicketFinisherImpl
extends Object
implements TicketFinisher<org.opendaylight.yangtools.yang.binding.DataObject>

Constructor Summary

Constructors

Constructor and Description
TicketFinisherImpl(BlockingQueue<TicketResult<org.opendaylight.yangtools.yang.binding.DataObject>> queue, Map<Class<? extends org.opendaylight.yangtools.yang.binding.DataObject>,Collection<PopListener<org.opendaylight.yangtools.yang.binding.DataObject>>> popListenersMapping)

Method Summary

Modifier and Type	Method and Description
void	finish() initiate shutdown of this worker
void	firePopNotification(List<org.opendaylight.yangtools.yang.binding.DataObject> processedMessages) notify popListeners
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

TicketFinisherImpl

public TicketFinisherImpl(BlockingQueue<TicketResult<org.opendaylight.yangtools.yang.binding.DataObject>> queue,
                          Map<Class<? extends org.opendaylight.yangtools.yang.binding.DataObject>,Collection<PopListener<org.opendaylight.yangtools.yang.binding.DataObject>>> popListenersMapping)

Parameters:

queue - ticket queue

popListenersMapping - message pop listener

Method Detail

run

public void run()

Specified by:

run in interface Runnable

firePopNotification

public void firePopNotification(List<org.opendaylight.yangtools.yang.binding.DataObject> processedMessages)

Description copied from interface: TicketFinisher

notify popListeners

Specified by:

firePopNotification in interface TicketFinisher<org.opendaylight.yangtools.yang.binding.DataObject>

Parameters:

processedMessages - processed message

finish

public void finish()

initiate shutdown of this worker

Specified by:

finish in interface TicketFinisher<org.opendaylight.yangtools.yang.binding.DataObject>