Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.apache.cxf.wsn.jms
Class JmsSubscription

java.lang.Object
  extended by org.apache.cxf.wsn.AbstractEndpoint
      extended by org.apache.cxf.wsn.AbstractSubscription
          extended by org.apache.cxf.wsn.jms.JmsSubscription
All Implemented Interfaces:
javax.jms.MessageListener, EndpointMBean, PausableSubscriptionManager
Direct Known Subclasses:
JaxwsSubscription
public abstract class JmsSubscription
extends AbstractSubscription
implements javax.jms.MessageListener

Field Summary
 
Fields inherited from class org.apache.cxf.wsn.AbstractSubscription
broker, consumerReference, contentFilter, datatypeFactory, QNAME_MESSAGE_CONTENT, QNAME_PRODUCER_PROPERTIES, QNAME_TOPIC_EXPRESSION, QNAME_USE_RAW, terminationTime, topic, useRaw, WSN_URI, XPATH1_URI
 
Fields inherited from class org.apache.cxf.wsn.AbstractEndpoint
address, endpoint, manager, name
 
Constructor Summary
JmsSubscription(String name)
           
 
Method Summary
protected  boolean doFilter(Element content)
           
protected abstract  void doNotify(Notify notify)
           
 javax.jms.Connection getConnection()
           
 void onMessage(javax.jms.Message jmsMessage)
           
protected  void pause()
           
protected  void renew(XMLGregorianCalendar terminationTime)
           
protected  void resume()
           
 void setConnection(javax.jms.Connection connection)
           
protected  void start()
           
protected  void unsubscribe()
           
protected  void validateSubscription(Subscribe subscribeRequest)
           
 
Methods inherited from class org.apache.cxf.wsn.AbstractSubscription
create, getBroker, getCurrentTime, getTerminationTime, parseTerminationTime, pauseSubscription, renew, resumeSubscription, setBroker, setTerminationTime, unsubscribe, validateInitialTerminationTime, validateTerminationTime
 
Methods inherited from class org.apache.cxf.wsn.AbstractEndpoint
getAddress, getEpr, getManager, getMBeanName, getName, register, setAddress, setManager, unregister
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JmsSubscription

public JmsSubscription(String name)
Method Detail

start

protected void start()
              throws SubscribeCreationFailedFault
Specified by:
start in class AbstractSubscription
Throws:
SubscribeCreationFailedFault

validateSubscription

protected void validateSubscription(Subscribe subscribeRequest)
                             throws InvalidFilterFault,
                                    InvalidMessageContentExpressionFault,
                                    InvalidProducerPropertiesExpressionFault,
                                    InvalidTopicExpressionFault,
                                    SubscribeCreationFailedFault,
                                    TopicExpressionDialectUnknownFault,
                                    TopicNotSupportedFault,
                                    UnacceptableInitialTerminationTimeFault,
                                    UnsupportedPolicyRequestFault,
                                    UnrecognizedPolicyRequestFault
Overrides:
validateSubscription in class AbstractSubscription
Throws:
InvalidFilterFault
InvalidMessageContentExpressionFault
InvalidProducerPropertiesExpressionFault
InvalidTopicExpressionFault
SubscribeCreationFailedFault
TopicExpressionDialectUnknownFault
TopicNotSupportedFault
UnacceptableInitialTerminationTimeFault
UnsupportedPolicyRequestFault
UnrecognizedPolicyRequestFault

pause

protected void pause()
              throws PauseFailedFault
Specified by:
pause in class AbstractSubscription
Throws:
PauseFailedFault

resume

protected void resume()
               throws ResumeFailedFault
Specified by:
resume in class AbstractSubscription
Throws:
ResumeFailedFault

renew

protected void renew(XMLGregorianCalendar terminationTime)
              throws UnacceptableTerminationTimeFault
Specified by:
renew in class AbstractSubscription
Throws:
UnacceptableTerminationTimeFault

unsubscribe

protected void unsubscribe()
                    throws UnableToDestroySubscriptionFault
Overrides:
unsubscribe in class AbstractSubscription
Throws:
UnableToDestroySubscriptionFault

getConnection

public javax.jms.Connection getConnection()

setConnection

public void setConnection(javax.jms.Connection connection)

onMessage

public void onMessage(javax.jms.Message jmsMessage)
Specified by:
onMessage in interface javax.jms.MessageListener

doFilter

protected boolean doFilter(Element content)

doNotify

protected abstract void doNotify(Notify notify)
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Apache CXF