Package 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

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

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)

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

producerSession

protected javax.jms.Session producerSession

connectionCreationTimestamp

protected static long connectionCreationTimestamp

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

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