org.apache.uima.adapter.jms.activemq
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
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
producerSession
protected javax.jms.Session producerSession
connectionCreationTimestamp
protected static long connectionCreationTimestamp
JmsEndpointConnection_impl
public JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap,
Endpoint anEndpoint,
AnalysisEngineController aController)
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
- Throws:
AsynchAEException
ServiceShutdownException
open
public void open(java.lang.String brokerUri,
java.lang.String anEndpointName)
throws AsynchAEException,
ServiceShutdownException
- 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 interface org.apache.activemq.advisory.ConsumerListener
finalize
protected void finalize()
throws java.lang.Throwable
- Overrides:
finalize
in class java.lang.Object
- Throws:
java.lang.Throwable
Copyright © 2012. All Rights Reserved.