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 Object
implements org.apache.activemq.advisory.ConsumerListener
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static long
protected javax.jms.Session
-
Constructor Summary
ConstructorsConstructorDescriptionJmsEndpointConnection_impl
(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, Endpoint anEndpoint, AnalysisEngineController aController) -
Method Summary
Modifier and TypeMethodDescriptionvoid
abort()
void
close()
protected static boolean
connectionClosedOrFailed
(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap) protected void
finalize()
protected String
protected String
boolean
isOpen()
boolean
void
onConsumerEvent
(org.apache.activemq.advisory.ConsumerEvent arg0) void
open()
void
javax.jms.BytesMessage
produceByteMessage
(byte[] aSerializedCAS) javax.jms.ObjectMessage
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
(Endpoint delegateEndpoint) protected void
setEndpoint
(String endpoint) void
setRetryEnabled
(boolean retryEnabled) protected void
setServerUri
(String serverUri)
-
Field Details
-
producerSession
protected javax.jms.Session producerSession -
connectionCreationTimestamp
protected static long connectionCreationTimestamp
-
-
Constructor Details
-
JmsEndpointConnection_impl
public JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, Endpoint anEndpoint, AnalysisEngineController aController)
-
-
Method Details
-
isRetryEnabled
public boolean isRetryEnabled() -
setRetryEnabled
public void setRetryEnabled(boolean retryEnabled) -
isOpen
public boolean isOpen() -
connectionClosedOrFailed
protected static boolean connectionClosedOrFailed(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap) -
open
-
open
public void open(String brokerUri, String anEndpointName) throws AsynchAEException, ServiceShutdownException -
abort
public void abort() -
close
- Throws:
Exception
-
getEndpoint
-
setEndpoint
-
setDelegateEndpoint
-
getServerUri
-
setServerUri
-
produceTextMessage
- Throws:
AsynchAEException
-
produceByteMessage
- Throws:
AsynchAEException
-
produceObjectMessage
- 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
-