public class JmsEndpointConnection_impl extends 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 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) |
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(String brokerUri, String anEndpointName) throws AsynchAEException, ServiceShutdownException
public void abort()
protected String getEndpoint()
protected void setEndpoint(String endpoint)
protected void setDelegateEndpoint(Endpoint delegateEndpoint)
protected String getServerUri()
protected void setServerUri(String serverUri)
public javax.jms.TextMessage produceTextMessage(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
Copyright © 2016. All rights reserved.