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

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 String

getEndpoint()

protected String

getServerUri()

boolean

isOpen()

boolean

isRetryEnabled()

void

onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0)

void

open()

void

open(String brokerUri, String anEndpointName)

javax.jms.BytesMessage

produceByteMessage(byte[] aSerializedCAS)

javax.jms.ObjectMessage

produceObjectMessage()

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)

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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
  
  public void open() throws AsynchAEException, ServiceShutdownException
  
  Throws:
  
  AsynchAEException
  
  ServiceShutdownException
- open
  
  public void open(String brokerUri, String anEndpointName) throws AsynchAEException, ServiceShutdownException
  
  Throws:
  
  AsynchAEException
  
  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(Endpoint delegateEndpoint)
- getServerUri
  
  protected String getServerUri()
- setServerUri
  
  protected void setServerUri(String serverUri)
- produceTextMessage
  
  public javax.jms.TextMessage produceTextMessage(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 Throwable
  
  Overrides:
  
  finalize in class Object
  
  Throws:
  
  Throwable

Class JmsEndpointConnection_impl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

producerSession

connectionCreationTimestamp

Constructor Details

JmsEndpointConnection_impl

Method Details

isRetryEnabled

setRetryEnabled

isOpen

connectionClosedOrFailed

open

open

abort

close

getEndpoint

setEndpoint

setDelegateEndpoint

getServerUri

setServerUri

produceTextMessage

produceByteMessage

produceObjectMessage

send

send

onConsumerEvent

finalize