org.apache.qpid.client
Class BasicMessageProducer_0_8

java.lang.Object
  extended by org.apache.qpid.client.Closeable
      extended by org.apache.qpid.client.BasicMessageProducer
          extended by org.apache.qpid.client.BasicMessageProducer_0_8
All Implemented Interfaces:
MessageProducer

public class BasicMessageProducer_0_8
extends BasicMessageProducer


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.client.BasicMessageProducer
BasicMessageProducer.PublishMode
 
Field Summary
 
Fields inherited from class org.apache.qpid.client.BasicMessageProducer
_channelId, _destination, _disableTimestamps, _logger, _protocolHandler, _session, _userID, publishMode
 
Fields inherited from class org.apache.qpid.client.Closeable
_closed, _closing
 
Constructor Summary
BasicMessageProducer_0_8(AMQConnection connection, AMQDestination destination, boolean transacted, int channelId, AMQSession session, AMQProtocolHandler protocolHandler, long producerId, boolean immediate, boolean mandatory, boolean waitUntilSent)
           
 
Method Summary
(package private)  void declareDestination(AMQDestination destination)
           
(package private)  void sendMessage(AMQDestination destination, Message origMessage, AbstractJMSMessage message, UUID messageId, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate, boolean wait)
           
 
Methods inherited from class org.apache.qpid.client.BasicMessageProducer
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSession, getTimeToLive, isBound, resubscribe, send, send, send, send, send, send, send, send, send, sendImpl, sendImpl, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setEncoding, setMimeType, setPriority, setPublishMode, setTimeToLive
 
Methods inherited from class org.apache.qpid.client.Closeable
checkNotClosed, isClosed, isClosing
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BasicMessageProducer_0_8

BasicMessageProducer_0_8(AMQConnection connection,
                         AMQDestination destination,
                         boolean transacted,
                         int channelId,
                         AMQSession session,
                         AMQProtocolHandler protocolHandler,
                         long producerId,
                         boolean immediate,
                         boolean mandatory,
                         boolean waitUntilSent)
Method Detail

declareDestination

void declareDestination(AMQDestination destination)
Specified by:
declareDestination in class BasicMessageProducer

sendMessage

void sendMessage(AMQDestination destination,
                 Message origMessage,
                 AbstractJMSMessage message,
                 UUID messageId,
                 int deliveryMode,
                 int priority,
                 long timeToLive,
                 boolean mandatory,
                 boolean immediate,
                 boolean wait)
           throws JMSException
Specified by:
sendMessage in class BasicMessageProducer
Throws:
JMSException


Licensed to the Apache Software Foundation