org.apache.qpid.topic
Class MessageFactory

java.lang.Object
  extended by org.apache.qpid.topic.MessageFactory

 class MessageFactory
extends Object


Constructor Summary
MessageFactory(Session session)
           
MessageFactory(Session session, int size)
           
 
Method Summary
(package private)  MessageConsumer createControlConsumer()
           
(package private)  MessageProducer createControlPublisher()
           
(package private)  MessageConsumer createDurableTopicConsumer(String name)
           
(package private)  Message createEventMessage()
           
(package private)  Message createReportRequestMessage()
           
(package private)  Message createReportResponseMessage(String msg)
           
(package private)  Message createShutdownMessage()
           
(package private)  MessageConsumer createTopicConsumer()
           
(package private)  MessageProducer createTopicPublisher()
           
(package private)  Object getReport(Message m)
           
(package private)  Topic getTopic()
           
(package private)  boolean isReport(Message m)
           
(package private)  boolean isShutdown(Message m)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageFactory

MessageFactory(Session session)
         throws JMSException
Throws:
JMSException

MessageFactory

MessageFactory(Session session,
               int size)
         throws JMSException
Throws:
JMSException
Method Detail

getTopic

Topic getTopic()

createEventMessage

Message createEventMessage()
                     throws JMSException
Throws:
JMSException

createShutdownMessage

Message createShutdownMessage()
                        throws JMSException
Throws:
JMSException

createReportRequestMessage

Message createReportRequestMessage()
                             throws JMSException
Throws:
JMSException

createReportResponseMessage

Message createReportResponseMessage(String msg)
                              throws JMSException
Throws:
JMSException

isShutdown

boolean isShutdown(Message m)

isReport

boolean isReport(Message m)

getReport

Object getReport(Message m)

createTopicConsumer

MessageConsumer createTopicConsumer()
                              throws Exception
Throws:
Exception

createDurableTopicConsumer

MessageConsumer createDurableTopicConsumer(String name)
                                     throws Exception
Throws:
Exception

createControlConsumer

MessageConsumer createControlConsumer()
                                throws Exception
Throws:
Exception

createTopicPublisher

MessageProducer createTopicPublisher()
                               throws Exception
Throws:
Exception

createControlPublisher

MessageProducer createControlPublisher()
                                 throws Exception
Throws:
Exception


Licensed to the Apache Software Foundation