|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.muse.core.AbstractCapability
org.apache.muse.ws.resource.impl.AbstractWsResourceCapability
org.apache.muse.ws.notification.impl.SimpleSubscriptionManager
public class SimpleSubscriptionManager
SimpleSubscriptionManager is Muse's default implementation of the
WS-Notification SubscriptionManager port type. It uses the
NotificationConsumerClient class
to send messages to its subscribers. It also provides an initialization
flag, trace-notifications that allows users to turn on tracing
for the outgoing notification messages (the default is 'false').
This implementation does not support subscription policies.
Field Summary |
---|
Fields inherited from interface org.apache.muse.ws.notification.SubscriptionManager |
---|
PROPERTIES |
Constructor Summary | |
---|---|
SimpleSubscriptionManager()
|
Method Summary | |
---|---|
protected NotificationConsumerClient |
createConsumerClient()
Users can override this method to provide a different implementation of the WS-N client class without changing the implementation of subscription management. |
void |
deleteProperty(QName property)
|
protected NotificationConsumerClient |
getConsumerClient()
|
EndpointReference |
getConsumerReference()
|
Date |
getCreationTime()
|
Filter |
getFilter()
|
protected int |
getNumberOfTries()
|
EndpointReference |
getProducerReference()
|
Element[] |
getProperty(QName property)
|
QName[] |
getPropertyNames()
Concrete capability classes that define properties MUST override this method and provide the names of the properties. |
Policy |
getSubscriptionPolicy()
This implementation always returns null. |
void |
initialize()
AbstractWsResourceCapability continues the initialization process by inspecting the concrete class to find all of the getters (and, if applicable, setters) for its resource properties. |
void |
insertProperty(QName property,
Element[] values)
|
protected boolean |
isDestroyedOnFailure()
|
boolean |
isPaused()
|
protected boolean |
isUsingTrace()
|
void |
pauseSubscription()
Temporarily stops the producer resource from sending messages that are published to consumer. |
void |
publish(NotificationMessage message)
Sends the given message to the subscription's consumer resource. |
void |
resumeSubscription()
If the subscription is paused, it is unpaused, so that messages published to the topic will once again be sent to the consumer. |
void |
setConsumerReference(EndpointReference consumer)
|
void |
setFilter(Filter filter)
|
void |
setProducerReference(EndpointReference producer)
|
void |
setSubscriptionPolicy(Policy policy)
Logs a warning message that this feature is not supported. |
Element |
toXML()
Converts this object into an XML representation, as defined by its related schema or specification. |
Element |
toXML(Document doc)
Converts this object into an XML representation, as defined by its related schema or specification. |
void |
updateProperty(QName property,
Element[] values)
|
Methods inherited from class org.apache.muse.ws.resource.impl.AbstractWsResourceCapability |
---|
createGettersAndSetters, deleteProperty, getGetter, getProperty, getPropertyElements, getSetter, getWsResource, insertProperty, invokeMethod, setResource, updateProperty |
Methods inherited from class org.apache.muse.core.AbstractCapability |
---|
getActions, getCapabilityURI, getEnvironment, getInitializationParameter, getInitializationParameters, getLog, getMessageHandler, getPersistence, getResource, hasBeenInitialized, hasBeenShutdown, initializeCompleted, prepareShutdown, setCapabilityURI, setEnvironment, setInitializationParameters, setLog, setMessageHandler, setMessageHandlers, setPersistence, shutdown |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.muse.ws.resource.WsResourceCapability |
---|
getWsResource |
Methods inherited from interface org.apache.muse.core.Capability |
---|
getActions, getCapabilityURI, getEnvironment, getLog, getMessageHandler, getPersistence, getResource, initializeCompleted, prepareShutdown, setCapabilityURI, setEnvironment, setLog, setMessageHandlers, setPersistence, setResource |
Methods inherited from interface org.apache.muse.core.Initialization |
---|
hasBeenInitialized |
Methods inherited from interface org.apache.muse.core.InitializationParameters |
---|
getInitializationParameter, getInitializationParameters, setInitializationParameters |
Methods inherited from interface org.apache.muse.core.Shutdown |
---|
hasBeenShutdown, shutdown |
Constructor Detail |
---|
public SimpleSubscriptionManager()
Method Detail |
---|
protected NotificationConsumerClient createConsumerClient()
protected NotificationConsumerClient getConsumerClient()
public EndpointReference getConsumerReference()
getConsumerReference
in interface SubscriptionManager
public Date getCreationTime()
getCreationTime
in interface SubscriptionManager
public Filter getFilter()
getFilter
in interface SubscriptionManager
protected int getNumberOfTries()
public EndpointReference getProducerReference()
getProducerReference
in interface SubscriptionManager
public QName[] getPropertyNames()
getPropertyNames
in class AbstractWsResourceCapability
public Policy getSubscriptionPolicy()
getSubscriptionPolicy
in interface SubscriptionManager
public void initialize() throws SoapFault
AbstractWsResourceCapability
initialize
in interface Initialization
initialize
in class AbstractWsResourceCapability
SoapFault
protected boolean isDestroyedOnFailure()
public boolean isPaused()
isPaused
in interface SubscriptionManager
protected boolean isUsingTrace()
public void pauseSubscription()
SubscriptionManager
pauseSubscription
in interface SubscriptionManager
public void publish(NotificationMessage message)
SubscriptionManager
publish
in interface SubscriptionManager
public void resumeSubscription()
SubscriptionManager
resumeSubscription
in interface SubscriptionManager
public void setConsumerReference(EndpointReference consumer)
setConsumerReference
in interface SubscriptionManager
public void setFilter(Filter filter)
setFilter
in interface SubscriptionManager
public void setProducerReference(EndpointReference producer)
setProducerReference
in interface SubscriptionManager
public void setSubscriptionPolicy(Policy policy)
setSubscriptionPolicy
in interface SubscriptionManager
public Element toXML()
XmlSerializable
toXML
in interface XmlSerializable
public Element toXML(Document doc)
XmlSerializable
toXML
in interface XmlSerializable
doc
- The DOM Document that will be used to create all of the nodes
in the resulting XML fragment.
public void deleteProperty(QName property) throws BaseFault
BaseFault
public Element[] getProperty(QName property) throws BaseFault
BaseFault
public void insertProperty(QName property, Element[] values) throws BaseFault
BaseFault
public void updateProperty(QName property, Element[] values) throws BaseFault
BaseFault
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |