com.caucho.message.common
Class AbstractMessageFactory<T>
java.lang.Object
com.caucho.message.common.AbstractQueueSender<T>
com.caucho.message.common.AbstractMessageFactory<T>
- All Implemented Interfaces:
- MessagePropertiesFactory<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingQueue<T>, java.util.Queue<T>
- Direct Known Subclasses:
- NullMessageFactory, SenderMessageFactory
public class AbstractMessageFactory<T>
- extends AbstractQueueSender<T>
- implements MessagePropertiesFactory<T>
message factory
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, toString |
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, removeAll, retainAll, size, toArray, toArray |
AbstractMessageFactory
public AbstractMessageFactory()
setDurable
public void setDurable(boolean isDurable)
- Specified by:
setDurable
in interface MessagePropertiesFactory<T>
isDurable
public boolean isDurable()
- Specified by:
isDurable
in interface MessagePropertiesFactory<T>
getPriority
public int getPriority()
- Specified by:
getPriority
in interface MessagePropertiesFactory<T>
setPriority
public void setPriority(int priority)
- Specified by:
setPriority
in interface MessagePropertiesFactory<T>
getTimeToLive
public long getTimeToLive()
- Specified by:
getTimeToLive
in interface MessagePropertiesFactory<T>
setTimeToLive
public void setTimeToLive(long ttl)
- Specified by:
setTimeToLive
in interface MessagePropertiesFactory<T>
isFirstAcquirer
public boolean isFirstAcquirer()
- Specified by:
isFirstAcquirer
in interface MessagePropertiesFactory<T>
setFirstAcquirer
public void setFirstAcquirer(boolean isFirst)
- Specified by:
setFirstAcquirer
in interface MessagePropertiesFactory<T>
getMessageId
public java.lang.Object getMessageId()
- Specified by:
getMessageId
in interface MessagePropertiesFactory<T>
setMessageId
public void setMessageId(java.lang.Object value)
- Specified by:
setMessageId
in interface MessagePropertiesFactory<T>
getUserId
public java.lang.String getUserId()
- Specified by:
getUserId
in interface MessagePropertiesFactory<T>
setUserId
public void setUserId(java.lang.String value)
- Specified by:
setUserId
in interface MessagePropertiesFactory<T>
getTo
public java.lang.String getTo()
- Specified by:
getTo
in interface MessagePropertiesFactory<T>
setTo
public void setTo(java.lang.String to)
- Specified by:
setTo
in interface MessagePropertiesFactory<T>
getSubject
public java.lang.String getSubject()
- Specified by:
getSubject
in interface MessagePropertiesFactory<T>
setSubject
public void setSubject(java.lang.String subject)
- Specified by:
setSubject
in interface MessagePropertiesFactory<T>
getReplyTo
public java.lang.String getReplyTo()
- Specified by:
getReplyTo
in interface MessagePropertiesFactory<T>
setReplyTo
public void setReplyTo(java.lang.String value)
- Specified by:
setReplyTo
in interface MessagePropertiesFactory<T>
getCorrelationId
public java.lang.Object getCorrelationId()
- Specified by:
getCorrelationId
in interface MessagePropertiesFactory<T>
setCorrelationId
public void setCorrelationId(java.lang.Object value)
- Specified by:
setCorrelationId
in interface MessagePropertiesFactory<T>
getContentType
public java.lang.String getContentType()
- Specified by:
getContentType
in interface MessagePropertiesFactory<T>
setContentType
public void setContentType(java.lang.String value)
- Specified by:
setContentType
in interface MessagePropertiesFactory<T>
getContentEncoding
public java.lang.String getContentEncoding()
- Specified by:
getContentEncoding
in interface MessagePropertiesFactory<T>
setContentEncoding
public void setContentEncoding(java.lang.String value)
- Specified by:
setContentEncoding
in interface MessagePropertiesFactory<T>
getExpiryTime
public long getExpiryTime()
- Specified by:
getExpiryTime
in interface MessagePropertiesFactory<T>
setExpiryTime
public void setExpiryTime(long value)
- Specified by:
setExpiryTime
in interface MessagePropertiesFactory<T>
getCreationTime
public long getCreationTime()
- Specified by:
getCreationTime
in interface MessagePropertiesFactory<T>
setCreationTime
public void setCreationTime(long value)
- Specified by:
setCreationTime
in interface MessagePropertiesFactory<T>
getGroupId
public java.lang.String getGroupId()
- Specified by:
getGroupId
in interface MessagePropertiesFactory<T>
setGroupId
public void setGroupId(java.lang.String value)
- Specified by:
setGroupId
in interface MessagePropertiesFactory<T>
getGroupSequence
public long getGroupSequence()
- Specified by:
getGroupSequence
in interface MessagePropertiesFactory<T>
setGroupSequence
public void setGroupSequence(long value)
- Specified by:
setGroupSequence
in interface MessagePropertiesFactory<T>
getReplyToGroupId
public java.lang.String getReplyToGroupId()
- Specified by:
getReplyToGroupId
in interface MessagePropertiesFactory<T>
setReplyToGroupId
public void setReplyToGroupId(java.lang.String value)
- Specified by:
setReplyToGroupId
in interface MessagePropertiesFactory<T>
offerMicros
protected boolean offerMicros(MessagePropertiesFactory<T> factory,
T value,
long timeoutMicros)
- Description copied from class:
AbstractQueueSender
- Offers a value to the queue.
- Specified by:
offerMicros
in class AbstractQueueSender<T>
close
public void close()
- Specified by:
close
in interface MessagePropertiesFactory<T>