JMSConnector

Overview

Package

Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS (src)

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.axis.transport.jms
Class JMSConnector

java.lang.Object
  org.jboss.axis.transport.jms.JMSConnector

Direct Known Subclasses:: QueueConnector (src) , TopicConnector (src)

public abstract class JMSConnector
extends java.lang.Object

JMSConnector is an abstract class that encapsulates the work of connecting to JMS destinations. Its subclasses are TopicConnector and QueueConnector which further specialize connections to the pub-sub and the ptp domains. It also implements the capability to retry connections in the event of failures.

Nested Class Summary
`protected class`	`JMSConnector.AsyncConnection (src)`
`protected class`	`JMSConnector.SyncConnection (src)`

Field Summary
`protected JMSVendorAdapter (src)`	`m_adapter`
`protected boolean`	`m_allowReceive`
`protected long`	`m_connectRetryInterval`
`protected long`	`m_interactRetryInterval`
`protected int`	`m_numRetries`
`protected int`	`m_numSessions`
`protected long`	`m_poolTimeout`
`protected JMSConnector.AsyncConnection (src)`	`m_receiveConnection`
`protected JMSConnector.SyncConnection (src)`	`m_sendConnection`
`protected long`	`m_timeoutTime`

Constructor Summary
`JMSConnector(ConnectionFactory (src) connectionFactory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, java.lang.String clientID, java.lang.String username, java.lang.String password, JMSVendorAdapter (src) adapter)`

Method Summary
`protected abstract JMSConnector.AsyncConnection (src)`	`createAsyncConnection(ConnectionFactory (src) factory, Connection (src) connection, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)`
`protected Connection (src)`	`createConnectionWithRetry(ConnectionFactory (src) connectionFactory, java.lang.String username, java.lang.String password)`
`abstract JMSEndpoint (src)`	`createEndpoint(Destination (src) destination)`
`abstract JMSEndpoint (src)`	`createEndpoint(java.lang.String destinationName)`
`protected abstract JMSConnector.SyncConnection (src)`	`createSyncConnection(ConnectionFactory (src) factory, Connection (src) connection, int numSessions, java.lang.String threadName, java.lang.String clientID, java.lang.String username, java.lang.String password)`
`protected abstract Connection (src)`	`internalConnect(ConnectionFactory (src) connectionFactory, java.lang.String username, java.lang.String password)`
`void`	`shutdown()`
`void`	`start()`
`void`	`stop()`

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

m_numRetries

protected int m_numRetries

m_connectRetryInterval

protected long m_connectRetryInterval

m_interactRetryInterval

protected long m_interactRetryInterval

m_timeoutTime

protected long m_timeoutTime

m_poolTimeout

protected long m_poolTimeout

m_receiveConnection

protected JMSConnector.AsyncConnection (src)  m_receiveConnection

m_sendConnection

protected JMSConnector.SyncConnection (src)  m_sendConnection

m_numSessions

protected int m_numSessions

m_allowReceive

protected boolean m_allowReceive

m_adapter

protected JMSVendorAdapter (src)  m_adapter

Constructor Detail

JMSConnector

public JMSConnector(ConnectionFactory (src)  connectionFactory,
                    int numRetries,
                    int numSessions,
                    long connectRetryInterval,
                    long interactRetryInterval,
                    long timeoutTime,
                    boolean allowReceive,
                    java.lang.String clientID,
                    java.lang.String username,
                    java.lang.String password,
                    JMSVendorAdapter (src)  adapter)
             throws JMSException (src)

Method Detail

createConnectionWithRetry

protected Connection (src)  createConnectionWithRetry(ConnectionFactory (src)  connectionFactory,
                                               java.lang.String username,
                                               java.lang.String password)
                                        throws JMSException (src)

Throws:: JMSException (src)

stop

public void stop()

start

public void start()

shutdown

public void shutdown()

createEndpoint

public abstract JMSEndpoint (src)  createEndpoint(java.lang.String destinationName)
                                    throws JMSException (src)

Throws:: JMSException (src)

createEndpoint

public abstract JMSEndpoint (src)  createEndpoint(Destination (src)  destination)
                                    throws JMSException (src)

Throws:: JMSException (src)

internalConnect

protected abstract Connection (src)  internalConnect(ConnectionFactory (src)  connectionFactory,
                                              java.lang.String username,
                                              java.lang.String password)
                                       throws JMSException (src)

Throws:: JMSException (src)

createSyncConnection

protected abstract JMSConnector.SyncConnection (src)  createSyncConnection(ConnectionFactory (src)  factory,
                                                                    Connection (src)  connection,
                                                                    int numSessions,
                                                                    java.lang.String threadName,
                                                                    java.lang.String clientID,
                                                                    java.lang.String username,
                                                                    java.lang.String password)
                                                             throws JMSException (src)

Throws:: JMSException (src)

createAsyncConnection

protected abstract JMSConnector.AsyncConnection (src)  createAsyncConnection(ConnectionFactory (src)  factory,
                                                                      Connection (src)  connection,
                                                                      java.lang.String threadName,
                                                                      java.lang.String clientID,
                                                                      java.lang.String username,
                                                                      java.lang.String password)
                                                               throws JMSException (src)