org.apache.uima.adapter.jms.activemq
Class JmsEndpointConnection_impl

java.lang.Object
  extended by 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
protected static long connectionCreationTimestamp
           
protected  javax.jms.Session producerSession
           
 
Constructor Summary
JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, Endpoint anEndpoint, AnalysisEngineController aController)
           
 
Method Summary
 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


Copyright © 2012. All Rights Reserved.