|
SolarMetric Kodo JDO 3.3.5 generated on August 31 2005 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--kodo.event.AbstractRemoteCommitProvider | +--kodo.event.JMSRemoteCommitProvider
JMS-based implementation of RemoteCommitProvider
that
listens for object modifications and propagates those changes to
other RemoteCommitProviders over a JMS topic.
Fields inherited from class kodo.event.AbstractRemoteCommitProvider |
eventManager, log |
Constructor Summary | |
JMSRemoteCommitProvider()
|
Method Summary | |
void |
broadcast(RemoteCommitEvent event)
Notifies other remote event managers in this JVM and on other machines of changes to the cache. |
void |
close()
Close any resources used by this provider |
protected Message |
createMessage(RemoteCommitEvent event)
Returns a new Message to send to the topic. |
void |
endConfiguration()
Subclasses that need to perform actions in Configurable.endConfiguration() must invoke this method. |
protected MessageListener |
getMessageListener()
Returns a MessageListener capable of
understanding and processing messages created by
createMessage(kodo.event.RemoteCommitEvent) . |
protected Context |
newContext()
Returns a new Context object for use by this
provider. |
void |
onException(JMSException ex)
|
void |
setExceptionReconnectAttempts(int attempts)
The number of times to attempt to reconnect after a JMS send exception is detected. |
void |
setInto(Map m)
Set a map of properties to pass to the InitialContext
constructor for JNDI lookups. |
void |
setTopic(String name)
Sets the JMS Topic name. |
void |
setTopicConnectionFactory(String name)
Sets the JMS TopicConnectionFactory name. |
Methods inherited from class kodo.event.AbstractRemoteCommitProvider |
setConfiguration, setRemoteCommitEventManager, startConfiguration |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface com.solarmetric.conf.Configurable |
setConfiguration, startConfiguration |
Constructor Detail |
public JMSRemoteCommitProvider()
Method Detail |
public void setTopic(String name)
topic/KodoCommitProviderTopic
.public void setTopicConnectionFactory(String name)
java:/ConnectionFactory
.public void setExceptionReconnectAttempts(int attempts)
public void setInto(Map m)
InitialContext
constructor for JNDI lookups. Implementation of
GenericConfigurable
.setInto
in interface GenericConfigurable
protected Context newContext() throws NamingException
Context
object for use by this
provider.public void broadcast(RemoteCommitEvent event)
RemoteCommitProvider
public void close()
RemoteCommitProvider
public void endConfiguration()
Configurable.endConfiguration()
must invoke this method.endConfiguration
in interface Configurable
endConfiguration
in class AbstractRemoteCommitProvider
protected MessageListener getMessageListener()
Returns a MessageListener
capable of
understanding and processing messages created by
createMessage(kodo.event.RemoteCommitEvent)
.
The listener returned by this method is responsible for notifying the provider that a remote event has been received.
protected Message createMessage(RemoteCommitEvent event) throws JMSException
Message
to send to the topic. This
implementation creates an ObjectMessage
.public void onException(JMSException ex)
onException
in interface ExceptionListener
|
SolarMetric Kodo JDO 3.3.5 generated on August 31 2005 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |