Uses of Class
com.swiftmq.impl.streams.comp.io.QueueWireTapInput
-
Uses of QueueWireTapInput in com.swiftmq.impl.streams.comp.io
Modifier and TypeMethodDescriptionQueueWireTapInput.bufferSize
(int bufferSize) Sets the bufferSize of the internal BlockingQueue.QueueWireTapInput.maxBlockTime
(long maxBlockTime) Sets the maximum block time when the internal BlockingQueue is full.QueueWireTapInput.requiresDeepCopy
(boolean requiresDeepCopy) Sets whether the Message inserts requires a deep copy in order to change it later on.Creates a new QueueWireTapInput. -
Uses of QueueWireTapInput in com.swiftmq.impl.streams.processor.po
ModifierConstructorDescriptionPOWireTapMessage
(Semaphore semaphore, QueueWireTapInput wiretapInput)