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.
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
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()
Copyright © 2005-2012. All Rights Reserved.