Class JmsEndpointConnection_impl
- java.lang.Object
-
- org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl
-
- All Implemented Interfaces:
org.apache.activemq.advisory.ConsumerListener
public class JmsEndpointConnection_impl extends java.lang.Object implements org.apache.activemq.advisory.ConsumerListener
-
-
Field Summary
Fields Modifier and Type Field Description protected static long
connectionCreationTimestamp
protected javax.jms.Session
producerSession
-
Constructor Summary
Constructors Constructor Description JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, Endpoint anEndpoint, AnalysisEngineController aController)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
abort()
void
close()
protected static boolean
connectionClosedOrFailed(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap)
protected void
finalize()
protected java.lang.String
getEndpoint()
protected java.lang.String
getServerUri()
boolean
isOpen()
boolean
isRetryEnabled()
void
onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0)
void
open()
void
open(java.lang.String brokerUri, java.lang.String anEndpointName)
javax.jms.BytesMessage
produceByteMessage(byte[] aSerializedCAS)
javax.jms.ObjectMessage
produceObjectMessage()
javax.jms.TextMessage
produceTextMessage(java.lang.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(Endpoint delegateEndpoint)
protected void
setEndpoint(java.lang.String endpoint)
void
setRetryEnabled(boolean retryEnabled)
protected void
setServerUri(java.lang.String serverUri)
-
-
-
Constructor Detail
-
JmsEndpointConnection_impl
public JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, Endpoint anEndpoint, AnalysisEngineController aController)
-
-
Method Detail
-
isRetryEnabled
public boolean isRetryEnabled()
-
setRetryEnabled
public void setRetryEnabled(boolean retryEnabled)
-
isOpen
public boolean isOpen()
-
connectionClosedOrFailed
protected static boolean connectionClosedOrFailed(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap)
-
open
public void open() throws AsynchAEException, ServiceShutdownException
-
open
public void open(java.lang.String brokerUri, java.lang.String anEndpointName) throws AsynchAEException, ServiceShutdownException
-
abort
public void abort()
-
close
public void close() throws java.lang.Exception
- Throws:
java.lang.Exception
-
getEndpoint
protected java.lang.String getEndpoint()
-
setEndpoint
protected void setEndpoint(java.lang.String endpoint)
-
setDelegateEndpoint
protected void setDelegateEndpoint(Endpoint delegateEndpoint)
-
getServerUri
protected java.lang.String getServerUri()
-
setServerUri
protected void setServerUri(java.lang.String serverUri)
-
produceTextMessage
public javax.jms.TextMessage produceTextMessage(java.lang.String aTextMessage) throws AsynchAEException
- Throws:
AsynchAEException
-
produceByteMessage
public javax.jms.BytesMessage produceByteMessage(byte[] aSerializedCAS) throws AsynchAEException
- Throws:
AsynchAEException
-
produceObjectMessage
public javax.jms.ObjectMessage produceObjectMessage() throws AsynchAEException
- Throws:
AsynchAEException
-
send
public boolean send(javax.jms.Message aMessage, long msgSize, boolean startTimer)
-
send
public boolean send(javax.jms.Message aMessage, long msgSize, boolean startTimer, boolean failOnJMSException)
-
onConsumerEvent
public void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0)
- Specified by:
onConsumerEvent
in interfaceorg.apache.activemq.advisory.ConsumerListener
-
finalize
protected void finalize() throws java.lang.Throwable
- Overrides:
finalize
in classjava.lang.Object
- Throws:
java.lang.Throwable
-
-