org.jboss.messaging.jms.server.bridge
Class Bridge
java.lang.Object
org.jboss.messaging.jms.server.bridge.Bridge
- All Implemented Interfaces:
- MessagingComponent
public class Bridge
- extends java.lang.Object
- implements MessagingComponent
A Bridge
- Version:
- $Revision: 3799 $
$Id: Bridge.java 3799 2008-02-26 10:20:51Z timfox $
- Author:
- Tim Fox
Constructor Summary |
Bridge()
|
Bridge(ConnectionFactoryFactory sourceCff,
ConnectionFactoryFactory destCff,
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,
int 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 |
QOS_AT_MOST_ONCE
public static final int QOS_AT_MOST_ONCE
- See Also:
- Constant Field Values
QOS_DUPLICATES_OK
public static final int QOS_DUPLICATES_OK
- See Also:
- Constant Field Values
QOS_ONCE_AND_ONLY_ONCE
public static final int QOS_ONCE_AND_ONLY_ONCE
- See Also:
- Constant Field Values
Bridge
public Bridge()
Bridge
public Bridge(ConnectionFactoryFactory sourceCff,
ConnectionFactoryFactory destCff,
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,
int 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
pause
public void pause()
throws java.lang.Exception
- Throws:
java.lang.Exception
resume
public void resume()
throws java.lang.Exception
- Throws:
java.lang.Exception
getSourceDestinationFactory
public DestinationFactory getSourceDestinationFactory()
setSourceDestinationFactory
public void setSourceDestinationFactory(DestinationFactory dest)
getTargetDestinationFactory
public DestinationFactory getTargetDestinationFactory()
setTargetDestinationFactory
public void setTargetDestinationFactory(DestinationFactory dest)
getSourceUsername
public java.lang.String getSourceUsername()
setSourceUsername
public void setSourceUsername(java.lang.String name)
getSourcePassword
public java.lang.String getSourcePassword()
setSourcePassword
public void setSourcePassword(java.lang.String pwd)
getDestUsername
public java.lang.String getDestUsername()
setDestUserName
public void setDestUserName(java.lang.String name)
getDestPassword
public java.lang.String getDestPassword()
setDestPassword
public void setDestPassword(java.lang.String pwd)
getSelector
public java.lang.String getSelector()
setSelector
public void setSelector(java.lang.String selector)
getFailureRetryInterval
public long getFailureRetryInterval()
setFailureRetryInterval
public void setFailureRetryInterval(long interval)
getMaxRetries
public int getMaxRetries()
setMaxRetries
public void setMaxRetries(int retries)
getQualityOfServiceMode
public int getQualityOfServiceMode()
setQualityOfServiceMode
public void setQualityOfServiceMode(int mode)
getMaxBatchSize
public int getMaxBatchSize()
setMaxBatchSize
public void setMaxBatchSize(int size)
getMaxBatchTime
public long getMaxBatchTime()
setMaxBatchTime
public void setMaxBatchTime(long time)
getSubName
public java.lang.String getSubName()
setSubName
public void setSubName(java.lang.String subname)
getClientID
public java.lang.String getClientID()
setClientID
public void setClientID(java.lang.String clientID)
isAddMessageIDInHeader
public boolean isAddMessageIDInHeader()
setAddMessageIDInHeader
public void setAddMessageIDInHeader(boolean value)
isPaused
public boolean isPaused()
isFailed
public boolean isFailed()
isStarted
public boolean isStarted()
setSourceConnectionFactoryFactory
public void setSourceConnectionFactoryFactory(ConnectionFactoryFactory cff)
setDestConnectionFactoryFactory
public void setDestConnectionFactoryFactory(ConnectionFactoryFactory cff)
Copyright © 2006 JBoss Inc. All Rights Reserved.