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
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