org.apache.activemq.network
Class ForwardingBridge

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

public class ForwardingBridge
extends java.lang.Object
implements Bridge

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

Version:
$Revision$

Constructor Summary
ForwardingBridge(Transport localBroker, Transport remoteBroker)
           
 
Method Summary
 java.lang.String getClientId()
           
 java.lang.String getDestinationFilter()
           
 int getPrefetchSize()
           
 boolean isDispatchAsync()
           
protected  void serviceLocalCommand(Command command)
           
protected  void serviceLocalException(java.lang.Throwable error)
           
protected  void serviceRemoteCommand(Command command)
           
protected  void serviceRemoteException(java.io.IOException error)
           
 void setClientId(java.lang.String clientId)
           
 void setDestinationFilter(java.lang.String destinationFilter)
           
 void setDispatchAsync(boolean dispatchAsync)
           
 void setPrefetchSize(int prefetchSize)
           
 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

protected void serviceRemoteException(java.io.IOException error)

serviceRemoteCommand

protected void serviceRemoteCommand(Command command)

serviceLocalException

protected 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)


Copyright © 2009 Apache Software Foundation. All Rights Reserved.