|
Oracle® Streams Advanced Queuing Java API Reference 10g Release 2 (10.2) B14291-01 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
oracle.jms.AQjmsObject
oracle.jms.AQjmsProducer
This is an Oracle class which implements oracle.jms.AQjmsQueueSender
and oracle.jms.AQjmsTopicPublisher
.
AQjmsQueueSender
, AQjmsTopicPublisher
Method Summary | |
void |
bufferPublish(Topic topic, Message message, int priority, long timeToLive) Publishes a non-persistent message to an in-memory portion of the topic for an unidentified message producer, specifying delivery mode, priority and time-to-live. |
void |
bufferSend(Destination destination, Message message, int priority, long timeToLive) Sends a non-persistent message to an in-memory portion of the destination for an unidentified message producer, specifying priority and time-to-live. |
void |
bufferSend(Queue queue, Message message, int priority, long timeToLive) Sends a non-persistent message to an in-memory portion of the queue for an unidentified message producer, specifying delivery mode, priority and time-to-live. |
void |
close() Closes the message producer. |
int |
getDeliveryMode() Gets this producer's default delivery mode. |
Destination |
getDestination() Gets the destination associated with this MessageProducer . |
boolean |
getDisableMessageID() Gets an indication of whether message IDs are disabled. |
boolean |
getDisableMessageTimestamp() Gets an indication of whether message timestamps are disabled. |
int |
getPriority() Gets this producer's default priority. |
Queue |
getQueue() Gets the queue associated with this queue sender. |
long |
getTimeToLive() Gets the default length of time in milliseconds from its dispatch time that a produced message should be retained by the message system. |
Topic |
getTopic() Gets the topic associated with this publisher. |
java.lang.String |
getTransformation() Gets this producer's transformation. |
void |
publish(Message message) Publishes a message. |
void |
publish(Message message, oracle.jms.AQjmsAgent[] recipientList) Publishes a message to a specific list of recipients |
void |
publish(Message message, oracle.jms.AQjmsAgent[] recipientList, int deliveryMode, int priority, long timeToLive) Publishes a message to a topic by specifying a list of recipients, delivery mode, priority and time-to-live |
void |
publish(Message message, int deliveryMode, int priority, long timeToLive) Publishes a message to the topic specifying delivery mode, priority and time-to-live. |
void |
publish(Topic topic, Message message) Publishes a message to a topic for an unidentified message producer. |
void |
publish(Topic topic, Message message, oracle.jms.AQjmsAgent[] recipientList) Publishes a message to a topic by specifying a list of recipients. |
void |
publish(Topic topic, Message message, oracle.jms.AQjmsAgent[] recipientList, int deliveryMode, int priority, long timeToLive) Publishes a message to a topic by specifying a list of recipients, delivery mode, priority and time-to-live |
void |
publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive) Publishes a message to a topic for an unidentified message producer, specifying delivery mode, priority and time-to-live. |
void |
send(Destination destination, Message message) Sends a message to a destination for an unidentified message producer. |
void |
send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive) Sends a message to a destination for an unidentified message producer, specifying delivery mode, priority and time-to-live. |
void |
send(Message message) Sends a message. |
void |
send(Message message, int deliveryMode, int priority, long timeToLive) Sends a message. |
void |
send(Queue queue, Message message) Sends a message. |
void |
send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive) Sends a message. |
void |
setDeliveryMode(int deliveryMode) Sets this producer's default delivery mode. |
void |
setDisableMessageID(boolean value) Sets whether message IDs can be disabled. |
void |
setDisableMessageTimestamp(boolean value) Sets whether message timestamps can be disabled. |
void |
setPriority(int priority) Sets this producer's default priority. |
void |
setTimeToLive(long timeToLive) Sets the default length of time in milliseconds from its dispatch time that a produced message should be retained by the message system. |
void |
setTransformation(java.lang.String transformation) Sets this producer's transformation. |
Methods inherited from class oracle.jms.AQjmsObject |
checkClosed, children, finalize, getID, getParent, isOpen, localClose, preClose |
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
public void setDisableMessageID(boolean value) throws JMSException
Since message ID's take some effort to create and increase a message's size, some JMS providers may be able to reduce message overhead if they are given a hint that message IDs are not used by an application. When a client sets a Producer to disable message IDs, it is saying that no one depends on the message IDs of the messages it produces. Produced messages must then either have message ID set to null
or, if the hint is ignored, have message ID set to its normal unique value.
Message IDs are enabled by default.
setDisableMessageID
in interface MessageProducer
value
- hint that message IDs can be disabledJMSException
- if the disable message IDs hint is not set due to some error.public boolean getDisableMessageID() throws JMSException
Note that the returned value reflects the client-provided hint and can therefore only be used to determine whether or not message IDs might be set to null, not if they are being set to null.
getDisableMessageID
in interface MessageProducer
JMSException
- if the disable message IDs hint is not retrieved due to some error.public void setDisableMessageTimestamp(boolean value) throws JMSException
Message timestamps are enabled by default.
setDisableMessageTimestamp
in interface MessageProducer
value
- hint that message timestamps can be disabledJMSException
- if the disable message timestamp hint is not set due to some error.public boolean getDisableMessageTimestamp() throws JMSException
Note that the returned value reflects the client-provided hint and can therefore only be used to determine whether or not message timestamps might be set to zero, not if they are being set to zero.
getDisableMessageTimestamp
in interface MessageProducer
JMSException
- if the disable message timestamp hint is not retrieved due to some error.public void setDeliveryMode(int deliveryMode) throws JMSException
Delivery mode is set to PERSISTENT
by default.
setDeliveryMode
in interface MessageProducer
deliveryMode
- the message delivery mode for this message producer (PERSISTENT
or NON_PERSISTENT
)JMSException
- if the delivery mode is not set due to some error.MessageProducer.getDeliveryMode()
, DeliveryMode.NON_PERSISTENT
, DeliveryMode.PERSISTENT
, Message.DEFAULT_DELIVERY_MODE
public int getDeliveryMode() throws JMSException
getDeliveryMode
in interface MessageProducer
JMSException
- if the delivery mode is not retrieved due to some error.MessageProducer.setDeliveryMode(int)
public void setPriority(int priority) throws JMSException
setPriority
in interface MessageProducer
priority
- the message priority for this message producerJMSException
- if the priority is not set due to some error.MessageProducer.getPriority()
, Message.DEFAULT_PRIORITY
public int getPriority() throws JMSException
getPriority
in interface MessageProducer
JMSException
- if the priority is not retrieved due to some error.MessageProducer.setPriority(int)
public void setTimeToLive(long timeToLive) throws JMSException
Time-to-live is set to zero by default.
setTimeToLive
in interface MessageProducer
timeToLive
- the message time-to-live in milliseconds; zero is unlimitedJMSException
- if time-to-live is not set due to some error.MessageProducer.getTimeToLive()
, Message.DEFAULT_TIME_TO_LIVE
public long getTimeToLive() throws JMSException
getTimeToLive
in interface MessageProducer
JMSException
- if time-to-live is not retrieved due to some error.MessageProducer.setTimeToLive(long)
public Queue getQueue() throws JMSException
getQueue
in interface QueueSender
JMSException
- if the queue is not retrieved due to some error.public void setTransformation(java.lang.String transformation)
setTransformation
in interface AQjmsQueueSender
transformation
- the transformation to use when sending messagespublic java.lang.String getTransformation()
getTransformation
in interface AQjmsQueueSender
public void send(Message message) throws JMSException
send
in interface QueueSender
message
- the message to sendJMSException
- if the message is not sent due to some error.MessageProducer.getDeliveryMode()
, MessageProducer.getTimeToLive()
, MessageProducer.getPriority()
public void send(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
send
in interface QueueSender
message
- the message to senddeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not sent due to some error.public void send(Queue queue, Message message) throws JMSException
send
in interface QueueSender
queue
- The destination queue where the message has to be sent. This overrides the default queue of the Message Producer.message
- the message to sendJMSException
- if the message is not sent due to some error.MessageProducer.getDeliveryMode()
, MessageProducer.getTimeToLive()
, MessageProducer.getPriority()
public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
send
in interface QueueSender
queue
- The destination queue where the message has to be sent. This overrides the default queue of the Message Producer.message
- the message to senddeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not sent due to some error.public void bufferSend(Queue queue, Message message, int priority, long timeToLive) throws JMSException
queue
- The destination queue where the message has to be sent. This overrides the default queue of the Message Producer.message
- the message to sendpriority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not sent due to some error.public Topic getTopic() throws JMSException
getTopic
in interface TopicPublisher
JMSException
- if the topic is not retrieved due to some error.public void publish(Message message) throws JMSException
publish
in interface TopicPublisher
message
- the message to publishJMSException
- if the message is not published due to some error.MessageProducer.getDeliveryMode()
, MessageProducer.getTimeToLive()
, MessageProducer.getPriority()
public void publish(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface TopicPublisher
message
- the message to publishdeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not published due to some error.public void publish(Topic topic, Message message) throws JMSException
publish
in interface TopicPublisher
topic
- The topic to which to publish the message. This overrides the default topic of the Message Producer.message
- the message to publishJMSException
- if message is not published due to some error.MessageProducer.getDeliveryMode()
, MessageProducer.getTimeToLive()
, MessageProducer.getPriority()
public void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface TopicPublisher
topic
- The topic to which to publish the message. This overrides the default topic of the Message Producer.message
- the message to publishdeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not published due to some error.public void bufferPublish(Topic topic, Message message, int priority, long timeToLive) throws JMSException
topic
- The topic to which to publish the message. This overrides the default topic of the Message Producer.message
- the message to publishpriority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not published due to some error.public void publish(Message message, oracle.jms.AQjmsAgent[] recipientList) throws JMSException
publish
in interface AQjmsTopicPublisher
message
- the message to publishrecipientList
- the list of recipients to which the message is to be publishedJMSException
- if the message is not published due to some error.public void publish(Topic topic, Message message, oracle.jms.AQjmsAgent[] recipientList) throws JMSException
publish
in interface AQjmsTopicPublisher
topic
- The topic to which to publish the message. This overrides the default topic of the Message Producer.message
- the message to publishrecipientList
- the list of recipients to which the message is to be publishedJMSException
- if the message is not published due to some error.public void publish(Message message, oracle.jms.AQjmsAgent[] recipientList, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface AQjmsTopicPublisher
message
- the message to publishrecipientList
- the list of recipients to which the message is to be publisheddeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not published due to some error.public void publish(Topic topic, Message message, oracle.jms.AQjmsAgent[] recipientList, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface AQjmsTopicPublisher
topic
- The topic to which to publish the message. This overrides the default topic of the Message Producer.message
- the message to publishrecipientList
- the list of recipients to which the message is to be publisheddeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not published due to some error.public void close() throws JMSException
MessageProducer
Since a provider may allocate some resources on behalf of a MessageProducer
outside the Java virtual machine, clients should close them when they are not needed. Relying on garbage collection to eventually reclaim these resources may not be timely enough.
close
in interface MessageProducer
JMSException
public Destination getDestination() throws JMSException
MessageProducer
.getDestination
in interface MessageProducer
Destination/
JMSException
- if the destination is not retrieved due to some error.public void send(Destination destination, Message message) throws JMSException
MessageProducer
's default delivery mode, priority, and time to live.
Typically, a message producer is assigned a destination at creation time; however, the JMS API also supports unidentified message producers, which require that the destination be supplied every time a message is sent.
send
in interface MessageProducer
destination
- the destination to send this message tomessage
- the message to sendJMSException
- if the message is not sent due to some error.MessageFormatException
- if an invalid message is specified.InvalidDestinationException
- if a client uses this method with an invalid destination.java.lang.UnsupportedOperationException
- if a client uses this method with a MessageProducer
that specified a destination at creation time.Session.createProducer(javax.jms.Destination)
, MessageProducer
public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
Typically, a message producer is assigned a destination at creation time; however, the JMS API also supports unidentified message producers, which require that the destination be supplied every time a message is sent.
send
in interface MessageProducer
destination
- the destination to send this message tomessage
- the message to senddeliveryMode
- the delivery mode for message
(DeliveryMode.PERSISTENT
or DeliveryMode.NON_PERSISTENT
)priority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not sent due to some error.MessageFormatException
- if an invalid message is specified.InvalidDestinationException
- if a client uses this method with an invalid destination.Session.createProducer(javax.jms.Destination)
public void bufferSend(Destination destination, Message message, int priority, long timeToLive) throws JMSException
destination
- the destination to send this message tomessage
- the message to sendpriority
- the priority for message
(JMS defines 0 as lowest and 9 as highest)timeToLive
- the time-to-live for message
(milliseconds; 0 means no limit)JMSException
- if the message is not sent due to some error.MessageFormatException
- if an invalid message is specified.InvalidDestinationException
- if a client uses this method with an invalid destination.Session.createProducer(javax.jms.Destination)
|
Oracle® Streams Advanced Queuing Java API Reference 10g Release 2 (10.2) B14291-01 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |