public class JmsEndpointConnection_impl
extends java.lang.Object
implements org.apache.activemq.advisory.ConsumerListener
Modifier and Type | Field and Description |
---|---|
protected static long |
connectionCreationTimestamp |
protected javax.jms.Session |
producerSession |
Constructor and Description |
---|
JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap,
Endpoint anEndpoint,
AnalysisEngineController aController) |
Modifier and Type | Method and 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) |
protected javax.jms.Session producerSession
protected static long connectionCreationTimestamp
public JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap, Endpoint anEndpoint, AnalysisEngineController aController)
public boolean isRetryEnabled()
public void setRetryEnabled(boolean retryEnabled)
public boolean isOpen()
protected static boolean connectionClosedOrFailed(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap)
public void open() throws AsynchAEException, ServiceShutdownException
public void open(java.lang.String brokerUri, java.lang.String anEndpointName) throws AsynchAEException, ServiceShutdownException
public void abort()
public void close() throws java.lang.Exception
java.lang.Exception
protected java.lang.String getEndpoint()
protected void setEndpoint(java.lang.String endpoint)
protected void setDelegateEndpoint(Endpoint delegateEndpoint)
protected java.lang.String getServerUri()
protected void setServerUri(java.lang.String serverUri)
public javax.jms.TextMessage produceTextMessage(java.lang.String aTextMessage) throws AsynchAEException
AsynchAEException
public javax.jms.BytesMessage produceByteMessage(byte[] aSerializedCAS) throws AsynchAEException
AsynchAEException
public javax.jms.ObjectMessage produceObjectMessage() throws AsynchAEException
AsynchAEException
public boolean send(javax.jms.Message aMessage, long msgSize, boolean startTimer)
public boolean send(javax.jms.Message aMessage, long msgSize, boolean startTimer, boolean failOnJMSException)
public void onConsumerEvent(org.apache.activemq.advisory.ConsumerEvent arg0)
onConsumerEvent
in interface org.apache.activemq.advisory.ConsumerListener
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
Copyright © 2012. All Rights Reserved.