Package com.swiftmq.impl.amqp

Class OutboundQueue

java.lang.Object

com.swiftmq.tools.queue.SingleProcessorQueue

com.swiftmq.impl.amqp.OutboundQueue

public class OutboundQueue
extends SingleProcessorQueue

Method Summary

Modifier and Type	Method	Description
protected void	process(java.lang.Object[] bulk, int n)
void	setOutboundTracer(OutboundTracer outboundTracer)
protected void	startProcessor()

Methods inherited from class com.swiftmq.tools.queue.SingleProcessorQueue

clear, close, dequeue, enqueue, getSize, isClosed, isStarted, startQueue, stopQueue, validateClearElement

Methods inherited from class java.lang.Object

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

Method Detail

setOutboundTracer

public void setOutboundTracer(OutboundTracer outboundTracer)

startProcessor

protected void startProcessor()

Specified by:

startProcessor in class SingleProcessorQueue

process

protected void process(java.lang.Object[] bulk,
                       int n)

Specified by:

process in class SingleProcessorQueue