public abstract class JmsSubscription extends AbstractSubscription implements javax.jms.MessageListener
broker, consumerReference, contentFilter, datatypeFactory, QNAME_MESSAGE_CONTENT, QNAME_PRODUCER_PROPERTIES, QNAME_TOPIC_EXPRESSION, QNAME_USE_RAW, terminationTime, topic, useRaw, WSN_URI, XPATH1_URIaddress, endpoint, manager, name| Constructor and Description |
|---|
JmsSubscription(String name) |
| Modifier and Type | Method and Description |
|---|---|
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) |
create, getBroker, getCurrentTime, getTerminationTime, parseTerminationTime, pauseSubscription, renew, resumeSubscription, setBroker, setTerminationTime, unsubscribe, validateInitialTerminationTime, validateTerminationTimegetAddress, getEpr, getManager, getMBeanName, getName, getWSDLLocation, register, setAddress, setManager, unregisterpublic JmsSubscription(String name)
protected void start()
throws SubscribeCreationFailedFault
start in class AbstractSubscriptionSubscribeCreationFailedFaultprotected void validateSubscription(Subscribe subscribeRequest) throws InvalidFilterFault, InvalidMessageContentExpressionFault, InvalidProducerPropertiesExpressionFault, InvalidTopicExpressionFault, SubscribeCreationFailedFault, TopicExpressionDialectUnknownFault, TopicNotSupportedFault, UnacceptableInitialTerminationTimeFault, UnsupportedPolicyRequestFault, UnrecognizedPolicyRequestFault
validateSubscription in class AbstractSubscriptionInvalidFilterFaultInvalidMessageContentExpressionFaultInvalidProducerPropertiesExpressionFaultInvalidTopicExpressionFaultSubscribeCreationFailedFaultTopicExpressionDialectUnknownFaultTopicNotSupportedFaultUnacceptableInitialTerminationTimeFaultUnsupportedPolicyRequestFaultUnrecognizedPolicyRequestFaultprotected void pause()
throws PauseFailedFault
pause in class AbstractSubscriptionPauseFailedFaultprotected void resume()
throws ResumeFailedFault
resume in class AbstractSubscriptionResumeFailedFaultprotected void renew(XMLGregorianCalendar terminationTime) throws UnacceptableTerminationTimeFault
renew in class AbstractSubscriptionUnacceptableTerminationTimeFaultprotected void unsubscribe()
throws UnableToDestroySubscriptionFault
unsubscribe in class AbstractSubscriptionUnableToDestroySubscriptionFaultpublic javax.jms.Connection getConnection()
public void setConnection(javax.jms.Connection connection)
public void onMessage(javax.jms.Message jmsMessage)
onMessage in interface javax.jms.MessageListenerprotected boolean doFilter(Element content)
protected abstract void doNotify(Notify notify)
Apache CXF