org.apache.qpid.client
Interface AMQConnectionDelegate

All Known Implementing Classes:
AMQConnectionDelegate_0_10, AMQConnectionDelegate_0_9, AMQConnectionDelegate_8_0, AMQConnectionDelegate_9_1

public interface AMQConnectionDelegate


Method Summary
 void closeConnection(long timeout)
           
 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()
           
 

Method Detail

makeBrokerConnection

org.apache.qpid.framing.ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail)
                                                             throws IOException,
                                                                    org.apache.qpid.AMQException
Throws:
IOException
org.apache.qpid.AMQException

createSession

Session createSession(boolean transacted,
                      int acknowledgeMode,
                      int prefetchHigh,
                      int prefetchLow)
                      throws JMSException
Throws:
JMSException

createXASession

XASession createXASession()
                          throws JMSException
Create an XASession with default prefetch values of: High = MaxPrefetch Low = MaxPrefetch / 2

Returns:
XASession
Throws:
JMSException - thrown if there is a problem creating the session.

createXASession

XASession createXASession(int prefetchHigh,
                          int prefetchLow)
                          throws JMSException
Throws:
JMSException

failoverPrep

void failoverPrep()

resubscribeSessions

void resubscribeSessions()
                         throws JMSException,
                                org.apache.qpid.AMQException,
                                FailoverException
Throws:
JMSException
org.apache.qpid.AMQException
FailoverException

closeConnection

void closeConnection(long timeout)
                     throws JMSException,
                            org.apache.qpid.AMQException
Throws:
JMSException
org.apache.qpid.AMQException

executeRetrySupport

<T,E extends Exception> T executeRetrySupport(FailoverProtectedOperation<T,E> operation)
                      throws E extends Exception
Throws:
E extends Exception

getMaxChannelID

int getMaxChannelID()

getProtocolVersion

org.apache.qpid.framing.ProtocolVersion getProtocolVersion()


Licensed to the Apache Software Foundation