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 Object
- implements org.apache.activemq.advisory.ConsumerListener
producerSession
protected javax.jms.Session producerSession
connectionCreationTimestamp
protected static long connectionCreationTimestamp
JmsEndpointConnection_impl
public JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap,
org.apache.uima.aae.controller.Endpoint anEndpoint,
org.apache.uima.aae.controller.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 org.apache.uima.aae.error.AsynchAEException,
org.apache.uima.aae.error.ServiceShutdownException
- Throws:
org.apache.uima.aae.error.AsynchAEException
org.apache.uima.aae.error.ServiceShutdownException
open
public void open(String anEndpointName,
String brokerUri)
throws org.apache.uima.aae.error.AsynchAEException,
org.apache.uima.aae.error.ServiceShutdownException
- Throws:
org.apache.uima.aae.error.AsynchAEException
org.apache.uima.aae.error.ServiceShutdownException
abort
public void abort()
close
public void close()
throws Exception
- Throws:
Exception
getEndpoint
protected String getEndpoint()
setEndpoint
protected void setEndpoint(String endpoint)
setDelegateEndpoint
protected void setDelegateEndpoint(org.apache.uima.aae.controller.Endpoint delegateEndpoint)
getServerUri
protected String getServerUri()
setServerUri
protected void setServerUri(String serverUri)
produceTextMessage
public javax.jms.TextMessage produceTextMessage(String aTextMessage)
throws org.apache.uima.aae.error.AsynchAEException
- Throws:
org.apache.uima.aae.error.AsynchAEException
produceByteMessage
public javax.jms.BytesMessage produceByteMessage(byte[] aSerializedCAS)
throws org.apache.uima.aae.error.AsynchAEException
- Throws:
org.apache.uima.aae.error.AsynchAEException
produceObjectMessage
public javax.jms.ObjectMessage produceObjectMessage()
throws org.apache.uima.aae.error.AsynchAEException
- Throws:
org.apache.uima.aae.error.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 Throwable
- Overrides:
finalize
in class Object
- Throws:
Throwable
Copyright © 2006-2012 The Apache Software Foundation. All Rights Reserved.