public class AMQConnectionDelegate_8_0 extends Object implements AMQConnectionDelegate
Constructor and Description |
---|
AMQConnectionDelegate_8_0(AMQConnection conn) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkException(Throwable thrown) |
void |
closeConnection(long timeout) |
Session |
createSession(boolean transacted,
int acknowledgeMode,
int prefetch) |
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 |
isAddrSyntaxSupported() |
boolean |
isConfirmedPublishNonTransactionalSupported() |
boolean |
isConfirmedPublishSupported() |
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()
For all sessions, and for all consumers in those sessions, resubscribe.
|
void |
setHeartbeatListener(HeartbeatListener listener) |
boolean |
supportsIsBound() |
boolean |
verifyClientID() |
public AMQConnectionDelegate_8_0(AMQConnection conn)
public void closeConnection(long timeout) throws javax.jms.JMSException, QpidException
closeConnection
in interface AMQConnectionDelegate
javax.jms.JMSException
QpidException
protected boolean checkException(Throwable thrown)
public boolean isConfirmedPublishSupported()
public ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail) throws QpidException
makeBrokerConnection
in interface AMQConnectionDelegate
QpidException
public Session createSession(boolean transacted, int acknowledgeMode, int prefetch) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.XASession createXASession(int prefetchHigh, int prefetchLow) throws javax.jms.JMSException
createXASession
in interface AMQConnectionDelegate
javax.jms.JMSException
public javax.jms.XASession createXASession(int ackMode) throws javax.jms.JMSException
createXASession
in interface AMQConnectionDelegate
javax.jms.JMSException
public Session createSession(boolean transacted, int acknowledgeMode, int prefetchHigh, int prefetchLow) throws javax.jms.JMSException
createSession
in interface AMQConnectionDelegate
javax.jms.JMSException
public javax.jms.XASession createXASession() throws javax.jms.JMSException
createXASession
in interface AMQConnectionDelegate
javax.jms.JMSException
- thrown if there is a problem creating the session.public void resubscribeSessions() throws javax.jms.JMSException, QpidException, FailoverException
resubscribeSessions
in interface AMQConnectionDelegate
javax.jms.JMSException
QpidException
FailoverException
public <T,E extends Exception> T executeRetrySupport(FailoverProtectedOperation<T,E> operation) throws E extends Exception
executeRetrySupport
in interface AMQConnectionDelegate
E extends Exception
public int getMaxChannelID()
getMaxChannelID
in interface AMQConnectionDelegate
public int getMinChannelID()
getMinChannelID
in interface AMQConnectionDelegate
public ProtocolVersion getProtocolVersion()
getProtocolVersion
in interface AMQConnectionDelegate
public boolean verifyClientID() throws javax.jms.JMSException
verifyClientID
in interface AMQConnectionDelegate
javax.jms.JMSException
public boolean isSupportedServerFeature(String featureName)
AMQConnectionDelegate
qpid.
followed by one or more words separated by minus signs
e.g. qpid.jms-selector.isSupportedServerFeature
in interface AMQConnectionDelegate
featureName
- name of feature.public void setHeartbeatListener(HeartbeatListener listener)
setHeartbeatListener
in interface AMQConnectionDelegate
public boolean supportsIsBound()
supportsIsBound
in interface AMQConnectionDelegate
public boolean isMessageCompressionSupported()
isMessageCompressionSupported
in interface AMQConnectionDelegate
public boolean isVirtualHostPropertiesSupported()
isVirtualHostPropertiesSupported
in interface AMQConnectionDelegate
public boolean isAddrSyntaxSupported()
public boolean isConfirmedPublishNonTransactionalSupported()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.