org.jboss.messaging.jms.bridge.impl
Class JMSBridgeImpl
java.lang.Object
org.jboss.messaging.jms.bridge.impl.JMSBridgeImpl
- All Implemented Interfaces:
- MessagingComponent, JMSBridge
public class JMSBridgeImpl
- extends java.lang.Object
- implements MessagingComponent, JMSBridge
A JMSBridge
- Version:
- $Revision:4566 $
$Id:JMSBridge.java 4566 2008-06-24 08:01:35Z jmesnil $
- Author:
- Tim Fox
Constructor Summary |
JMSBridgeImpl()
|
JMSBridgeImpl(ConnectionFactoryFactory sourceCff,
ConnectionFactoryFactory targetCff,
DestinationFactory sourceDestinationFactory,
DestinationFactory targetDestinationFactory,
java.lang.String sourceUsername,
java.lang.String sourcePassword,
java.lang.String targetUsername,
java.lang.String targetPassword,
java.lang.String selector,
long failureRetryInterval,
int maxRetries,
QualityOfServiceMode qosMode,
int maxBatchSize,
long maxBatchTime,
java.lang.String subName,
java.lang.String clientID,
boolean addMessageIDInHeader)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSBridgeImpl
public JMSBridgeImpl()
JMSBridgeImpl
public JMSBridgeImpl(ConnectionFactoryFactory sourceCff,
ConnectionFactoryFactory targetCff,
DestinationFactory sourceDestinationFactory,
DestinationFactory targetDestinationFactory,
java.lang.String sourceUsername,
java.lang.String sourcePassword,
java.lang.String targetUsername,
java.lang.String targetPassword,
java.lang.String selector,
long failureRetryInterval,
int maxRetries,
QualityOfServiceMode qosMode,
int maxBatchSize,
long maxBatchTime,
java.lang.String subName,
java.lang.String clientID,
boolean addMessageIDInHeader)
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface MessagingComponent
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface MessagingComponent
- Throws:
java.lang.Exception
isStarted
public boolean isStarted()
- Specified by:
isStarted
in interface MessagingComponent
pause
public void pause()
throws java.lang.Exception
- Specified by:
pause
in interface JMSBridge
- Throws:
java.lang.Exception
resume
public void resume()
throws java.lang.Exception
- Specified by:
resume
in interface JMSBridge
- Throws:
java.lang.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 java.lang.String getSourceUsername()
- Specified by:
getSourceUsername
in interface JMSBridge
setSourceUsername
public void setSourceUsername(java.lang.String name)
- Specified by:
setSourceUsername
in interface JMSBridge
getSourcePassword
public java.lang.String getSourcePassword()
- Specified by:
getSourcePassword
in interface JMSBridge
setSourcePassword
public void setSourcePassword(java.lang.String pwd)
- Specified by:
setSourcePassword
in interface JMSBridge
getTargetUsername
public java.lang.String getTargetUsername()
- Specified by:
getTargetUsername
in interface JMSBridge
setTargetUsername
public void setTargetUsername(java.lang.String name)
- Specified by:
setTargetUsername
in interface JMSBridge
getTargetPassword
public java.lang.String getTargetPassword()
- Specified by:
getTargetPassword
in interface JMSBridge
setTargetPassword
public void setTargetPassword(java.lang.String pwd)
- Specified by:
setTargetPassword
in interface JMSBridge
getSelector
public java.lang.String getSelector()
- Specified by:
getSelector
in interface JMSBridge
setSelector
public void setSelector(java.lang.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 java.lang.String getSubscriptionName()
- Specified by:
getSubscriptionName
in interface JMSBridge
setSubscriptionName
public void setSubscriptionName(java.lang.String subname)
- Specified by:
setSubscriptionName
in interface JMSBridge
getClientID
public java.lang.String getClientID()
- Specified by:
getClientID
in interface JMSBridge
setClientID
public void setClientID(java.lang.String clientID)
- Specified by:
setClientID
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(javax.transaction.TransactionManager tm)
- Specified by:
setTransactionManager
in interface JMSBridge
Copyright © 2006 JBoss Inc. All Rights Reserved.