|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.client.AMQConnectionDelegate_0_10
public class AMQConnectionDelegate_0_10
Field Summary | |
---|---|
(package private) org.apache.qpid.transport.Connection |
_qpidConnection
The QpidConeection instance that is mapped with thie JMS connection. |
Constructor Summary | |
---|---|
AMQConnectionDelegate_0_10(AMQConnection conn)
|
Method Summary | ||
---|---|---|
void |
closeConnection(long timeout)
|
|
void |
closed(org.apache.qpid.transport.Connection conn)
|
|
Session |
createSession(boolean transacted,
int acknowledgeMode,
int prefetchHigh,
int prefetchLow)
create a Session and start it if required. |
|
XASession |
createXASession()
Create an XASession with default prefetch values of: High = MaxPrefetch Low = MaxPrefetch / 2 |
|
XASession |
createXASession(int prefetchHigh,
int prefetchLow)
create an XA Session and start it if required. |
|
void |
exception(org.apache.qpid.transport.Connection conn,
org.apache.qpid.transport.ConnectionException exc)
|
|
|
executeRetrySupport(FailoverProtectedOperation<T,E> operation)
|
|
void |
failoverPrep()
|
|
int |
getMaxChannelID()
|
|
org.apache.qpid.framing.ProtocolVersion |
getProtocolVersion()
|
|
protected org.apache.qpid.transport.Connection |
getQpidConnection()
|
|
org.apache.qpid.framing.ProtocolVersion |
makeBrokerConnection(BrokerDetails brokerDetail)
Make a connection with the broker |
|
void |
opened(org.apache.qpid.transport.Connection conn)
|
|
void |
resubscribeSessions()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
org.apache.qpid.transport.Connection _qpidConnection
Constructor Detail |
---|
public AMQConnectionDelegate_0_10(AMQConnection conn)
Method Detail |
---|
public Session createSession(boolean transacted, int acknowledgeMode, int prefetchHigh, int prefetchLow) throws JMSException
createSession
in interface AMQConnectionDelegate
JMSException
public XASession createXASession() throws JMSException
createXASession
in interface AMQConnectionDelegate
JMSException
public XASession createXASession(int prefetchHigh, int prefetchLow) throws JMSException
createXASession
in interface AMQConnectionDelegate
JMSException
public org.apache.qpid.framing.ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail) throws IOException, org.apache.qpid.AMQException
makeBrokerConnection
in interface AMQConnectionDelegate
brokerDetail
- The detail of the broker to connect to.
IOException
org.apache.qpid.AMQException
public void failoverPrep()
failoverPrep
in interface AMQConnectionDelegate
public void resubscribeSessions() throws JMSException, org.apache.qpid.AMQException, FailoverException
resubscribeSessions
in interface AMQConnectionDelegate
JMSException
org.apache.qpid.AMQException
FailoverException
public void closeConnection(long timeout) throws JMSException, org.apache.qpid.AMQException
closeConnection
in interface AMQConnectionDelegate
JMSException
org.apache.qpid.AMQException
public void opened(org.apache.qpid.transport.Connection conn)
opened
in interface org.apache.qpid.transport.ConnectionListener
public void exception(org.apache.qpid.transport.Connection conn, org.apache.qpid.transport.ConnectionException exc)
exception
in interface org.apache.qpid.transport.ConnectionListener
public void closed(org.apache.qpid.transport.Connection conn)
closed
in interface org.apache.qpid.transport.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 org.apache.qpid.framing.ProtocolVersion getProtocolVersion()
getProtocolVersion
in interface AMQConnectionDelegate
protected org.apache.qpid.transport.Connection getQpidConnection()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |