Package | Description |
---|---|
org.apache.oozie.jms | |
org.apache.oozie.service |
Constructor and Description |
---|
JMSExceptionListener(JMSConnectionInfo connInfo,
ConnectionContext connCtxt,
boolean retry)
Create ExceptionLister for a JMS Connection
|
Modifier and Type | Method and Description |
---|---|
JMSConnectionInfo |
JMSAccessorService.JMSRetryRunnable.getJMSConnectionInfo() |
JMSConnectionInfo |
HCatAccessorService.getJMSConnectionInfo(URI publisherURI)
Given a publisher host:port return the connection details of JMS server that the publisher
publishes to
|
Modifier and Type | Method and Description |
---|---|
ConnectionContext |
JMSAccessorService.createConnectionContext(JMSConnectionInfo connInfo) |
ConnectionContext |
JMSAccessorService.createProducerConnectionContext(JMSConnectionInfo connInfo) |
void |
JMSAccessorService.reestablishConnection(JMSConnectionInfo connInfo)
Reestablish connection for the given JMS connect information
|
void |
JMSAccessorService.registerForNotification(JMSConnectionInfo connInfo,
String topic,
MessageHandler msgHandler)
Register for notifications on a JMS topic.
|
void |
JMSAccessorService.unregisterFromNotification(JMSConnectionInfo connInfo,
String topic)
Unregister from listening to JMS messages on a topic.
|
Constructor and Description |
---|
JMSRetryRunnable(JMSConnectionInfo connInfo) |
Copyright © 2018 Apache Software Foundation. All rights reserved.