org.apache.qpid.client
Class AMQConnectionDelegate_0_10

java.lang.Object
  extended by org.apache.qpid.client.AMQConnectionDelegate_0_10
All Implemented Interfaces:
AMQConnectionDelegate, org.apache.qpid.transport.ConnectionListener

public class AMQConnectionDelegate_0_10
extends Object
implements AMQConnectionDelegate, org.apache.qpid.transport.ConnectionListener


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)
           
<T,E extends Exception>
T
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

_qpidConnection

org.apache.qpid.transport.Connection _qpidConnection
The QpidConeection instance that is mapped with thie JMS connection.

Constructor Detail

AMQConnectionDelegate_0_10

public AMQConnectionDelegate_0_10(AMQConnection conn)
Method Detail

createSession

public Session createSession(boolean transacted,
                             int acknowledgeMode,
                             int prefetchHigh,
                             int prefetchLow)
                      throws JMSException
create a Session and start it if required.

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

createXASession

public XASession createXASession(int prefetchHigh,
                                 int prefetchLow)
                          throws JMSException
create an XA Session and start it if required.

Specified by:
createXASession in interface AMQConnectionDelegate
Throws:
JMSException

makeBrokerConnection

public org.apache.qpid.framing.ProtocolVersion makeBrokerConnection(BrokerDetails brokerDetail)
                                                             throws IOException,
                                                                    org.apache.qpid.AMQException
Make a connection with the broker

Specified by:
makeBrokerConnection in interface AMQConnectionDelegate
Parameters:
brokerDetail - The detail of the broker to connect to.
Throws:
IOException
org.apache.qpid.AMQException

failoverPrep

public void failoverPrep()
Specified by:
failoverPrep in interface AMQConnectionDelegate

resubscribeSessions

public void resubscribeSessions()
                         throws JMSException,
                                org.apache.qpid.AMQException,
                                FailoverException
Specified by:
resubscribeSessions in interface AMQConnectionDelegate
Throws:
JMSException
org.apache.qpid.AMQException
FailoverException

closeConnection

public void closeConnection(long timeout)
                     throws JMSException,
                            org.apache.qpid.AMQException
Specified by:
closeConnection in interface AMQConnectionDelegate
Throws:
JMSException
org.apache.qpid.AMQException

opened

public void opened(org.apache.qpid.transport.Connection conn)
Specified by:
opened in interface org.apache.qpid.transport.ConnectionListener

exception

public void exception(org.apache.qpid.transport.Connection conn,
                      org.apache.qpid.transport.ConnectionException exc)
Specified by:
exception in interface org.apache.qpid.transport.ConnectionListener

closed

public void closed(org.apache.qpid.transport.Connection conn)
Specified by:
closed in interface org.apache.qpid.transport.ConnectionListener

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

getQpidConnection

protected org.apache.qpid.transport.Connection getQpidConnection()


Licensed to the Apache Software Foundation