public class JmsEndpointConnection_impl extends Object implements org.apache.activemq.advisory.ConsumerListener
| Modifier and Type | Field and Description |
|---|---|
protected static long |
connectionCreationTimestamp |
protected org.apache.uima.aae.controller.Endpoint |
delegateEndpoint |
protected javax.jms.Destination |
destination |
protected boolean |
isReplyEndpoint |
protected AtomicLong |
lastDispatchTimestamp |
protected javax.jms.Session |
producerSession |
| Constructor and Description |
|---|
JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap,
org.apache.uima.aae.controller.Endpoint anEndpoint,
org.apache.uima.aae.controller.AnalysisEngineController aController) |
| Modifier and Type | Method and Description |
|---|---|
void |
abort() |
void |
close() |
protected static boolean |
connectionClosedOrFailed(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap) |
protected void |
finalize() |
protected String |
getEndpoint() |
protected String |
getServerUri() |
boolean |
isOpen() |
boolean |
isRetryEnabled() |
void |
onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0) |
void |
open() |
void |
open(String anEndpointName,
String brokerUri) |
javax.jms.BytesMessage |
produceByteMessage(byte[] aSerializedCAS) |
javax.jms.ObjectMessage |
produceObjectMessage() |
javax.jms.TextMessage |
produceTextMessage(String aTextMessage) |
boolean |
send(javax.jms.Message aMessage,
long msgSize,
boolean startTimer) |
boolean |
send(javax.jms.Message aMessage,
long msgSize,
boolean startTimer,
boolean failOnJMSException) |
protected void |
setDelegateEndpoint(org.apache.uima.aae.controller.Endpoint delegateEndpoint) |
protected void |
setEndpoint(String endpoint) |
void |
setRetryEnabled(boolean retryEnabled) |
protected void |
setServerUri(String serverUri) |
protected AtomicLong lastDispatchTimestamp
protected javax.jms.Destination destination
protected javax.jms.Session producerSession
protected org.apache.uima.aae.controller.Endpoint delegateEndpoint
protected static long connectionCreationTimestamp
protected boolean isReplyEndpoint
public JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, org.apache.uima.aae.controller.Endpoint anEndpoint, org.apache.uima.aae.controller.AnalysisEngineController aController)
public boolean isRetryEnabled()
public void setRetryEnabled(boolean retryEnabled)
public boolean isOpen()
protected static boolean connectionClosedOrFailed(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap)
public void open()
throws org.apache.uima.aae.error.AsynchAEException,
org.apache.uima.aae.error.ServiceShutdownException
public void open(String anEndpointName, String brokerUri) throws org.apache.uima.aae.error.AsynchAEException, org.apache.uima.aae.error.ServiceShutdownException
public void abort()
protected String getEndpoint()
protected void setEndpoint(String endpoint)
protected void setDelegateEndpoint(org.apache.uima.aae.controller.Endpoint delegateEndpoint)
protected String getServerUri()
protected void setServerUri(String serverUri)
public javax.jms.TextMessage produceTextMessage(String aTextMessage) throws org.apache.uima.aae.error.AsynchAEException
public javax.jms.BytesMessage produceByteMessage(byte[] aSerializedCAS)
throws org.apache.uima.aae.error.AsynchAEException
public javax.jms.ObjectMessage produceObjectMessage()
throws org.apache.uima.aae.error.AsynchAEException
public boolean send(javax.jms.Message aMessage,
long msgSize,
boolean startTimer)
public boolean send(javax.jms.Message aMessage,
long msgSize,
boolean startTimer,
boolean failOnJMSException)
public void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0)
onConsumerEvent in interface org.apache.activemq.advisory.ConsumerListenerCopyright © 2006–2016 The Apache Software Foundation. All rights reserved.