org.apache.activemq.network
Class ForwardingBridge

java.lang.Object
  extended by org.apache.activemq.network.ForwardingBridge
All Implemented Interfaces:
Service

public class ForwardingBridge
extends Object
implements Service

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


Constructor Summary
ForwardingBridge(Transport localBroker, Transport remoteBroker)
           
 
Method Summary
 String getClientId()
           
 long getDequeueCounter()
           
 String getDestinationFilter()
           
 long getEnqueueCounter()
           
 String getLocalAddress()
           
 String getLocalBrokerName()
           
 int getPrefetchSize()
           
 String getRemoteAddress()
           
 String getRemoteBrokerName()
           
 boolean isDispatchAsync()
           
 boolean isUseCompression()
           
protected  void serviceLocalCommand(Command command)
           
 void serviceLocalException(Throwable error)
           
protected  void serviceRemoteCommand(Command command)
           
 void serviceRemoteException(Throwable error)
           
 void setClientId(String clientId)
           
 void setDestinationFilter(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 Exception
Specified by:
start in interface Service
Throws:
Exception

triggerStartBridge

protected void triggerStartBridge()
                           throws IOException
Throws:
IOException

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Throws:
Exception

serviceRemoteException

public void serviceRemoteException(Throwable error)

serviceRemoteCommand

protected void serviceRemoteCommand(Command command)

serviceLocalException

public void serviceLocalException(Throwable error)

serviceLocalCommand

protected void serviceLocalCommand(Command command)

getClientId

public String getClientId()

setClientId

public void setClientId(String clientId)

getPrefetchSize

public int getPrefetchSize()

setPrefetchSize

public void setPrefetchSize(int prefetchSize)

isDispatchAsync

public boolean isDispatchAsync()

setDispatchAsync

public void setDispatchAsync(boolean dispatchAsync)

getDestinationFilter

public String getDestinationFilter()

setDestinationFilter

public void setDestinationFilter(String destinationFilter)

setNetworkBridgeFailedListener

public void setNetworkBridgeFailedListener(NetworkBridgeListener listener)

getRemoteAddress

public String getRemoteAddress()

getLocalAddress

public String getLocalAddress()

getLocalBrokerName

public String getLocalBrokerName()

getRemoteBrokerName

public 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.


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.