Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.mom4j.jms
Class MessageProducerImpl  view MessageProducerImpl download MessageProducerImpl.java

java.lang.Object
  extended byorg.mom4j.jms.MessageProducerImpl
All Implemented Interfaces:
javax.jms.MessageProducer, javax.jms.QueueSender, javax.jms.TopicPublisher

public class MessageProducerImpl
extends java.lang.Object
implements javax.jms.MessageProducer, javax.jms.QueueSender, javax.jms.TopicPublisher


Field Summary
private  int deliveryMode
           
private  DestinationImpl destination
           
private  boolean disableMessageId
           
private  boolean disableMessageTimestamp
           
private  int priority
           
private  SessionImpl session
           
private  long timeToLive
           
 
Constructor Summary
(package private) MessageProducerImpl(DestinationImpl destination, SessionImpl session)
           
 
Method Summary
 void close()
           
 int getDeliveryMode()
           
 javax.jms.Destination getDestination()
           
 boolean getDisableMessageID()
           
 boolean getDisableMessageTimestamp()
           
 int getPriority()
           
 javax.jms.Queue getQueue()
           
 long getTimeToLive()
           
 javax.jms.Topic getTopic()
           
 void publish(javax.jms.Message msg)
           
 void publish(javax.jms.Message msg, int deliveryMode, int priority, long timeToLive)
           
 void publish(javax.jms.Topic topic, javax.jms.Message msg)
           
 void publish(javax.jms.Topic topic, javax.jms.Message msg, int deliveryMode, int priority, long timeToLive)
           
 void send(javax.jms.Destination destination, javax.jms.Message msg)
           
 void send(javax.jms.Destination destination, javax.jms.Message msg, int deliveryMode, int priority, long timeToLive)
           
 void send(javax.jms.Message msg)
           
 void send(javax.jms.Message msg, int deliveryMode, int priority, long timeToLive)
           
 void send(javax.jms.Queue queue, javax.jms.Message msg)
           
 void send(javax.jms.Queue queue, javax.jms.Message msg, int deliveryMode, int priority, long timeToLive)
           
 void setDeliveryMode(int mode)
           
 void setDisableMessageID(boolean value)
           
 void setDisableMessageTimestamp(boolean value)
           
 void setPriority(int value)
           
 void setTimeToLive(long timetolive)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

destination

private DestinationImpl destination

session

private SessionImpl session

timeToLive

private long timeToLive

priority

private int priority

deliveryMode

private int deliveryMode

disableMessageTimestamp

private boolean disableMessageTimestamp

disableMessageId

private boolean disableMessageId
Constructor Detail

MessageProducerImpl

MessageProducerImpl(DestinationImpl destination,
                    SessionImpl session)
Method Detail

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws javax.jms.JMSException
Specified by:
getDisableMessageTimestamp in interface javax.jms.MessageProducer

getPriority

public int getPriority()
                throws javax.jms.JMSException
Specified by:
getPriority in interface javax.jms.MessageProducer

setDeliveryMode

public void setDeliveryMode(int mode)
                     throws javax.jms.JMSException
Specified by:
setDeliveryMode in interface javax.jms.MessageProducer

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean value)
                                throws javax.jms.JMSException
Specified by:
setDisableMessageTimestamp in interface javax.jms.MessageProducer

setTimeToLive

public void setTimeToLive(long timetolive)
                   throws javax.jms.JMSException
Specified by:
setTimeToLive in interface javax.jms.MessageProducer

getTimeToLive

public long getTimeToLive()
                   throws javax.jms.JMSException
Specified by:
getTimeToLive in interface javax.jms.MessageProducer

getDeliveryMode

public int getDeliveryMode()
                    throws javax.jms.JMSException
Specified by:
getDeliveryMode in interface javax.jms.MessageProducer

getDisableMessageID

public boolean getDisableMessageID()
                            throws javax.jms.JMSException
Specified by:
getDisableMessageID in interface javax.jms.MessageProducer

setDisableMessageID

public void setDisableMessageID(boolean value)
                         throws javax.jms.JMSException
Specified by:
setDisableMessageID in interface javax.jms.MessageProducer

setPriority

public void setPriority(int value)
                 throws javax.jms.JMSException
Specified by:
setPriority in interface javax.jms.MessageProducer

getDestination

public javax.jms.Destination getDestination()
                                     throws javax.jms.JMSException
Specified by:
getDestination in interface javax.jms.MessageProducer

send

public void send(javax.jms.Message msg,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer

send

public void send(javax.jms.Message msg)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message msg)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer

send

public void send(javax.jms.Destination destination,
                 javax.jms.Message msg,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.MessageProducer

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.MessageProducer

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException
Specified by:
getQueue in interface javax.jms.QueueSender

send

public void send(javax.jms.Queue queue,
                 javax.jms.Message msg)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.QueueSender

send

public void send(javax.jms.Queue queue,
                 javax.jms.Message msg,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException
Specified by:
send in interface javax.jms.QueueSender

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException
Specified by:
getTopic in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Message msg,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Topic topic,
                    javax.jms.Message msg)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Message msg)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher

publish

public void publish(javax.jms.Topic topic,
                    javax.jms.Message msg,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws javax.jms.JMSException
Specified by:
publish in interface javax.jms.TopicPublisher