org.skyscreamer.nevado.jms.connector

Class AbstractSQSConnectorFactory

java.lang.Object

org.skyscreamer.nevado.jms.connector.AbstractSQSConnectorFactory

All Implemented Interfaces:

SQSConnectorFactory

Direct Known Subclasses:

AmazonAwsSQSConnectorFactory

public abstract class AbstractSQSConnectorFactory
extends Object
implements SQSConnectorFactory

Abstract implementation of factory for SQSConnector objects.

Author:

Carter Page

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	_isSecure
protected org.apache.commons.logging.Log	_log
protected long	_receiveCheckIntervalMs
static int	DEFAULT_RECEIVE_CHECK_INTERVAL_MS

Constructor Summary

Constructors

Constructor and Description
AbstractSQSConnectorFactory()

Method Summary

Methods

Modifier and Type	Method and Description
SQSConnector	getInstance(String awsAccessKey, String awsSecretKey)
abstract SQSConnector	getInstance(String awsAccessKey, String awsSecretKey, String awsSQSEndpoint, String awsSNSEndpoint)
void	setReceiveCheckIntervalMs(long receiveCheckIntervalMs)
void	setSecure(boolean secure)

Methods inherited from class java.lang.Object

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

Field Detail

_log

protected final org.apache.commons.logging.Log _log

DEFAULT_RECEIVE_CHECK_INTERVAL_MS

public static final int DEFAULT_RECEIVE_CHECK_INTERVAL_MS

See Also:

Constant Field Values

_isSecure

protected boolean _isSecure

_receiveCheckIntervalMs

protected long _receiveCheckIntervalMs

Constructor Detail

AbstractSQSConnectorFactory

public AbstractSQSConnectorFactory()

Method Detail

getInstance

public abstract SQSConnector getInstance(String awsAccessKey,
                       String awsSecretKey,
                       String awsSQSEndpoint,
                       String awsSNSEndpoint)
                                  throws javax.jms.JMSException

Specified by:

getInstance in interface SQSConnectorFactory

Throws:

javax.jms.JMSException

getInstance

public SQSConnector getInstance(String awsAccessKey,
                       String awsSecretKey)
                         throws javax.jms.JMSException

Specified by:

getInstance in interface SQSConnectorFactory

Throws:

javax.jms.JMSException

setSecure

public void setSecure(boolean secure)

setReceiveCheckIntervalMs

public void setReceiveCheckIntervalMs(long receiveCheckIntervalMs)