org.apache.activemq.network

Class ForwardingBridge

java.lang.Object

org.apache.activemq.network.ForwardingBridge

All Implemented Interfaces:

Service

public class ForwardingBridge
extends java.lang.Object
implements Service

Forwards all messages from the local broker to the remote broker.

Constructor Summary

Constructors

Constructor and Description
ForwardingBridge(Transport localBroker, Transport remoteBroker)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getClientId()
long	getDequeueCounter()
java.lang.String	getDestinationFilter()
long	getEnqueueCounter()
java.lang.String	getLocalAddress()
java.lang.String	getLocalBrokerName()
int	getPrefetchSize()
java.lang.String	getRemoteAddress()
java.lang.String	getRemoteBrokerName()
boolean	isDispatchAsync()
boolean	isUseCompression()
protected void	serviceLocalCommand(Command command)
void	serviceLocalException(java.lang.Throwable error)
protected void	serviceRemoteCommand(Command command)
void	serviceRemoteException(java.lang.Throwable error)
void	setClientId(java.lang.String clientId)
void	setDestinationFilter(java.lang.String destinationFilter)
void	setDispatchAsync(boolean dispatchAsync)
void	setNetworkBridgeFailedListener(NetworkBridgeListener listener)
void	setPrefetchSize(int prefetchSize)
void	setUseCompression(boolean useCompression)
void	start()
void	stop()
protected void	triggerStartBridge()

Methods inherited from class java.lang.Object

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

Constructor Detail

ForwardingBridge

public ForwardingBridge(Transport localBroker,
                Transport remoteBroker)

Method Detail

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Service

Throws:

java.lang.Exception

triggerStartBridge

protected void triggerStartBridge()
                           throws java.io.IOException

Throws:

java.io.IOException

stop

public void stop()
          throws java.lang.Exception

Specified by:

stop in interface Service

Throws:

java.lang.Exception

serviceRemoteException

public void serviceRemoteException(java.lang.Throwable error)

serviceRemoteCommand

protected void serviceRemoteCommand(Command command)

serviceLocalException

public void serviceLocalException(java.lang.Throwable error)

serviceLocalCommand

protected void serviceLocalCommand(Command command)

getClientId

public java.lang.String getClientId()

setClientId

public void setClientId(java.lang.String clientId)

getPrefetchSize

public int getPrefetchSize()

setPrefetchSize

public void setPrefetchSize(int prefetchSize)

isDispatchAsync

public boolean isDispatchAsync()

setDispatchAsync

public void setDispatchAsync(boolean dispatchAsync)

getDestinationFilter

public java.lang.String getDestinationFilter()

setDestinationFilter

public void setDestinationFilter(java.lang.String destinationFilter)

setNetworkBridgeFailedListener

public void setNetworkBridgeFailedListener(NetworkBridgeListener listener)

getRemoteAddress

public java.lang.String getRemoteAddress()

getLocalAddress

public java.lang.String getLocalAddress()

getLocalBrokerName

public java.lang.String getLocalBrokerName()

getRemoteBrokerName

public java.lang.String getRemoteBrokerName()

getDequeueCounter

public long getDequeueCounter()

getEnqueueCounter

public long getEnqueueCounter()

setUseCompression

public void setUseCompression(boolean useCompression)

Parameters:

useCompression - True if forwarded Messages should have their bodies compressed.

isUseCompression

public boolean isUseCompression()

Returns:

the vale of the useCompression setting, true if forwarded messages will be compressed.