com.caucho.message.common

Class SenderMessageFactory<T>

java.lang.Object

com.caucho.message.common.AbstractQueueSender<T>

com.caucho.message.common.AbstractMessageFactory<T>

com.caucho.message.common.SenderMessageFactory<T>

All Implemented Interfaces:

MessagePropertiesFactory<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>

public class SenderMessageFactory<T>
extends AbstractMessageFactory<T>

message factory

Constructor Summary

Constructors

Constructor and Description
SenderMessageFactory(AbstractMessageSender<T> sender)

Method Summary

Modifier and Type	Method and Description
protected boolean	offerMicros(MessagePropertiesFactory<T> factory, T value, long timeoutMicros) Offers a value to the queue.
java.lang.String	toString()

Methods inherited from class com.caucho.message.common.AbstractMessageFactory

close, getContentEncoding, getContentType, getCorrelationId, getCreationTime, getExpiryTime, getGroupId, getGroupSequence, getMessageId, getPriority, getReplyTo, getReplyToGroupId, getSubject, getTimeToLive, getTo, getUserId, isDurable, isFirstAcquirer, setContentEncoding, setContentType, setCorrelationId, setCreationTime, setDurable, setExpiryTime, setFirstAcquirer, setGroupId, setGroupSequence, setMessageId, setPriority, setReplyTo, setReplyToGroupId, setSubject, setTimeToLive, setTo, setUserId

Methods inherited from class com.caucho.message.common.AbstractQueueSender

add, addAll, clear, contains, containsAll, drainTo, drainTo, element, getMessageFactory, isEmpty, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, remove, removeAll, retainAll, size, take, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take

Methods inherited from interface java.util.Queue

element, peek, poll, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

SenderMessageFactory

public SenderMessageFactory(AbstractMessageSender<T> sender)

Method Detail

offerMicros

protected boolean offerMicros(MessagePropertiesFactory<T> factory,
                              T value,
                              long timeoutMicros)

Description copied from class: AbstractQueueSender

Offers a value to the queue.

Overrides:

offerMicros in class AbstractMessageFactory<T>

toString

public java.lang.String toString()

Overrides:

toString in class AbstractQueueSender<T>