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.AnalysisEngineController |
controller |
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) |
org.apache.activemq.AsyncCallback |
createAMQCallbackListener(int command,
javax.jms.Message aMessage) |
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 org.apache.uima.aae.controller.AnalysisEngineController controller
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, ConnectException
public void open(String anEndpointName, String brokerUri) throws org.apache.uima.aae.error.AsynchAEException, org.apache.uima.aae.error.ServiceShutdownException, ConnectException
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, ConnectException
public javax.jms.BytesMessage produceByteMessage(byte[] aSerializedCAS) throws org.apache.uima.aae.error.AsynchAEException, ConnectException
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 org.apache.activemq.AsyncCallback createAMQCallbackListener(int command, javax.jms.Message aMessage) throws Exception
Exception
public void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0)
onConsumerEvent
in interface org.apache.activemq.advisory.ConsumerListener
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.