Uses of Class
com.swiftmq.impl.streams.comp.io.QueueWireTapInput
Packages that use QueueWireTapInput
-
Uses of QueueWireTapInput in com.swiftmq.impl.streams.comp.io
Methods in com.swiftmq.impl.streams.comp.io that return QueueWireTapInputModifier 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
Methods in com.swiftmq.impl.streams.processor.po that return QueueWireTapInputConstructors in com.swiftmq.impl.streams.processor.po with parameters of type QueueWireTapInputModifierConstructorDescriptionPOWireTapMessage
(Semaphore semaphore, QueueWireTapInput wiretapInput)