org.apache.qpid.client
Class AMQConnectionDelegate_8_0

java.lang.Object
  extended by 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


Constructor Summary
AMQConnectionDelegate_8_0(AMQConnection conn)
           
 
Method Summary
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)
           
 XASession createXASession()
          Create an XASession with default prefetch values of: High = MaxPrefetch Low = MaxPrefetch / 2
 XASession createXASession(int prefetchHigh, int prefetchLow)
           
<T,E extends Exception>
T
executeRetrySupport(FailoverProtectedOperation<T,E> operation)
           
 void failoverPrep()
           
 int getMaxChannelID()
           
 org.apache.qpid.framing.ProtocolVersion getProtocolVersion()
           
 org.apache.qpid.framing.ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail)
           
 void resubscribeSessions()
          For all sessions, and for all consumers in those sessions, resubscribe.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AMQConnectionDelegate_8_0

public AMQConnectionDelegate_8_0(AMQConnection conn)
Method Detail

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