org.hornetq.jms.bridge.impl

Class JMSBridgeImpl

java.lang.Object

org.hornetq.jms.bridge.impl.JMSBridgeImpl

All Implemented Interfaces:

HornetQComponent, JMSBridge

public class JMSBridgeImpl
extends Object
implements HornetQComponent, JMSBridge

A JMSBridge

Version:

$Revision:4566 $ $Id:JMSBridge.java 4566 2008-06-24 08:01:35Z jmesnil $

Author:

Tim Fox

Constructor Summary

Constructors

Constructor and Description
JMSBridgeImpl()
JMSBridgeImpl(ConnectionFactoryFactory sourceCff, ConnectionFactoryFactory targetCff, DestinationFactory sourceDestinationFactory, DestinationFactory targetDestinationFactory, String sourceUsername, String sourcePassword, String targetUsername, String targetPassword, String selector, long failureRetryInterval, int maxRetries, QualityOfServiceMode qosMode, int maxBatchSize, long maxBatchTime, String subName, String clientID, boolean addMessageIDInHeader)
JMSBridgeImpl(ConnectionFactoryFactory sourceCff, ConnectionFactoryFactory targetCff, DestinationFactory sourceDestinationFactory, DestinationFactory targetDestinationFactory, String sourceUsername, String sourcePassword, String targetUsername, String targetPassword, String selector, long failureRetryInterval, int maxRetries, QualityOfServiceMode qosMode, int maxBatchSize, long maxBatchTime, String subName, String clientID, boolean addMessageIDInHeader, MBeanServer mbeanServer, String objectName)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
String	getClientID()
long	getFailureRetryInterval()
int	getMaxBatchSize()
long	getMaxBatchTime()
int	getMaxRetries()
QualityOfServiceMode	getQualityOfServiceMode()
String	getSelector()
DestinationFactory	getSourceDestinationFactory()
String	getSourcePassword()
String	getSourceUsername()
String	getSubscriptionName()
DestinationFactory	getTargetDestinationFactory()
String	getTargetPassword()
String	getTargetUsername()
String	getTransactionManagerLocatorClass()
String	getTransactionManagerLocatorMethod()
boolean	isAddMessageIDInHeader()
boolean	isFailed()
boolean	isPaused()
boolean	isStarted()
void	pause()
void	resume()
void	setAddMessageIDInHeader(boolean value)
void	setClientID(String clientID)
void	setFailureRetryInterval(long interval)
void	setMaxBatchSize(int size)
void	setMaxBatchTime(long time)
void	setMaxRetries(int retries)
void	setQualityOfServiceMode(QualityOfServiceMode mode)
void	setSelector(String selector)
void	setSourceConnectionFactoryFactory(ConnectionFactoryFactory cff)
void	setSourceDestinationFactory(DestinationFactory dest)
void	setSourcePassword(String pwd)
void	setSourceUsername(String name)
void	setSubscriptionName(String subname)
void	setTargetConnectionFactoryFactory(ConnectionFactoryFactory cff)
void	setTargetDestinationFactory(DestinationFactory dest)
void	setTargetPassword(String pwd)
void	setTargetUsername(String name)
void	setTransactionManager(TransactionManager tm)
void	setTransactionManagerLocatorClass(String transactionManagerLocatorClass)
void	setTransactionManagerLocatorMethod(String transactionManagerLocatorMethod)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSBridgeImpl

public JMSBridgeImpl()

JMSBridgeImpl

public JMSBridgeImpl(ConnectionFactoryFactory sourceCff,
             ConnectionFactoryFactory targetCff,
             DestinationFactory sourceDestinationFactory,
             DestinationFactory targetDestinationFactory,
             String sourceUsername,
             String sourcePassword,
             String targetUsername,
             String targetPassword,
             String selector,
             long failureRetryInterval,
             int maxRetries,
             QualityOfServiceMode qosMode,
             int maxBatchSize,
             long maxBatchTime,
             String subName,
             String clientID,
             boolean addMessageIDInHeader)

JMSBridgeImpl

public JMSBridgeImpl(ConnectionFactoryFactory sourceCff,
             ConnectionFactoryFactory targetCff,
             DestinationFactory sourceDestinationFactory,
             DestinationFactory targetDestinationFactory,
             String sourceUsername,
             String sourcePassword,
             String targetUsername,
             String targetPassword,
             String selector,
             long failureRetryInterval,
             int maxRetries,
             QualityOfServiceMode qosMode,
             int maxBatchSize,
             long maxBatchTime,
             String subName,
             String clientID,
             boolean addMessageIDInHeader,
             MBeanServer mbeanServer,
             String objectName)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

destroy

public void destroy()

pause

public void pause()
           throws Exception

Specified by:

pause in interface JMSBridge

Throws:

Exception

resume

public void resume()
            throws Exception

Specified by:

resume in interface JMSBridge

Throws:

Exception

getSourceDestinationFactory

public DestinationFactory getSourceDestinationFactory()

Specified by:

getSourceDestinationFactory in interface JMSBridge

setSourceDestinationFactory

public void setSourceDestinationFactory(DestinationFactory dest)

Specified by:

setSourceDestinationFactory in interface JMSBridge

getTargetDestinationFactory

public DestinationFactory getTargetDestinationFactory()

Specified by:

getTargetDestinationFactory in interface JMSBridge

setTargetDestinationFactory

public void setTargetDestinationFactory(DestinationFactory dest)

Specified by:

setTargetDestinationFactory in interface JMSBridge

getSourceUsername

public String getSourceUsername()

Specified by:

getSourceUsername in interface JMSBridge

setSourceUsername

public void setSourceUsername(String name)

Specified by:

setSourceUsername in interface JMSBridge

getSourcePassword

public String getSourcePassword()

Specified by:

getSourcePassword in interface JMSBridge

setSourcePassword

public void setSourcePassword(String pwd)

Specified by:

setSourcePassword in interface JMSBridge

getTargetUsername

public String getTargetUsername()

Specified by:

getTargetUsername in interface JMSBridge

setTargetUsername

public void setTargetUsername(String name)

Specified by:

setTargetUsername in interface JMSBridge

getTargetPassword

public String getTargetPassword()

Specified by:

getTargetPassword in interface JMSBridge

setTargetPassword

public void setTargetPassword(String pwd)

Specified by:

setTargetPassword in interface JMSBridge

getSelector

public String getSelector()

Specified by:

getSelector in interface JMSBridge

setSelector

public void setSelector(String selector)

Specified by:

setSelector in interface JMSBridge

getFailureRetryInterval

public long getFailureRetryInterval()

Specified by:

getFailureRetryInterval in interface JMSBridge

setFailureRetryInterval

public void setFailureRetryInterval(long interval)

Specified by:

setFailureRetryInterval in interface JMSBridge

getMaxRetries

public int getMaxRetries()

Specified by:

getMaxRetries in interface JMSBridge

setMaxRetries

public void setMaxRetries(int retries)

Specified by:

setMaxRetries in interface JMSBridge

getQualityOfServiceMode

public QualityOfServiceMode getQualityOfServiceMode()

Specified by:

getQualityOfServiceMode in interface JMSBridge

setQualityOfServiceMode

public void setQualityOfServiceMode(QualityOfServiceMode mode)

Specified by:

setQualityOfServiceMode in interface JMSBridge

getMaxBatchSize

public int getMaxBatchSize()

Specified by:

getMaxBatchSize in interface JMSBridge

setMaxBatchSize

public void setMaxBatchSize(int size)

Specified by:

setMaxBatchSize in interface JMSBridge

getMaxBatchTime

public long getMaxBatchTime()

Specified by:

getMaxBatchTime in interface JMSBridge

setMaxBatchTime

public void setMaxBatchTime(long time)

Specified by:

setMaxBatchTime in interface JMSBridge

getSubscriptionName

public String getSubscriptionName()

Specified by:

getSubscriptionName in interface JMSBridge

setSubscriptionName

public void setSubscriptionName(String subname)

Specified by:

setSubscriptionName in interface JMSBridge

getClientID

public String getClientID()

Specified by:

getClientID in interface JMSBridge

setClientID

public void setClientID(String clientID)

Specified by:

setClientID in interface JMSBridge

getTransactionManagerLocatorClass

public String getTransactionManagerLocatorClass()

Specified by:

getTransactionManagerLocatorClass in interface JMSBridge

setTransactionManagerLocatorClass

public void setTransactionManagerLocatorClass(String transactionManagerLocatorClass)

Specified by:

setTransactionManagerLocatorClass in interface JMSBridge

getTransactionManagerLocatorMethod

public String getTransactionManagerLocatorMethod()

Specified by:

getTransactionManagerLocatorMethod in interface JMSBridge

setTransactionManagerLocatorMethod

public void setTransactionManagerLocatorMethod(String transactionManagerLocatorMethod)

Specified by:

setTransactionManagerLocatorMethod in interface JMSBridge

isAddMessageIDInHeader

public boolean isAddMessageIDInHeader()

Specified by:

isAddMessageIDInHeader in interface JMSBridge

setAddMessageIDInHeader

public void setAddMessageIDInHeader(boolean value)

Specified by:

setAddMessageIDInHeader in interface JMSBridge

isPaused

public boolean isPaused()

Specified by:

isPaused in interface JMSBridge

isFailed

public boolean isFailed()

Specified by:

isFailed in interface JMSBridge

setSourceConnectionFactoryFactory

public void setSourceConnectionFactoryFactory(ConnectionFactoryFactory cff)

Specified by:

setSourceConnectionFactoryFactory in interface JMSBridge

setTargetConnectionFactoryFactory

public void setTargetConnectionFactoryFactory(ConnectionFactoryFactory cff)

Specified by:

setTargetConnectionFactoryFactory in interface JMSBridge

setTransactionManager

public void setTransactionManager(TransactionManager tm)

Specified by:

setTransactionManager in interface JMSBridge