public interface AMQConnectionDelegate
Modifier and Type | Method and Description |
---|---|
void |
closeConnection(long timeout) |
Session |
createSession(boolean transacted,
int acknowledgeMode,
int prefetchHigh,
int prefetchLow) |
javax.jms.XASession |
createXASession()
Create an XASession with default prefetch values of:
High = MaxPrefetch
Low = MaxPrefetch / 2
|
javax.jms.XASession |
createXASession(int ackMode) |
javax.jms.XASession |
createXASession(int prefetchHigh,
int prefetchLow) |
<T,E extends Exception> |
executeRetrySupport(FailoverProtectedOperation<T,E> operation) |
int |
getMaxChannelID() |
int |
getMinChannelID() |
ProtocolVersion |
getProtocolVersion() |
boolean |
isMessageCompressionSupported() |
boolean |
isSupportedServerFeature(String featureName)
Tests whether the server has advertised support for the specified feature
via the qpid.features server connection property.
|
boolean |
isVirtualHostPropertiesSupported() |
ProtocolVersion |
makeBrokerConnection(BrokerDetails brokerDetail) |
void |
resubscribeSessions() |
void |
setHeartbeatListener(HeartbeatListener listener) |
boolean |
supportsIsBound() |
boolean |
verifyClientID() |
ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail) throws IOException, QpidException
IOException
QpidException
Session createSession(boolean transacted, int acknowledgeMode, int prefetchHigh, int prefetchLow) throws javax.jms.JMSException
javax.jms.JMSException
javax.jms.XASession createXASession() throws javax.jms.JMSException
javax.jms.JMSException
- thrown if there is a problem creating the session.javax.jms.XASession createXASession(int prefetchHigh, int prefetchLow) throws javax.jms.JMSException
javax.jms.JMSException
javax.jms.XASession createXASession(int ackMode) throws javax.jms.JMSException
javax.jms.JMSException
void resubscribeSessions() throws javax.jms.JMSException, QpidException, FailoverException
javax.jms.JMSException
QpidException
FailoverException
void closeConnection(long timeout) throws javax.jms.JMSException, QpidException
javax.jms.JMSException
QpidException
<T,E extends Exception> T executeRetrySupport(FailoverProtectedOperation<T,E> operation) throws E extends Exception
E extends Exception
int getMaxChannelID()
int getMinChannelID()
ProtocolVersion getProtocolVersion()
boolean verifyClientID() throws javax.jms.JMSException, QpidException
javax.jms.JMSException
QpidException
boolean isSupportedServerFeature(String featureName)
qpid.
followed by one or more words separated by minus signs
e.g. qpid.jms-selector.featureName
- name of feature.void setHeartbeatListener(HeartbeatListener listener)
boolean supportsIsBound()
boolean isMessageCompressionSupported()
boolean isVirtualHostPropertiesSupported()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.