public class AMQConnectionDelegate_0_10 extends Object implements AMQConnectionDelegate, ConnectionListener, FrameSizeObserver
Constructor and Description |
---|
AMQConnectionDelegate_0_10(AMQConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
closeConnection(long timeout) |
void |
closed(Connection conn) |
Session |
createSession(boolean transacted,
int acknowledgeMode,
int prefetchHigh,
int prefetchLow)
create a Session and start it if required.
|
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)
create an XA Session and start it if required.
|
void |
exception(Connection conn,
ConnectionException exc) |
<T,E extends Exception> |
executeRetrySupport(FailoverProtectedOperation<T,E> operation) |
void |
failoverPrep() |
int |
getMaxChannelID() |
int |
getMinChannelID() |
ProtocolVersion |
getProtocolVersion() |
protected Connection |
getQpidConnection() |
String |
getUUID() |
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)
Make a connection with the broker
|
void |
opened(Connection conn) |
boolean |
redirect(String host,
List<Object> knownHosts) |
void |
resubscribeSessions() |
void |
setHeartbeatListener(HeartbeatListener listener) |
void |
setMaxFrameSize(int frameSize) |
boolean |
supportsIsBound() |
boolean |
verifyClientID() |
public AMQConnectionDelegate_0_10(AMQConnection conn)
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
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 ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail) throws IOException, QpidException
makeBrokerConnection
in interface AMQConnectionDelegate
brokerDetail
- The detail of the broker to connect to.IOException
QpidException
public void failoverPrep()
public void resubscribeSessions() throws javax.jms.JMSException, QpidException, FailoverException
resubscribeSessions
in interface AMQConnectionDelegate
javax.jms.JMSException
QpidException
FailoverException
public void closeConnection(long timeout) throws javax.jms.JMSException, QpidException
closeConnection
in interface AMQConnectionDelegate
javax.jms.JMSException
QpidException
public void opened(Connection conn)
opened
in interface ConnectionListener
public void exception(Connection conn, ConnectionException exc)
exception
in interface ConnectionListener
public void closed(Connection conn)
closed
in interface ConnectionListener
public boolean redirect(String host, List<Object> knownHosts)
redirect
in interface ConnectionListener
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 String getUUID()
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
protected Connection getQpidConnection()
public boolean verifyClientID() throws javax.jms.JMSException, QpidException
verifyClientID
in interface AMQConnectionDelegate
javax.jms.JMSException
QpidException
public boolean supportsIsBound()
supportsIsBound
in interface AMQConnectionDelegate
public boolean isMessageCompressionSupported()
isMessageCompressionSupported
in interface AMQConnectionDelegate
public boolean isVirtualHostPropertiesSupported()
isVirtualHostPropertiesSupported
in interface AMQConnectionDelegate
public void setMaxFrameSize(int frameSize)
setMaxFrameSize
in interface FrameSizeObserver
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.