org.skyscreamer.nevado.jms.connector.amazonaws

Class AmazonAwsSQSConnectorFactory

java.lang.Object

org.skyscreamer.nevado.jms.connector.AbstractSQSConnectorFactory

org.skyscreamer.nevado.jms.connector.amazonaws.AmazonAwsSQSConnectorFactory

All Implemented Interfaces:

SQSConnectorFactory

Direct Known Subclasses:

PlainTextAmazonSQSConnectorFactory

public class AmazonAwsSQSConnectorFactory
extends AbstractSQSConnectorFactory

Connectory factory for Amazon AWS connector.

Author:

Carter Page

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	_useAsyncSend

Fields inherited from class org.skyscreamer.nevado.jms.connector.AbstractSQSConnectorFactory

_isSecure, _log, _receiveCheckIntervalMs, DEFAULT_RECEIVE_CHECK_INTERVAL_MS

Constructor Summary

Constructors

Constructor and Description
AmazonAwsSQSConnectorFactory()

Method Summary

Methods

Modifier and Type	Method and Description
protected AmazonAwsSQSConnector	createConnector(String awsAccessKey, String awsSecretKey)
AmazonAwsSQSConnector	getInstance(String awsAccessKey, String awsSecretKey, String awsSQSEndpoint, String awsSNSEndpoint)
boolean	isUseAsyncSend()
void	setUseAsyncSend(boolean useAsyncSend)

Methods inherited from class org.skyscreamer.nevado.jms.connector.AbstractSQSConnectorFactory

getInstance, setReceiveCheckIntervalMs, setSecure

Methods inherited from class java.lang.Object

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

Field Detail

_useAsyncSend

protected boolean _useAsyncSend

Constructor Detail

AmazonAwsSQSConnectorFactory

public AmazonAwsSQSConnectorFactory()

Method Detail

getInstance

public AmazonAwsSQSConnector getInstance(String awsAccessKey,
                                String awsSecretKey,
                                String awsSQSEndpoint,
                                String awsSNSEndpoint)

Specified by:

getInstance in interface SQSConnectorFactory

Specified by:

getInstance in class AbstractSQSConnectorFactory

createConnector

protected AmazonAwsSQSConnector createConnector(String awsAccessKey,
                                    String awsSecretKey)

setUseAsyncSend

public void setUseAsyncSend(boolean useAsyncSend)

isUseAsyncSend

public boolean isUseAsyncSend()