org.apache.axis.transport.jms

Class TopicConnector

public class TopicConnector extends JMSConnector

TopicConnector is a concrete JMSConnector subclass that specifically handles connections to topics (pub-sub domain).

Author: Jaime Meritt (jmeritt@sonicsoftware.com) Richard Chung (rchung@sonicsoftware.com) Dave Chappell (chappell@sonicsoftware.com)

Constructor Summary
TopicConnector(TopicConnectionFactory factory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, String clientID, String username, String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl)
Method Summary
protected AsyncConnectioncreateAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password)
JMSEndpointcreateEndpoint(String destination)
JMSEndpointcreateEndpoint(Destination destination)
Create an endpoint for a queue destination.
protected SyncConnectioncreateSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password)
protected ConnectioninternalConnect(ConnectionFactory connectionFactory, String username, String password)

Constructor Detail

TopicConnector

public TopicConnector(TopicConnectionFactory factory, int numRetries, int numSessions, long connectRetryInterval, long interactRetryInterval, long timeoutTime, boolean allowReceive, String clientID, String username, String password, JMSVendorAdapter adapter, JMSURLHelper jmsurl)

Method Detail

createAsyncConnection

protected AsyncConnection createAsyncConnection(ConnectionFactory factory, Connection connection, String threadName, String clientID, String username, String password)

createEndpoint

public JMSEndpoint createEndpoint(String destination)

createEndpoint

public JMSEndpoint createEndpoint(Destination destination)
Create an endpoint for a queue destination.

Parameters: destination

Returns:

Throws: JMSException

createSyncConnection

protected SyncConnection createSyncConnection(ConnectionFactory factory, Connection connection, int numSessions, String threadName, String clientID, String username, String password)

internalConnect

protected Connection internalConnect(ConnectionFactory connectionFactory, String username, String password)
Copyright B) 2005 Apache Web Services Project. All Rights Reserved.