org.apache.qpid.client
Class AMQConnectionDelegate_8_0
java.lang.Object
org.apache.qpid.client.AMQConnectionDelegate_8_0
- All Implemented Interfaces:
- AMQConnectionDelegate
- Direct Known Subclasses:
- AMQConnectionDelegate_0_9, AMQConnectionDelegate_9_1
public class AMQConnectionDelegate_8_0
- extends Object
- implements AMQConnectionDelegate
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AMQConnectionDelegate_8_0
public AMQConnectionDelegate_8_0(AMQConnection conn)
closeConnection
public void closeConnection(long timeout)
throws JMSException,
org.apache.qpid.AMQException
- Specified by:
closeConnection
in interface AMQConnectionDelegate
- Throws:
JMSException
org.apache.qpid.AMQException
checkException
protected boolean checkException(Throwable thrown)
makeBrokerConnection
public org.apache.qpid.framing.ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail)
throws org.apache.qpid.AMQException,
IOException
- Specified by:
makeBrokerConnection
in interface AMQConnectionDelegate
- Throws:
org.apache.qpid.AMQException
IOException
createSession
public Session createSession(boolean transacted,
int acknowledgeMode,
int prefetch)
throws JMSException
- Throws:
JMSException
createXASession
public XASession createXASession(int prefetchHigh,
int prefetchLow)
throws JMSException
- Specified by:
createXASession
in interface AMQConnectionDelegate
- Throws:
JMSException
createSession
public Session createSession(boolean transacted,
int acknowledgeMode,
int prefetchHigh,
int prefetchLow)
throws JMSException
- Specified by:
createSession
in interface AMQConnectionDelegate
- Throws:
JMSException
createXASession
public XASession createXASession()
throws JMSException
- Create an XASession with default prefetch values of:
High = MaxPrefetch
Low = MaxPrefetch / 2
- Specified by:
createXASession
in interface AMQConnectionDelegate
- Returns:
- XASession
- Throws:
JMSException
- thrown if there is a problem creating the session.
failoverPrep
public void failoverPrep()
- Specified by:
failoverPrep
in interface AMQConnectionDelegate
resubscribeSessions
public void resubscribeSessions()
throws JMSException,
org.apache.qpid.AMQException,
FailoverException
- For all sessions, and for all consumers in those sessions, resubscribe. This is called during failover handling.
The caller must hold the failover mutex before calling this method.
- Specified by:
resubscribeSessions
in interface AMQConnectionDelegate
- Throws:
JMSException
org.apache.qpid.AMQException
FailoverException
executeRetrySupport
public <T,E extends Exception> T executeRetrySupport(FailoverProtectedOperation<T,E> operation)
throws E extends Exception
- Specified by:
executeRetrySupport
in interface AMQConnectionDelegate
- Throws:
E extends Exception
getMaxChannelID
public int getMaxChannelID()
- Specified by:
getMaxChannelID
in interface AMQConnectionDelegate
getProtocolVersion
public org.apache.qpid.framing.ProtocolVersion getProtocolVersion()
- Specified by:
getProtocolVersion
in interface AMQConnectionDelegate
Licensed to the Apache Software Foundation