org.apache.activemq.network
Class ForwardingBridge
java.lang.Object
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$
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ForwardingBridge
public ForwardingBridge(Transport localBroker,
Transport remoteBroker)
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 © 2011 Apache Software Foundation. All Rights Reserved.